Lines Matching defs:kvp_transaction
83 } kvp_transaction;
115 kvp_transaction.state = HVUTIL_READY;
127 hv_poll_channel(kvp_transaction.recv_channel, kvp_poll_wrapper);
158 hv_poll_channel(kvp_transaction.recv_channel, kvp_poll_wrapper);
163 tasklet_schedule(&kvp_transaction.recv_channel->callback_event);
213 if (kvp_transaction.state < HVUTIL_READY) {
218 if (kvp_transaction.state < HVUTIL_USERSPACE_REQ)
221 kvp_transaction.state = HVUTIL_USERSPACE_RECV;
254 hv_poll_channel(kvp_transaction.recv_channel, kvp_poll_wrapper);
378 __u8 operation = kvp_transaction.kvp_msg->kvp_hdr.operation;
379 __u8 pool = kvp_transaction.kvp_msg->kvp_hdr.pool;
385 if (kvp_transaction.state != HVUTIL_HOSTMSG_RECEIVED)
394 in_msg = kvp_transaction.kvp_msg;
496 kvp_transaction.state = HVUTIL_USERSPACE_REQ;
502 kvp_transaction.state = HVUTIL_READY;
533 buf_len = kvp_transaction.recv_len;
534 channel = kvp_transaction.recv_channel;
535 req_id = kvp_transaction.recv_req_id;
565 switch (kvp_transaction.kvp_msg->kvp_hdr.operation) {
649 if (kvp_transaction.state < HVUTIL_READY) {
662 if (kvp_transaction.state > HVUTIL_READY)
691 kvp_transaction.recv_len = recvlen;
692 kvp_transaction.recv_req_id = requestid;
693 kvp_transaction.kvp_msg = kvp_msg;
695 if (kvp_transaction.state < HVUTIL_READY) {
700 kvp_transaction.state = HVUTIL_HOSTMSG_RECEIVED;
727 hv_poll_channel(kvp_transaction.recv_channel, kvp_poll_wrapper);
736 kvp_transaction.state = HVUTIL_DEVICE_INIT;
743 kvp_transaction.recv_channel = srv->channel;
751 kvp_transaction.state = HVUTIL_DEVICE_INIT;
770 struct vmbus_channel *channel = kvp_transaction.recv_channel;
787 kvp_transaction.state = HVUTIL_READY;
793 struct vmbus_channel *channel = kvp_transaction.recv_channel;
802 kvp_transaction.state = HVUTIL_DEVICE_DYING;