replication: struct replicator_queue - Move to replicator-queue-private.h

diff --git a/src/replication/replicator/Makefile.am b/src/replication/replicator/Makefile.am
index a0ac563f9c96e8873c1684526a46e7e8db129cee..bcd349a0e4efeeb97e79707c9e6ed05973813952 100644 (file)
--- a/src/replication/replicator/Makefile.am
+++ b/src/replication/replicator/Makefile.am
@@ -32,5 +32,6 @@ noinst_HEADERS = \
        dsync-client.h \
        replicator-brain.h \
        replicator-queue.h \
+       replicator-queue-private.h \
        replicator-settings.h \
        notify-connection.h

diff --git a/src/replication/replicator/replicator-queue-private.h b/src/replication/replicator/replicator-queue-private.h
new file mode 100644 (file)
index 0000000..fe57c1d
--- /dev/null
+++ b/src/replication/replicator/replicator-queue-private.h
@@ -0,0 +1,21 @@
+#ifndef REPLICATOR_QUEUE_PRIVATE_H
+#define REPLICATOR_QUEUE_PRIVATE_H
+
+#include "replicator-queue.h"
+
+struct replicator_queue {
+       struct priorityq *user_queue;
+       struct event *event;
+       /* username => struct replicator_user* */
+       HASH_TABLE(char *, struct replicator_user *) user_hash;
+
+       ARRAY(struct replicator_sync_lookup) sync_lookups;
+
+       unsigned int full_sync_interval;
+       unsigned int failure_resync_interval;
+
+       void (*change_callback)(void *context);
+       void *change_context;
+};
+
+#endif

diff --git a/src/replication/replicator/replicator-queue.c b/src/replication/replicator/replicator-queue.c
index 4099815116a475e1d4799fa1a5b4d259d0d6d4e3..5fd8e368fc118b2d436c7a948833109f667a8e3f 100644 (file)
--- a/src/replication/replicator/replicator-queue.c
+++ b/src/replication/replicator/replicator-queue.c
@@ -8,7 +8,7 @@
 #include "str.h"
 #include "strescape.h"
 #include "hash.h"
-#include "replicator-queue.h"
+#include "replicator-queue-private.h"
 
 #include <unistd.h>
 #include <fcntl.h>
@@ -22,20 +22,6 @@ struct replicator_sync_lookup {
        bool wait_for_next_push;
 };
 
-struct replicator_queue {
-       struct priorityq *user_queue;
-       /* username => struct replicator_user* */
-       HASH_TABLE(char *, struct replicator_user *) user_hash;
-
-       ARRAY(struct replicator_sync_lookup) sync_lookups;
-
-       unsigned int full_sync_interval;
-       unsigned int failure_resync_interval;
-
-       void (*change_callback)(void *context);
-       void *change_context;
-};
-
 struct replicator_queue_iter {
        struct replicator_queue *queue;
        struct hash_iterate_context *iter;