Merge pull request #871 from fengzeroz/v2.2

fix(ekuiper): float/double precision

plugins/ekuiper/json_rw.c

@@ -155,9 +155,10 @@ int json_encode_read_resp_tags(void *json_object, void *param)
         }
 
         neu_json_elem_t tag_elem = {
-            .name = json_tag.name,
-            .t    = json_tag.t,
-            .v    = json_tag.value,
+            .name      = json_tag.name,
+            .t         = json_tag.t,
+            .v         = json_tag.value,
+            .precision = trans_data->tags[i].value.precision,
         };
 
         ret = neu_json_encode_field((0 != json_tag.error) ? errors_object

src/adapter/adapter.c

@@ -61,7 +61,7 @@ neu_adapter_t *neu_adapter_create(neu_adapter_info_t *info)
     neu_event_io_param_t    param       = { 0 };
     neu_event_timer_param_t timer_param = {
         .second      = 0,
-        .millisecond = 100,
+        .millisecond = 10,
         .cb          = update_timestamp,
     };
 

src/connection/connection.c

@@ -350,7 +350,7 @@ ssize_t neu_conn_recv(neu_conn_t *conn, uint8_t *buf, ssize_t len)
                    conn->fd, len, ret, strerror(errno), errno);
     }
 
-    if (errno == EPIPE || ret <= 0) {
+    if (errno == EPIPE || ret == -1) {
         conn_disconnect(conn);
     }
 

src/event/event_linux.c

@@ -103,7 +103,10 @@ static void *event_loop(void *arg)
                 assert(size != -1);
 
                 nng_mtx_lock(data->ctx.timer->mtx);
+                epoll_ctl(epoll_fd, EPOLL_CTL_DEL, data->fd, NULL);
                 ret = data->callback.timer(data->usr_data);
+                timerfd_settime(data->fd, 0, &data->ctx.timer->value, NULL);
+                epoll_ctl(epoll_fd, EPOLL_CTL_ADD, data->fd, &event);
                 nng_mtx_unlock(data->ctx.timer->mtx);
             }
             break;

version

@@ -1 +1 @@
-2.2.6
+2.2.7