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

Merge pull request #1565 from fengzeroz/v2.6

Browse Source 
Revert "adapter/manager recv list timeout"
This commit is contained in:
fengzeroz
2023-09-26 13:45:43 +08:00
committed by GitHub
parent 35f2a1e28b fa219c1850
commit 2693e59508
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);