Lines Matching refs:hvs
242 struct hvsock *hvs = vsk->trans;
243 struct vmbus_channel *chan = hvs->chan;
294 struct hvsock *hvs = NULL;
344 hvs = vsock_sk(sk)->trans;
345 hvs->chan = chan;
382 hvs->chan = NULL;
433 struct hvsock *hvs;
436 hvs = kzalloc(sizeof(*hvs), GFP_KERNEL);
437 if (!hvs)
440 vsk->trans = hvs;
441 hvs->vsk = vsk;
463 static void hvs_shutdown_lock_held(struct hvsock *hvs, int mode)
467 if (hvs->fin_sent || !hvs->chan)
471 (void)hvs_send_data(hvs->chan, (struct hvs_send_buf *)&hdr, 0);
472 hvs->fin_sent = true;
534 struct hvsock *hvs = vsk->trans;
535 struct vmbus_channel *chan = hvs->chan;
540 kfree(hvs);
566 static int hvs_update_recv_data(struct hvsock *hvs)
571 recv_buf = (struct hvs_recv_buf *)(hvs->recv_desc + 1);
578 hvs->vsk->peer_shutdown |= SEND_SHUTDOWN;
580 hvs->recv_data_len = payload_len;
581 hvs->recv_data_off = 0;
589 struct hvsock *hvs = vsk->trans;
590 bool need_refill = !hvs->recv_desc;
599 hvs->recv_desc = hv_pkt_iter_first(hvs->chan);
600 ret = hvs_update_recv_data(hvs);
605 recv_buf = (struct hvs_recv_buf *)(hvs->recv_desc + 1);
606 to_read = min_t(u32, len, hvs->recv_data_len);
607 ret = memcpy_to_msg(msg, recv_buf->data + hvs->recv_data_off, to_read);
611 hvs->recv_data_len -= to_read;
612 if (hvs->recv_data_len == 0) {
613 hvs->recv_desc = hv_pkt_iter_next(hvs->chan, hvs->recv_desc);
614 if (hvs->recv_desc) {
615 ret = hvs_update_recv_data(hvs);
620 hvs->recv_data_off += to_read;
629 struct hvsock *hvs = vsk->trans;
630 struct vmbus_channel *chan = hvs->chan;
659 ret = hvs_send_data(hvs->chan, send_buf, to_write);
676 struct hvsock *hvs = vsk->trans;
679 if (hvs->recv_data_len > 0)
682 switch (hvs_channel_readable_payload(hvs->chan)) {
700 struct hvsock *hvs = vsk->trans;
702 return hvs_channel_writable_bytes(hvs->chan);
712 struct hvsock *hvs = vsk->trans;
714 return hvs->chan != NULL;
728 struct hvsock *hvs = vsk->trans;
730 *readable = hvs_channel_readable(hvs->chan);