diff options
Diffstat (limited to 'src/core')
| -rw-r--r-- | src/core/dialer.c | 5 | ||||
| -rw-r--r-- | src/core/listener.c | 5 | ||||
| -rw-r--r-- | src/core/pipe.c | 10 | ||||
| -rw-r--r-- | src/core/stats.c | 4 |
4 files changed, 24 insertions, 0 deletions
diff --git a/src/core/dialer.c b/src/core/dialer.c index 91d8082b..e1178783 100644 --- a/src/core/dialer.c +++ b/src/core/dialer.c @@ -128,6 +128,7 @@ dialer_stats_init(nni_dialer *d) void nni_dialer_bump_error(nni_dialer *d, int err) { +#ifdef NNG_ENABLE_STATS switch (err) { case NNG_ECONNABORTED: case NNG_ECONNRESET: @@ -156,6 +157,10 @@ nni_dialer_bump_error(nni_dialer *d, int err) BUMP_STAT(&d->d_stats.s_othererr); break; } +#else + NNI_ARG_UNUSED(d); + NNI_ARG_UNUSED(err); +#endif } int diff --git a/src/core/listener.c b/src/core/listener.c index 189f8905..d44a5456 100644 --- a/src/core/listener.c +++ b/src/core/listener.c @@ -125,6 +125,7 @@ listener_stats_init(nni_listener *l) void nni_listener_bump_error(nni_listener *l, int err) { +#ifdef NNG_ENABLE_STATS switch (err) { case NNG_ECONNABORTED: case NNG_ECONNRESET: @@ -150,6 +151,10 @@ nni_listener_bump_error(nni_listener *l, int err) BUMP_STAT(&l->l_stats.s_othererr); break; } +#else + NNI_ARG_UNUSED(l); + NNI_ARG_UNUSED(err); +#endif } int diff --git a/src/core/pipe.c b/src/core/pipe.c index 7a632b0f..f7269eb4 100644 --- a/src/core/pipe.c +++ b/src/core/pipe.c @@ -351,15 +351,25 @@ nni_pipe_add_stat(nni_pipe *p, nni_stat_item *item) void nni_pipe_bump_rx(nni_pipe *p, size_t nbytes) { +#ifdef NNG_ENABLE_STATS nni_stat_inc_atomic(&p->p_stats.s_rxbytes, nbytes); nni_stat_inc_atomic(&p->p_stats.s_rxmsgs, 1); +#else + NNI_ARG_UNUSED(p); + NNI_ARG_UNUSED(nbytes); +#endif } void nni_pipe_bump_tx(nni_pipe *p, size_t nbytes) { +#ifdef NNG_ENABLE_STATS nni_stat_inc_atomic(&p->p_stats.s_txbytes, nbytes); nni_stat_inc_atomic(&p->p_stats.s_txmsgs, 1); +#else + NNI_ARG_UNUSED(p); + NNI_ARG_UNUSED(nbytes); +#endif } void diff --git a/src/core/stats.c b/src/core/stats.c index 74b14f59..3c200fec 100644 --- a/src/core/stats.c +++ b/src/core/stats.c @@ -60,9 +60,13 @@ nni_stat_add(nni_stat_item *parent, nni_stat_item *child) void nni_stat_register(nni_stat_item *child) { +#ifdef NNG_ENABLE_STATS nni_mtx_lock(&stats_lock); nni_stat_add(&stats_root, child); nni_mtx_unlock(&stats_lock); +#else + NNI_ARG_UNUSED(child); +#endif } void |
