Lines Matching defs:dev_sc
389 hv_vss_notified(struct hv_vss_dev_sc *dev_sc, struct hv_vss_opt_msg *userdata)
392 mtx_lock(&dev_sc->sc->pending_mutex);
393 if (!STAILQ_EMPTY(&dev_sc->to_notify_queue)) {
394 reqp = STAILQ_FIRST(&dev_sc->to_notify_queue);
396 STAILQ_REMOVE_HEAD(&dev_sc->to_notify_queue, slink);
398 STAILQ_INSERT_TAIL(&dev_sc->to_ack_queue, reqp, slink);
405 mtx_unlock(&dev_sc->sc->pending_mutex);
409 hv_vss_notify(struct hv_vss_dev_sc *dev_sc, struct hv_vss_req_internal *reqp)
412 mtx_lock(&dev_sc->sc->pending_mutex);
413 STAILQ_INSERT_TAIL(&dev_sc->to_notify_queue, reqp, slink);
416 &dev_sc->sc->app_sc == dev_sc ? "app" : "daemon");
417 mtx_unlock(&dev_sc->sc->pending_mutex);
418 selwakeup(&dev_sc->hv_vss_selinfo);
425 hv_vss_daemon_acked(struct hv_vss_dev_sc *dev_sc, struct hv_vss_opt_msg *userdata)
438 mtx_lock(&dev_sc->sc->pending_mutex);
439 SEARCH_REMOVE_REQ_LOCKED(reqp, &dev_sc->to_ack_queue, slink, tmp, req_id);
440 mtx_unlock(&dev_sc->sc->pending_mutex);
458 if (dev_sc->sc->app_register_done) {
460 hv_vss_notify(&dev_sc->sc->app_sc, reqp);
479 hv_vss_app_acked(struct hv_vss_dev_sc *dev_sc, struct hv_vss_opt_msg *userdata)
492 mtx_lock(&dev_sc->sc->pending_mutex);
493 SEARCH_REMOVE_REQ_LOCKED(reqp, &dev_sc->to_ack_queue, slink, tmp, req_id);
494 mtx_unlock(&dev_sc->sc->pending_mutex);
504 if (dev_sc->sc->register_done) {
509 hv_vss_notify(&dev_sc->sc->daemon_sc, reqp);
533 struct hv_vss_dev_sc *dev_sc = (struct hv_vss_dev_sc*)dev->si_drv1;
537 if (dev_sc->sc->register_done)
540 dev_sc->sc->register_done = true;
541 hv_vss_callback(vmbus_get_channel(dev_sc->sc->dev), dev_sc->sc);
543 dev_sc->proc_task = curproc;
554 struct hv_vss_dev_sc *dev_sc = (struct hv_vss_dev_sc*)dev->si_drv1;
558 dev_sc->sc->register_done = false;
594 struct hv_vss_dev_sc *dev_sc = (struct hv_vss_dev_sc*)dev->si_drv1;
596 mtx_lock(&dev_sc->sc->pending_mutex);
600 if (!STAILQ_EMPTY(&dev_sc->to_notify_queue))
603 selrecord(td, &dev_sc->hv_vss_selinfo);
605 mtx_unlock(&dev_sc->sc->pending_mutex);
615 struct hv_vss_dev_sc *dev_sc = (struct hv_vss_dev_sc*)dev->si_drv1;
619 if (dev_sc->sc->app_register_done)
622 dev_sc->sc->app_register_done = true;
623 dev_sc->proc_task = curproc;
634 struct hv_vss_dev_sc *dev_sc = (struct hv_vss_dev_sc*)dev->si_drv1;
638 dev_sc->sc->app_register_done = false;
647 struct hv_vss_dev_sc *dev_sc;
650 dev_sc = (struct hv_vss_dev_sc*)dev->si_drv1;
657 hv_vss_notified(dev_sc, userdata);
660 hv_vss_app_acked(dev_sc, userdata);
674 struct hv_vss_dev_sc *dev_sc = (struct hv_vss_dev_sc*)dev->si_drv1;
676 mtx_lock(&dev_sc->sc->pending_mutex);
680 if (!STAILQ_EMPTY(&dev_sc->to_notify_queue))
683 selrecord(td, &dev_sc->hv_vss_selinfo);
685 mtx_unlock(&dev_sc->sc->pending_mutex);