X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=lib%2Fringbuffer%2Fring_buffer_iterator.c;fp=lib%2Fringbuffer%2Fring_buffer_iterator.c;h=286831a14f33c10a552b1b4d6b8d38df77ada752;hb=63629d862e5c6010d362dc30f2e8721221ef0dd5;hp=d25db72502756b96a7bc3d65ebb33da635436023;hpb=721caea47b6506f7ad9086c3e9801dc9dfe06b6a;p=deliverable%2Flttng-modules.git

diff --git a/lib/ringbuffer/ring_buffer_iterator.c b/lib/ringbuffer/ring_buffer_iterator.c
index d25db725..286831a1 100644
--- a/lib/ringbuffer/ring_buffer_iterator.c
+++ b/lib/ringbuffer/ring_buffer_iterator.c
@@ -105,6 +105,24 @@ restart:
 }
 EXPORT_SYMBOL_GPL(lib_ring_buffer_get_next_record);
 
+void lib_ring_buffer_put_current_record(struct lib_ring_buffer *buf)
+{
+	struct lib_ring_buffer_iter *iter;
+
+	if (!buf)
+		return;
+	iter = &buf->iter;
+	if (iter->state != ITER_NEXT_RECORD)
+		return;
+	iter->read_offset += iter->payload_len;
+	iter->state = ITER_TEST_RECORD;
+	if (iter->read_offset - iter->consumed >= iter->data_size) {
+		lib_ring_buffer_put_next_subbuf(buf);
+		iter->state = ITER_GET_SUBBUF;
+	}
+}
+EXPORT_SYMBOL_GPL(lib_ring_buffer_put_current_record);
+
 static int buf_is_higher(void *a, void *b)
 {
 	struct lib_ring_buffer *bufa = a;
@@ -696,12 +714,14 @@ skip_get_next:
 			return -EFAULT;
 		}
 		read_count += copy_len;
-	};
-	return read_count;
+	}
+	goto put_record;
 
 nodata:
 	*ppos = 0;
 	chan->iter.len_left = 0;
+put_record:
+	lib_ring_buffer_put_current_record(buf);
 	return read_count;
 }