Merge pull request #1314 from eeff/eeff/dev

fix: send update license request to all type of adapters

plugins/ekuiper/plugin_ekuiper.c

@@ -258,6 +258,8 @@ static int ekuiper_plugin_request(neu_plugin_t *      plugin,
     }
     case NEU_REQ_UNSUBSCRIBE_GROUP:
         break;
+    case NEU_REQ_UPDATE_LICENSE:
+        break;
     default:
         plog_warn(plugin, "unsupported request type: %d", header->type);
         break;

plugins/mqtt/mqtt_plugin.c

@@ -355,6 +355,8 @@ static int mqtt_plugin_request(neu_plugin_t *plugin, neu_reqresp_head_t *head,
         break;
     case NEU_REQRESP_NODE_DELETED:
         break;
+    case NEU_REQ_UPDATE_LICENSE:
+        break;
     default:
         error = NEU_ERR_MQTT_FAILURE;
         break;

plugins/restful/rest.c

@@ -241,6 +241,8 @@ static int dashb_plugin_request(neu_plugin_t *      plugin,
         handle_get_ndriver_tags_resp(header->ctx,
                                      (neu_resp_get_ndriver_tags_t *) data);
         break;
+    case NEU_REQ_UPDATE_LICENSE:
+        break;
     default:
         nlog_fatal("recv unhandle msg: %s",
                    neu_reqresp_type_string(header->type));

src/core/manager.c

@@ -253,8 +253,7 @@ static int manager_loop(enum neu_event_io_type type, int fd, void *usr_data)
         break;
     }
     case NEU_REQ_UPDATE_LICENSE: {
-        UT_array *pipes = neu_node_manager_get_pipes(manager->node_manager,
-                                                     NEU_NA_TYPE_DRIVER);
+        UT_array *pipes = neu_node_manager_get_pipes_all(manager->node_manager);
 
         utarray_foreach(pipes, nng_pipe *, pipe)
         {