From 595ec514a4677adead70a7680b61284202955151 Mon Sep 17 00:00:00 2001 From: eeff Date: Wed, 26 Jan 2022 16:17:45 +0800 Subject: [PATCH] Refactor neu_manager loop persistence event forwarding code --- src/core/neu_manager.c | 19 ++++++------------- 1 file changed, 6 insertions(+), 13 deletions(-) diff --git a/src/core/neu_manager.c b/src/core/neu_manager.c index ace70761..428b5403 100644 --- a/src/core/neu_manager.c +++ b/src/core/neu_manager.c @@ -1387,21 +1387,14 @@ static void manager_loop(void *arg) // fall through case MSG_EVENT_DEL_PLUGIN: { - nng_msg * out_msg = NULL; - msg_type_e msg_type = msg_get_type(pay_msg); - const char *name = msg_get_buf_ptr(pay_msg); - size_t len = msg_get_buf_len(pay_msg); - size_t msg_size = msg_inplace_data_get_size(len); - rv = nng_msg_alloc(&out_msg, msg_size); - if (rv == 0) { - message_t *msg_ptr = nng_msg_body(out_msg); - msg_inplace_data_init(msg_ptr, msg_type, len); - char *out_buf = msg_get_buf_ptr(msg_ptr); - memcpy(out_buf, name, len); - nng_msg_set_pipe(out_msg, persist_pipe); + msg_type_e msg_type = msg_get_type(pay_msg); + void * buf = msg_get_buf_ptr(pay_msg); + size_t size = msg_get_buf_len(pay_msg); + rv = manager_send_msg_to_pipe(manager, persist_pipe, msg_type, buf, + size); + if (0 == rv) { log_info("Forward event %d to %s pipe: %d", msg_type, DEFAULT_PERSIST_ADAPTER_NAME, persist_pipe); - nng_sendmsg(manager_bind->mng_sock, out_msg, 0); } break; }