diff options
Diffstat (limited to 'xlators/cluster/nsr-recon/src/recon_driver.h')
| -rw-r--r-- | xlators/cluster/nsr-recon/src/recon_driver.h | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/xlators/cluster/nsr-recon/src/recon_driver.h b/xlators/cluster/nsr-recon/src/recon_driver.h index 4030c9d73..8d87e29af 100644 --- a/xlators/cluster/nsr-recon/src/recon_driver.h +++ b/xlators/cluster/nsr-recon/src/recon_driver.h @@ -181,7 +181,7 @@ typedef struct nsr_recon_record_details_s { typedef struct _nsr_role_work_s { nsr_recon_role_t role; - uint32_t txn_id; + uint32_t term; struct list_head list; } nsr_role_work_t; @@ -236,6 +236,8 @@ typedef struct _nsr_per_node_worker_s { #if defined(NSR_DEBUG) FILE *fp; #endif + int32_t result; // result of latest work + int32_t op_errno; // errno } nsr_per_node_worker_t; typedef struct _nsr_replica_worker_s { @@ -256,7 +258,7 @@ typedef struct _nsr_recon_driver_ctxt { nsr_role_work_t role_head; volatile int32_t outstanding; uint32_t reconciliator_index; - uint32_t txn_id; + uint32_t term; uint32_t current_term; jmp_buf *env; nsr_mode_t mode; // default set to seq @@ -269,7 +271,7 @@ void * nsr_reconciliation_driver(void *); gf_boolean_t -nsr_recon_driver_set_role(nsr_recon_driver_ctx_t *ctx, nsr_recon_role_t *rr, uint32_t txn_id); +nsr_recon_driver_set_role(nsr_recon_driver_ctx_t *ctx, nsr_recon_role_t *rr, uint32_t term); #define atomic_inc(ptr) ((void) __sync_fetch_and_add(ptr, 1)) #define atomic_dec(ptr) ((void) __sync_fetch_and_add(ptr, -1)) |