Merge pull request #886 from fengzeroz/v2.2

version: 2.2.8
2026-10-30 07:31:55 +08:00 · 2022-11-04 13:01:16 +08:00 · 2022-11-04 04:59:46 +00:00 · 2022-11-03 18:11:45 +08:00 · 2022-11-03 18:09:17 +08:00
3 changed files with 4 additions and 2 deletions
@@ -114,6 +114,8 @@ static int ekuiper_plugin_start(neu_plugin_t *plugin)

    nng_pipe_notify(plugin->sock, NNG_PIPE_EV_ADD_POST, pipe_add_cb, plugin);
    nng_pipe_notify(plugin->sock, NNG_PIPE_EV_REM_POST, pipe_rm_cb, plugin);
+    nng_socket_set_int(plugin->sock, NNG_OPT_SENDBUF, 2048);
+    nng_socket_set_int(plugin->sock, NNG_OPT_RECVBUF, 2048);

    if ((rv = nng_listen(plugin->sock, EKUIPER_PLUGIN_URL, NULL, 0)) != 0) {
        plog_error(plugin, "nng_listen: %s", nng_strerror(rv));
@@ -56,7 +56,7 @@ void send_data(neu_plugin_t *plugin, neu_reqresp_trans_data_t *trans_data)
    rv = nng_sendmsg(plugin->sock, msg,
                     NNG_FLAG_NONBLOCK); // TODO: use aio to send message
    if (0 != rv) {
-        plog_error(plugin, "nng cannot send msg");
+        plog_error(plugin, "nng cannot send msg: %s", nng_strerror(rv));
        nng_msg_free(msg);
    }
 }
@@ -1 +1 @@
-2.2.7
+2.2.8
Author	SHA1	Message	Date
fengzeroz	6290fcb758	Merge pull request #886 from fengzeroz/v2.2 version: 2.2.8	2022-11-04 13:01:16 +08:00
fengzero	5c04d73e61	version: 2.2.8	2022-11-04 04:59:46 +00:00
fengzeroz	7622f19c6b	Merge pull request #884 from eeff/eeff/2.2 Pick to 2.2: enlarge ekuiper plugin send/recv queue length	2022-11-03 18:11:45 +08:00
eeff	88d1de415a	chore: enlarge ekuiper plugin send/recv queue length	2022-11-03 18:09:17 +08:00
@@ -1 +1 @@
 .2.7
 .2.8