65 	struct hv_ring_buffer_info *rbi = &channel->outbound;  in hv_signal_on_write()  local
68 	if (READ_ONCE(rbi->ring_buffer->interrupt_mask))  in hv_signal_on_write()
77 	if (old_write == READ_ONCE(rbi->ring_buffer->read_index))  in hv_signal_on_write()
151 hv_get_ringbuffer_availbytes(const struct hv_ring_buffer_info *rbi,  in hv_get_ringbuffer_availbytes()  argument
157 	read_loc = READ_ONCE(rbi->ring_buffer->read_index);  in hv_get_ringbuffer_availbytes()
158 	write_loc = READ_ONCE(rbi->ring_buffer->write_index);  in hv_get_ringbuffer_availbytes()
159 	dsize = rbi->ring_datasize;  in hv_get_ringbuffer_availbytes()
366 static u32 hv_pkt_iter_avail(const struct hv_ring_buffer_info *rbi)  in hv_pkt_iter_avail()  argument
368 	u32 priv_read_loc = rbi->priv_read_index;  in hv_pkt_iter_avail()
369 	u32 write_loc = READ_ONCE(rbi->ring_buffer->write_index);  in hv_pkt_iter_avail()
374 		return (rbi->ring_datasize - priv_read_loc) + write_loc;  in hv_pkt_iter_avail()
384 	struct hv_ring_buffer_info *rbi = &channel->inbound;  in hv_pkt_iter_first()  local
387 	if (hv_pkt_iter_avail(rbi) < sizeof(struct vmpacket_descriptor))  in hv_pkt_iter_first()
390 	desc = hv_get_ring_buffer(rbi) + rbi->priv_read_index;  in hv_pkt_iter_first()
408 	struct hv_ring_buffer_info *rbi = &channel->inbound;  in __hv_pkt_iter_next()  local
410 	u32 dsize = rbi->ring_datasize;  in __hv_pkt_iter_next()
413 	rbi->priv_read_index += packetlen + VMBUS_PKT_TRAILER;  in __hv_pkt_iter_next()
414 	if (rbi->priv_read_index >= dsize)  in __hv_pkt_iter_next()
415 		rbi->priv_read_index -= dsize;  in __hv_pkt_iter_next()
423 static u32 hv_pkt_iter_bytes_read(const struct hv_ring_buffer_info *rbi,  in hv_pkt_iter_bytes_read()  argument
426 	if (rbi->priv_read_index >= start_read_index)  in hv_pkt_iter_bytes_read()
427 		return rbi->priv_read_index - start_read_index;  in hv_pkt_iter_bytes_read()
429 		return rbi->ring_datasize - start_read_index +  in hv_pkt_iter_bytes_read()
430 			rbi->priv_read_index;  in hv_pkt_iter_bytes_read()
455 	struct hv_ring_buffer_info *rbi = &channel->inbound;  in hv_pkt_iter_close()  local
464 	start_read_index = rbi->ring_buffer->read_index;  in hv_pkt_iter_close()
465 	rbi->ring_buffer->read_index = rbi->priv_read_index;  in hv_pkt_iter_close()
472 	if (!rbi->ring_buffer->feature_bits.feat_pending_send_sz)  in hv_pkt_iter_close()
491 	pending_sz = READ_ONCE(rbi->ring_buffer->pending_send_sz);  in hv_pkt_iter_close()
500 	curr_write_sz = hv_get_bytes_to_write(rbi);  in hv_pkt_iter_close()
501 	bytes_read = hv_pkt_iter_bytes_read(rbi, start_read_index);  in hv_pkt_iter_close()