|
@@ -96,11 +96,9 @@ hv_set_next_write_location(struct hv_ring_buffer_info *ring_info,
|
|
|
|
|
|
/* Get the next read location for the specified ring buffer. */
|
|
/* Get the next read location for the specified ring buffer. */
|
|
static inline u32
|
|
static inline u32
|
|
-hv_get_next_read_location(struct hv_ring_buffer_info *ring_info)
|
|
|
|
|
|
+hv_get_next_read_location(const struct hv_ring_buffer_info *ring_info)
|
|
{
|
|
{
|
|
- u32 next = ring_info->ring_buffer->read_index;
|
|
|
|
-
|
|
|
|
- return next;
|
|
|
|
|
|
+ return ring_info->ring_buffer->read_index;
|
|
}
|
|
}
|
|
|
|
|
|
/*
|
|
/*
|
|
@@ -108,8 +106,8 @@ hv_get_next_read_location(struct hv_ring_buffer_info *ring_info)
|
|
* This allows the caller to skip.
|
|
* This allows the caller to skip.
|
|
*/
|
|
*/
|
|
static inline u32
|
|
static inline u32
|
|
-hv_get_next_readlocation_withoffset(struct hv_ring_buffer_info *ring_info,
|
|
|
|
- u32 offset)
|
|
|
|
|
|
+hv_get_next_readlocation_withoffset(const struct hv_ring_buffer_info *ring_info,
|
|
|
|
+ u32 offset)
|
|
{
|
|
{
|
|
u32 next = ring_info->ring_buffer->read_index;
|
|
u32 next = ring_info->ring_buffer->read_index;
|
|
|
|
|
|
@@ -130,7 +128,7 @@ hv_set_next_read_location(struct hv_ring_buffer_info *ring_info,
|
|
|
|
|
|
/* Get the size of the ring buffer. */
|
|
/* Get the size of the ring buffer. */
|
|
static inline u32
|
|
static inline u32
|
|
-hv_get_ring_buffersize(struct hv_ring_buffer_info *ring_info)
|
|
|
|
|
|
+hv_get_ring_buffersize(const struct hv_ring_buffer_info *ring_info)
|
|
{
|
|
{
|
|
return ring_info->ring_datasize;
|
|
return ring_info->ring_datasize;
|
|
}
|
|
}
|
|
@@ -147,7 +145,7 @@ hv_get_ring_bufferindices(struct hv_ring_buffer_info *ring_info)
|
|
* Assume there is enough room. Handles wrap-around in src case only!!
|
|
* Assume there is enough room. Handles wrap-around in src case only!!
|
|
*/
|
|
*/
|
|
static u32 hv_copyfrom_ringbuffer(
|
|
static u32 hv_copyfrom_ringbuffer(
|
|
- struct hv_ring_buffer_info *ring_info,
|
|
|
|
|
|
+ const struct hv_ring_buffer_info *ring_info,
|
|
void *dest,
|
|
void *dest,
|
|
u32 destlen,
|
|
u32 destlen,
|
|
u32 start_read_offset)
|
|
u32 start_read_offset)
|
|
@@ -171,7 +169,7 @@ static u32 hv_copyfrom_ringbuffer(
|
|
static u32 hv_copyto_ringbuffer(
|
|
static u32 hv_copyto_ringbuffer(
|
|
struct hv_ring_buffer_info *ring_info,
|
|
struct hv_ring_buffer_info *ring_info,
|
|
u32 start_write_offset,
|
|
u32 start_write_offset,
|
|
- void *src,
|
|
|
|
|
|
+ const void *src,
|
|
u32 srclen)
|
|
u32 srclen)
|
|
{
|
|
{
|
|
void *ring_buffer = hv_get_ring_buffer(ring_info);
|
|
void *ring_buffer = hv_get_ring_buffer(ring_info);
|
|
@@ -186,8 +184,8 @@ static u32 hv_copyto_ringbuffer(
|
|
}
|
|
}
|
|
|
|
|
|
/* Get various debug metrics for the specified ring buffer. */
|
|
/* Get various debug metrics for the specified ring buffer. */
|
|
-void hv_ringbuffer_get_debuginfo(struct hv_ring_buffer_info *ring_info,
|
|
|
|
- struct hv_ring_buffer_debug_info *debug_info)
|
|
|
|
|
|
+void hv_ringbuffer_get_debuginfo(const struct hv_ring_buffer_info *ring_info,
|
|
|
|
+ struct hv_ring_buffer_debug_info *debug_info)
|
|
{
|
|
{
|
|
u32 bytes_avail_towrite;
|
|
u32 bytes_avail_towrite;
|
|
u32 bytes_avail_toread;
|
|
u32 bytes_avail_toread;
|
|
@@ -264,7 +262,7 @@ void hv_ringbuffer_cleanup(struct hv_ring_buffer_info *ring_info)
|
|
|
|
|
|
/* Write to the ring buffer. */
|
|
/* Write to the ring buffer. */
|
|
int hv_ringbuffer_write(struct vmbus_channel *channel,
|
|
int hv_ringbuffer_write(struct vmbus_channel *channel,
|
|
- struct kvec *kv_list, u32 kv_count)
|
|
|
|
|
|
+ const struct kvec *kv_list, u32 kv_count)
|
|
{
|
|
{
|
|
int i = 0;
|
|
int i = 0;
|
|
u32 bytes_avail_towrite;
|
|
u32 bytes_avail_towrite;
|