diff options
Diffstat (limited to 'src/transport/tcp/tcp.c')
| -rw-r--r-- | src/transport/tcp/tcp.c | 33 |
1 files changed, 25 insertions, 8 deletions
diff --git a/src/transport/tcp/tcp.c b/src/transport/tcp/tcp.c index c978b279..02bc078e 100644 --- a/src/transport/tcp/tcp.c +++ b/src/transport/tcp/tcp.c @@ -68,7 +68,10 @@ struct tcptran_ep { nni_reap_item reap; nng_stream_dialer * dialer; nng_stream_listener *listener; - nni_stat_item st_rcvmaxsz; + +#ifdef NNG_ENABLE_STATS + nni_stat_item st_rcv_max; +#endif }; static void tcptran_pipe_send_start(tcptran_pipe *); @@ -173,7 +176,8 @@ tcptran_pipe_alloc(tcptran_pipe **pipep) nni_mtx_init(&p->mtx); if (((rv = nni_aio_alloc(&p->txaio, tcptran_pipe_send_cb, p)) != 0) || ((rv = nni_aio_alloc(&p->rxaio, tcptran_pipe_recv_cb, p)) != 0) || - ((rv = nni_aio_alloc(&p->negoaio, tcptran_pipe_nego_cb, p)) != 0)) { + ((rv = nni_aio_alloc(&p->negoaio, tcptran_pipe_nego_cb, p)) != + 0)) { tcptran_pipe_fini(p); return (rv); } @@ -857,9 +861,16 @@ tcptran_ep_init(tcptran_ep **epp, nng_url *url, nni_sock *sock) ep->proto = nni_sock_proto_id(sock); ep->url = url; - nni_stat_init(&ep->st_rcvmaxsz, "rcvmaxsz", "maximum receive size"); - nni_stat_set_type(&ep->st_rcvmaxsz, NNG_STAT_LEVEL); - nni_stat_set_unit(&ep->st_rcvmaxsz, NNG_UNIT_BYTES); +#ifdef NNG_ENABLE_STATS + static const nni_stat_info rcv_max_info = { + .si_name = "rcv_max", + .si_desc = "maximum receive size", + .si_type = NNG_STAT_LEVEL, + .si_unit = NNG_UNIT_BYTES, + .si_atomic = true, + }; + nni_stat_init(&ep->st_rcv_max, &rcv_max_info); +#endif *epp = ep; return (0); @@ -905,7 +916,9 @@ tcptran_dialer_init(void **dp, nng_url *url, nni_dialer *ndialer) return (rv); } - nni_dialer_add_stat(ndialer, &ep->st_rcvmaxsz); +#ifdef NNG_ENABLE_STATS + nni_dialer_add_stat(ndialer, &ep->st_rcv_max); +#endif *dp = ep; return (0); } @@ -936,7 +949,9 @@ tcptran_listener_init(void **lp, nng_url *url, nni_listener *nlistener) tcptran_ep_fini(ep); return (rv); } - nni_listener_add_stat(nlistener, &ep->st_rcvmaxsz); +#ifdef NNG_ENABLE_STATS + nni_listener_add_stat(nlistener, &ep->st_rcv_max); +#endif *lp = ep; return (0); @@ -1036,8 +1051,10 @@ tcptran_ep_set_recvmaxsz(void *arg, const void *v, size_t sz, nni_opt_type t) NNI_LIST_FOREACH (&ep->busypipes, p) { p->rcvmax = val; } - nni_stat_set_value(&ep->st_rcvmaxsz, val); nni_mtx_unlock(&ep->mtx); +#ifdef NNG_ENABLE_STATS + nni_stat_set_value(&ep->st_rcv_max, val); +#endif } return (rv); } |
