From fa219c1850993d43529a14cface698b7f115e162 Mon Sep 17 00:00:00 2001 From: fengzero Date: Tue, 26 Sep 2023 05:44:37 +0000 Subject: [PATCH] Revert "adapter/manager recv list timeout" This reverts commit b7bafef1e0856bff7dcaabb26a7048a6be8aab48. --- src/adapter/adapter.c | 2 +- src/core/manager.c | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/adapter/adapter.c b/src/adapter/adapter.c index e94dfda7..7d694bb4 100644 --- a/src/adapter/adapter.c +++ b/src/adapter/adapter.c @@ -154,7 +154,7 @@ neu_adapter_t *neu_adapter_create(neu_adapter_info_t *info, bool load) assert(rv == 0); nng_socket_set_int(adapter->sock, NNG_OPT_RECVBUF, 8192); nng_socket_set_int(adapter->sock, NNG_OPT_SENDBUF, 8192); - nng_socket_set_ms(adapter->sock, NNG_OPT_SENDTIMEO, 1000 * 10); + nng_socket_set_ms(adapter->sock, NNG_OPT_SENDTIMEO, 1000); nng_socket_get_int(adapter->sock, NNG_OPT_RECVFD, &adapter->recv_fd); switch (info->module->type) { diff --git a/src/core/manager.c b/src/core/manager.c index 0144db69..5567cc25 100644 --- a/src/core/manager.c +++ b/src/core/manager.c @@ -102,7 +102,7 @@ neu_manager_t *neu_manager_create() nng_socket_set_int(manager->socket, NNG_OPT_RECVBUF, 8192); nng_socket_set_int(manager->socket, NNG_OPT_SENDBUF, 8292); - nng_socket_set_ms(manager->socket, NNG_OPT_SENDTIMEO, 1000 * 10); + nng_socket_set_ms(manager->socket, NNG_OPT_SENDTIMEO, 1000); nng_socket_get_int(manager->socket, NNG_OPT_RECVFD, ¶m.fd); manager->loop = neu_event_add_io(manager->events, param);