1 files changed, 88 insertions, 0 deletions
diff --git a/database/engine/datafile.h b/database/engine/datafile.h
new file mode 100644
index 00000000..569f1b0a
--- /dev/null
+++ b/database/engine/datafile.h
@@ -0,0 +1,88 @@
+// SPDX-License-Identifier: GPL-3.0-or-later
+
+#ifndef NETDATA_DATAFILE_H
+#define NETDATA_DATAFILE_H
+
+#include "rrdengine.h"
+
+/* Forward declarations */
+struct rrdengine_datafile;
+struct rrdengine_journalfile;
+struct rrdengine_instance;
+
+#define DATAFILE_PREFIX "datafile-"
+#define DATAFILE_EXTENSION ".ndf"
+
+#ifndef MAX_DATAFILE_SIZE
+#define MAX_DATAFILE_SIZE   (512LU * 1024LU * 1024LU)
+#endif
+#if  MIN_DATAFILE_SIZE > MAX_DATAFILE_SIZE
+#error MIN_DATAFILE_SIZE > MAX_DATAFILE_SIZE
+#endif
+
+#define MIN_DATAFILE_SIZE   (4LU * 1024LU * 1024LU)
+#define MAX_DATAFILES (65536 * 4) /* Supports up to 64TiB for now */
+#define TARGET_DATAFILES (50)
+
+typedef enum __attribute__ ((__packed__)) {
+    DATAFILE_ACQUIRE_OPEN_CACHE = 0,
+    DATAFILE_ACQUIRE_PAGE_DETAILS,
+    DATAFILE_ACQUIRE_RETENTION,
+
+    // terminator
+    DATAFILE_ACQUIRE_MAX,
+} DATAFILE_ACQUIRE_REASONS;
+
+/* only one event loop is supported for now */
+struct rrdengine_datafile {
+    unsigned tier;
+    unsigned fileno;
+    uv_file file;
+    uint64_t pos;
+    uv_rwlock_t extent_rwlock;
+    struct rrdengine_instance *ctx;
+    struct rrdengine_journalfile *journalfile;
+    struct rrdengine_datafile *prev;
+    struct rrdengine_datafile *next;
+
+    struct {
+        SPINLOCK spinlock;
+        bool populated;
+    } populate_mrg;
+
+    struct {
+        SPINLOCK spinlock;
+        size_t running;
+        size_t flushed_to_open_running;
+    } writers;
+
+    struct {
+        SPINLOCK spinlock;
+        unsigned lockers;
+        unsigned lockers_by_reason[DATAFILE_ACQUIRE_MAX];
+        bool available;
+        time_t time_to_evict;
+    } users;
+
+    struct {
+        SPINLOCK spinlock;
+        Pvoid_t pending_epdl_by_extent_offset_judyL;
+    } extent_queries;
+};
+
+bool datafile_acquire(struct rrdengine_datafile *df, DATAFILE_ACQUIRE_REASONS reason);
+void datafile_release(struct rrdengine_datafile *df, DATAFILE_ACQUIRE_REASONS reason);
+bool datafile_acquire_for_deletion(struct rrdengine_datafile *df);
+
+void datafile_list_insert(struct rrdengine_instance *ctx, struct rrdengine_datafile *datafile, bool having_lock);
+void datafile_list_delete_unsafe(struct rrdengine_instance *ctx, struct rrdengine_datafile *datafile);
+void generate_datafilepath(struct rrdengine_datafile *datafile, char *str, size_t maxlen);
+int close_data_file(struct rrdengine_datafile *datafile);
+int unlink_data_file(struct rrdengine_datafile *datafile);
+int destroy_data_file_unsafe(struct rrdengine_datafile *datafile);
+int create_data_file(struct rrdengine_datafile *datafile);
+int create_new_datafile_pair(struct rrdengine_instance *ctx, bool having_lock);
+int init_data_files(struct rrdengine_instance *ctx);
+void finalize_data_files(struct rrdengine_instance *ctx);
+
+#endif /* NETDATA_DATAFILE_H */
+\ No newline at end of file