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);