now with generating lists!

Signed-off-by: Gediminas Jakutis <gediminas@varciai.lt>

1 files changed, 27 insertions, 3 deletions

diff --git a/src/io.c b/src/io.c
index 41c5880..9dae2e1 100644
--- a/src/io.c
+++ b/src/io.c
@@ -218,11 +218,35 @@ err:
 
 int stream_flush_list(struct stream * const in)
 {
-	int ret = ENOSYS;
+	ssize_t ret = 0;
+	size_t remaining;
+	ssize_t written;
+	size_t i;
+
+	/* adjust pointers to have a base starting at 0, to cater to disk storage format.
+	 * File offsets are otherwise 1:1 to memory addresses, which is neat.
+	 * Just don't process the last offset, as that is always NULL/zero.
+	 * */
 
-	(void) in;
+	for (i = 0; i < (in->n - 1); ++i) {
+		in->cache_l[i].offset = (char *) in->cache_l[i].next - in->cache;
+	}
 
-	rin_warn("stub!");
+	/* dump the bloody list */
+	written = 0;
+	remaining = in->n * in->settings->stride;
 
+	do {
+		ret = write(in->fd, in->cache + written, remaining);
+		if (ret < 0) {
+			try(errno != EAGAIN, err, errno, "Writing to stream failed with %zi", ret);
+		} else {
+			written += ret;
+			remaining -= ret;
+			ret = 0;
+		}
+	} while (remaining);
+
+err:
 	return ret;
 }