1 files changed, 56 insertions, 0 deletions
diff --git a/src/cache.c b/src/cache.c
new file mode 100644
index 0000000..c88cc78
--- /dev/null
+++ b/src/cache.c
@@ -0,0 +1,56 @@
+/* SPDX-License-Identifier: LGPL-2.1-only */
+
+/* Copyright (C) 2020 Gediminas Jakutis */
+
+#include <errno.h>
+#include <stdlib.h>
+#include "defs.h"
+
+int cache_create(struct stream * const restrict in, const struct settings * const restrict s)
+{
+	int ret;
+	void *cache;
+
+	try(!(cache = calloc(in->n, s->stride)), err, ENOMEM);
+
+	in->cache = cache;
+err:
+	return ret;
+}
+
+int cache_populate(struct stream * const restrict in)
+{
+	int ret = 0;
+	ssize_t i;
+
+	for (i = 0; i < in->n; ++i) {
+		try_s((ret = in->get_element(in, i, in->cache + i)), err);
+	}
+
+err:
+	return ret;
+}
+
+int cache_flush(struct stream * const in)
+{
+	int ret;
+	ssize_t i;
+
+	for (i = 0; i < in->n; ++i) {
+		try_s((ret = in->put_element(in, i, in->cache + i)), err);
+	}
+
+err:
+	return ret;
+}
+
+int cache_destroy(struct stream * const in)
+{
+	int ret;
+
+	try(!in->cache, err, EINVAL);
+	free(in->cache);
+	in->cache = NULL;
+err:
+	return ret;
+}