1 files changed, 48 insertions, 0 deletions
diff --git a/src/dict/dict-connection.h b/src/dict/dict-connection.h
new file mode 100644
index 0000000..2241dad
--- /dev/null
+++ b/src/dict/dict-connection.h
@@ -0,0 +1,48 @@
+#ifndef DICT_CONNECTION_H
+#define DICT_CONNECTION_H
+
+#include "dict.h"
+#include "connection.h"
+
+struct dict_connection_transaction {
+	unsigned int id;
+	struct dict_connection *conn;
+	struct dict_transaction_context *ctx;
+};
+
+struct dict_connection {
+	struct connection conn;
+	struct dict_connection *prev, *next;
+	struct dict_server *server;
+	int refcount;
+
+	char *name;
+	struct dict *dict;
+	enum dict_data_type value_type;
+
+	struct timeout *to_unref;
+
+	/* There are only a few transactions per client, so keeping them in
+	   array is fast enough */
+	ARRAY(struct dict_connection_transaction) transactions;
+	ARRAY(struct dict_connection_cmd *) cmds;
+	unsigned int async_id_counter;
+
+	bool iter_flush_pending;
+	bool destroyed;
+};
+
+struct master_service_connection;
+
+struct dict_connection *
+dict_connection_create(struct master_service_connection *master_conn);
+
+void dict_connection_ref(struct dict_connection *conn);
+bool dict_connection_unref(struct dict_connection *conn);
+void dict_connection_unref_safe(struct dict_connection *conn);
+
+unsigned int dict_connections_current_count(void);
+void dict_connections_init(void);
+void dict_connections_destroy_all(void);
+
+#endif