From 36ef45a30315c07daec5564a363bcd71aec8844a Mon Sep 17 00:00:00 2001
From: fengzero <fengzero@fengzero.com>
Date: Thu, 21 Apr 2022 06:21:47 +0000
Subject: [PATCH] fix(adapter): the adapter state does not enter ready

---
 src/adapter/adapter.c | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/adapter/adapter.c b/src/adapter/adapter.c
index 12874e8a..3ee6c872 100644
--- a/src/adapter/adapter.c
+++ b/src/adapter/adapter.c
@@ -1444,7 +1444,6 @@ int adapter_loop(enum neu_event_io_type type, int fd, void *usr_data)
         case MSG_CMD_RESP_PONG: {
             char *buf_ptr = msg_get_buf_ptr(pay_msg);
 
-            adapter->state = ADAPTER_STATE_INIT;
             log_info("Adapter(%s) received pong: %s\n", adapter->name, buf_ptr);
             break;
         }
@@ -1851,6 +1850,9 @@ int neu_adapter_init(neu_adapter_t *adapter)
         buf_ptr[strlen(adapter->name)] = 0;
         nng_sendmsg(adapter->nng.sock, out_msg, 0);
     }
+    if (adapter->state == ADAPTER_STATE_IDLE) {
+        adapter->state = ADAPTER_STATE_INIT;
+    }
     adapter->plugin_info.module->intf_funs->init(adapter->plugin_info.plugin);
     return rv;
 }