From 149093fa7ae2091e3e67489590aeebe53df0e2b0 Mon Sep 17 00:00:00 2001
From: eeff <33566201+eeff@users.noreply.github.com>
Date: Wed, 7 Jun 2023 17:54:33 +0800
Subject: [PATCH] fix: send update license request to all type of adapters

---
 plugins/ekuiper/plugin_ekuiper.c | 2 ++
 plugins/mqtt/mqtt_plugin.c       | 2 ++
 plugins/restful/rest.c           | 2 ++
 src/core/manager.c               | 3 +--
 4 files changed, 7 insertions(+), 2 deletions(-)

diff --git a/plugins/ekuiper/plugin_ekuiper.c b/plugins/ekuiper/plugin_ekuiper.c
index c64d9b27..9325651c 100644
--- a/plugins/ekuiper/plugin_ekuiper.c
+++ b/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;
diff --git a/plugins/mqtt/mqtt_plugin.c b/plugins/mqtt/mqtt_plugin.c
index efdece91..4fdc84b6 100644
--- a/plugins/mqtt/mqtt_plugin.c
+++ b/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;
diff --git a/plugins/restful/rest.c b/plugins/restful/rest.c
index e85b6109..2ff95f9a 100644
--- a/plugins/restful/rest.c
+++ b/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));
diff --git a/src/core/manager.c b/src/core/manager.c
index f6606dec..e358a294 100644
--- a/src/core/manager.c
+++ b/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)
         {