Lines Matching full:outgoing

227  * For replies, find matching outgoing request and wake any waiters.
442     msg = QTAILQ_FIRST(&proxy->outgoing);  in vfio_user_send_one()
448     QTAILQ_REMOVE(&proxy->outgoing, msg, next);  in vfio_user_send_one()
461  * Send messages from outgoing queue when the socket buffer has space.
462  * If we deplete 'outgoing', remove ourselves from the poll list.
471         while (!QTAILQ_EMPTY(&proxy->outgoing)) {  in vfio_user_send()
556  * Messages are queued onto the proxy's outgoing list.
569  * They transition from the outgoing list to the pending list
575  * They also transition from outgoing to pending when sent, but
579  * As an optimization, if the outgoing list and the socket send
581  * added to the outgoing list.  The rest of the transitions are
596      * Unsent outgoing msgs - add to tail  in vfio_user_send_queued()
598     if (!QTAILQ_EMPTY(&proxy->outgoing)) {  in vfio_user_send_queued()
599         QTAILQ_INSERT_TAIL(&proxy->outgoing, msg, next);  in vfio_user_send_queued()
614         QTAILQ_INSERT_HEAD(&proxy->outgoing, msg, next);  in vfio_user_send_queued()
707                 list = msg->pending ? &proxy->pending : &proxy->outgoing;  in vfio_user_send_wait()
780                 list = msg->pending ? &proxy->pending : &proxy->outgoing;  in vfio_user_wait_reqs()
919     QTAILQ_INIT(&proxy->outgoing);  in vfio_user_connect_dev()
959     QTAILQ_FOREACH_SAFE(r1, &proxy->outgoing, next, r2) {  in vfio_user_disconnect()
961         QTAILQ_REMOVE(&proxy->outgoing, r1, next);  in vfio_user_disconnect()