diff options
Diffstat (limited to 'xlators/cluster/nsr-recon/src/recon_driver.h')
-rw-r--r-- | xlators/cluster/nsr-recon/src/recon_driver.h | 15 |
1 files changed, 12 insertions, 3 deletions
diff --git a/xlators/cluster/nsr-recon/src/recon_driver.h b/xlators/cluster/nsr-recon/src/recon_driver.h index 096ca88b5..4030c9d73 100644 --- a/xlators/cluster/nsr-recon/src/recon_driver.h +++ b/xlators/cluster/nsr-recon/src/recon_driver.h @@ -233,6 +233,9 @@ typedef struct _nsr_per_node_worker_s { pthread_mutex_t mutex; //mutex to guard the state pthread_cond_t cv; //condition variable for signaling the worker thread gf_boolean_t is_control; +#if defined(NSR_DEBUG) + FILE *fp; +#endif } nsr_per_node_worker_t; typedef struct _nsr_replica_worker_s { @@ -257,6 +260,9 @@ typedef struct _nsr_recon_driver_ctxt { uint32_t current_term; jmp_buf *env; nsr_mode_t mode; // default set to seq +#if defined(NSR_DEBUG) + FILE *fp; +#endif } nsr_recon_driver_ctx_t; void * @@ -278,7 +284,8 @@ extern int nsr_debug_level; extern FILE *recon_create_log (char *member, char *module); extern void -_nsr_driver_log (const char *func, int line, char *member, char *fmt, ...); +_nsr_driver_log (const char *func, int line, char *member, FILE *fp, + char *fmt, ...); #define nsr_driver_log(dom, levl, fmt...) do { \ FMT_WARN (fmt); \ @@ -286,13 +293,15 @@ _nsr_driver_log (const char *func, int line, char *member, char *fmt, ...); nsr_recon_private_t *priv = ctx->this->private; \ _nsr_driver_log (__FUNCTION__, __LINE__, \ priv->replica_group_members[0], \ + ctx->fp, \ ##fmt); \ } \ } while (0) extern void _nsr_worker_log (const char *func, int line, char *member, - char *type, uint32_t index, char *fmt, ...); + char *type, uint32_t index, FILE *fp, + char *fmt, ...); #define nsr_worker_log(dom, levl, fmt...) do { \ FMT_WARN (fmt); \ @@ -303,7 +312,7 @@ _nsr_worker_log (const char *func, int line, char *member, priv->replica_group_members[0], \ ctx->is_control ? "recon-con" : \ "recon-data", \ - ctx->index, \ + ctx->index, ctx->fp, \ ##fmt); \ } \ } while (0) |