GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-20 16:05:10 +08:00
Code Issues Packages Projects Releases Wiki Activity

Revert "adapter/manager recv list timeout"

Browse Source 
This reverts commit b7bafef1e0.
This commit is contained in:
fengzero
2023-09-26 05:44:37 +00:00
parent 35f2a1e28b
commit fa219c1850
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/adapter/adapter.c
+1 -1
View File
@@ -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) {
src/core/manager.c
+1 -1
View File
@@ -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, &param.fd);
manager->loop = neu_event_add_io(manager->events, param);