1 files changed, 78 insertions, 0 deletions
diff --git a/xlators/cluster/nsr-recon/src/recon_xlator.h b/xlators/cluster/nsr-recon/src/recon_xlator.h
new file mode 100644
index 000000000..c0f1e2145
--- /dev/null
+++ b/xlators/cluster/nsr-recon/src/recon_xlator.h
@@ -0,0 +1,78 @@
+/*
+  Copyright (c) 2008-2012 Red Hat, Inc. <http://www.redhat.com>
+  This file is part of GlusterFS.
+
+  This file is licensed to you under your choice of the GNU Lesser
+  General Public License, version 3 or any later version (LGPLv3 or
+  later), or the GNU General Public License, version 2 (GPLv2), in all
+  cases as published by the Free Software Foundation.
+*/
+
+#ifndef __RECON_XLATOR_H__
+#define __RECON_XLATOR_H__
+
+#include <semaphore.h>
+#include <pthread.h>
+
+enum gf_dht_mem_types_ {
+        gf_mt_recon_private_t = gf_common_mt_end + 1,
+};
+
+enum nsr_recon_xlator_sector_t {
+        nsr_recon_xlator_sector_0 = 0, // to report back the status of given transaction ids
+        nsr_recon_xlator_sector_1 = 512, //  to write here information about leadership changes from the brick
+        nsr_recon_xlator_sector_2 = (512 * 2), // to write here individual roles and wait for that role to be done
+        nsr_recon_xlator_sector_3 = (512 *3), // read from here to get term info for given term
+        nsr_recon_xlator_sector_4 = (512 * 4), // read from here to get last term info
+};
+
+
+typedef struct _nsr_recon_private_s {
+        xlator_t *this; //back pointer
+        unsigned int replica_group_size; // number of static members of replica group
+        char **replica_group_members; // replica group members (including itself in first slot)
+        pthread_t thread_id; // driver thread id
+        nsr_recon_driver_ctx_t *driver_thread_context; //driver thread context
+        unsigned int outstanding; // for communicating with driver thread
+        call_frame_t *frame; // old frame that is pending (just one as of now)
+        struct list_head list;
+        char *volname;
+        uint32_t txn_id;
+        char *changelog_base_path;
+        char *base_dir;
+#ifdef  NSR_DEBUG
+        uint32_t recon_main_log_fd;
+#endif
+} nsr_recon_private_t;
+
+#define atomic_cmpxchg         __sync_val_compare_and_swap
+
+/*
+ * REVIEW
+ * Ideally, use gf_log like everyone else.  Failing that, at least put the logs
+ * with all the others in /var/log instead of /tmp.
+ */
+#ifdef NSR_DEBUG
+#define recon_main_log(dom, levl, fmt...) \
+        { \
+                nsr_recon_private_t   *priv   = this->private;  \
+                char c[255]; \
+                if (!priv->recon_main_log_fd) { \
+                        mkdir("/tmp/nsr-logs/", 0777);  \
+                        priv->recon_main_log_fd = open("/tmp/nsr-logs/recon-main-log", O_RDWR|O_CREAT|O_TRUNC); \
+                } \
+                sprintf(c, fmt); \
+                write(priv->recon_main_log_fd, c, strlen(c));  \
+        }
+#else
+#define recon_main_log(dom, levl, fmt...) gf_log(dom, levl, fmt)
+#endif
+
+
+void nsr_recon_libchangelog_get_this_term_info(xlator_t *this, char *bp, int32_t term, nsr_recon_last_term_info_t *lt);
+void nsr_recon_libchangelog_get_last_term_info(xlator_t *this, char *bp, int32_t term, nsr_recon_last_term_info_t *lt);
+void nsr_recon_return_back(nsr_recon_private_t *priv, uint32_t term_id);
+void nsr_recon_libchangelog_get_records(xlator_t *this, char *bp, int32_t term, uint32_t first, uint32_t last, void *buf);
+
+
+#endif /* #ifndef __RECON_XLATOR_H__ */