From 8e6344602628a72cec6b52addca34cd246bf4bcd Mon Sep 17 00:00:00 2001
From: lishu <lishu@iie.ac.cn>
Date: Thu, 6 Dec 2018 20:49:59 +0800
Subject: [PATCH] =?UTF-8?q?=E6=94=AF=E6=8C=81=E5=8D=95=E6=9C=BA=E5=90=8C?=
 =?UTF-8?q?=E6=97=B6=E8=BF=90=E8=A1=8C=E9=9F=B3=E8=A7=86=E9=A2=91=E5=92=8C?=
 =?UTF-8?q?=E5=9B=BE=E7=89=87=EF=BC=8C=E6=89=80=E4=BB=A5unixsocket?=
 =?UTF-8?q?=E7=9A=84=E9=85=8D=E7=BD=AE=E6=96=87=E4=BB=B6=E4=B8=8D=E8=83=BD?=
 =?UTF-8?q?=E6=9C=89=E9=BB=98=E8=AE=A4=E5=80=BC?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main.c | 54 ++++++++++++++++++++++++++++++++----------------------
 1 file changed, 32 insertions(+), 22 deletions(-)

diff --git a/src/main.c b/src/main.c
index 589a8fd..9356665 100644
--- a/src/main.c
+++ b/src/main.c
@@ -523,6 +523,7 @@ int read_conf_and_init(const char* filename)
 	uint32_t					hash_max_elem_num = 0;
 	uint32_t					hash_expire_time = 0;	
 	char						table_info_filename [MAX_PATH_LEN]={0};	
+	int 						rec_dest = 0;
 	
 	/*main log*/
 	memset(conf_buf,0,sizeof(conf_buf));
@@ -770,28 +771,34 @@ int read_conf_and_init(const char* filename)
 
 	/*unix socket : backward data send*/	
 	memset(conf_buf,0,sizeof(conf_buf));
-	MESA_load_profile_string_def(filename, "NETWORK", "UnixSocketSendSrcAddr", conf_buf, sizeof(conf_buf),"/home/mesasoft/frag_rssb/un_sender");
-	for(i=0;i<g_frag_cfg.thread_num;i++)
+	rec_dest = MESA_load_profile_string_def(filename, "NETWORK", "UnixSocketSendSrcAddr", conf_buf, sizeof(conf_buf),"/home/mesasoft/frag_rssb/un_sender");
+	if(-1!=rec_dest)
 	{
-		memset(buf,0,sizeof(buf));
-		snprintf(buf,sizeof(buf),"%s_%02d",conf_buf,i);
-		g_frag_run.send_fd[i] = init_unix_socket(buf);
-		if(-1==g_frag_run.send_fd[i])
+		for(i=0;i<g_frag_cfg.thread_num;i++)
 		{
-			printf("[%s] init_unix_socket error.\n", FRAG_REASSEMBLY_MODULE_NAME);
-			MESA_handle_runtime_log(g_frag_run.logger,RLOG_LV_FATAL,FRAG_REASSEMBLY_MODULE_NAME,
-								(char*)"[%s:%d] init_unix_socket error." , __FILE__,__LINE__);
-			return -1;
+			memset(buf,0,sizeof(buf));
+			snprintf(buf,sizeof(buf),"%s_%02d",conf_buf,i);
+			g_frag_run.send_fd[i] = init_unix_socket(buf);
+			if(-1==g_frag_run.send_fd[i])
+			{
+				printf("[%s] init_unix_socket error.\n", FRAG_REASSEMBLY_MODULE_NAME);
+				MESA_handle_runtime_log(g_frag_run.logger,RLOG_LV_FATAL,FRAG_REASSEMBLY_MODULE_NAME,
+									(char*)"[%s:%d] init_unix_socket error." , __FILE__,__LINE__);
+				return -1;
+			}
 		}
 	}
 	memset(conf_buf,0,sizeof(conf_buf));
 	memset(split_buf,0,sizeof(split_buf));
-	MESA_load_profile_string_def(filename, "NETWORK", "UnixSocketSendDestAddr", conf_buf, sizeof(conf_buf),"");
-	g_frag_cfg.send_dest_addr_num = string_split(conf_buf, split_buf, DEST_MAXNUM, ';');	
-	for(i=0;i<(uint32_t)g_frag_cfg.send_dest_addr_num;i++)
+	rec_dest = MESA_load_profile_string_def(filename, "NETWORK", "UnixSocketSendDestAddr", conf_buf, sizeof(conf_buf),"");
+	if(-1!=rec_dest)
 	{
-		strcpy(g_frag_cfg.send_dest_addr[i].sun_path,split_buf[i]);
-		g_frag_cfg.send_dest_addr[i].sun_family = AF_UNIX;
+		g_frag_cfg.send_dest_addr_num = string_split(conf_buf, split_buf, DEST_MAXNUM, ';');	
+		for(i=0;i<(uint32_t)g_frag_cfg.send_dest_addr_num;i++)
+		{
+			strcpy(g_frag_cfg.send_dest_addr[i].sun_path,split_buf[i]);
+			g_frag_cfg.send_dest_addr[i].sun_family = AF_UNIX;
+		}
 	}
 	
 	/*----USM send read conf and init----*/
@@ -839,14 +846,17 @@ int read_conf_and_init(const char* filename)
 	
 	/*unix socket : response msg recv*/		
 	memset(conf_buf,0,sizeof(conf_buf));
-	MESA_load_profile_string_def(filename, "NETWORK", "UnixSocketRecvAddr", conf_buf, sizeof(conf_buf),"/home/mesasoft/frag_rssb/un_recv");
-	g_frag_run.recv_msg_fd = init_recv_unix_socket(conf_buf);
-	if(-1==g_frag_run.recv_msg_fd)
+	rec_dest = MESA_load_profile_string_def(filename, "NETWORK", "UnixSocketRecvAddr", conf_buf, sizeof(conf_buf),"/home/mesasoft/frag_rssb/un_recv");
+	if(-1!=rec_dest)
 	{
-		printf("[%s] init_recv_unix_socket error.\n", FRAG_REASSEMBLY_MODULE_NAME);
-		MESA_handle_runtime_log(g_frag_run.logger,RLOG_LV_FATAL,FRAG_REASSEMBLY_MODULE_NAME,
-								(char*)"[%s:%d] init_recv_unix_socket." , __FILE__,__LINE__);
-		return -1;
+		g_frag_run.recv_msg_fd = init_recv_unix_socket(conf_buf);
+		if(-1==g_frag_run.recv_msg_fd)
+		{
+			printf("[%s] init_recv_unix_socket error.\n", FRAG_REASSEMBLY_MODULE_NAME);
+			MESA_handle_runtime_log(g_frag_run.logger,RLOG_LV_FATAL,FRAG_REASSEMBLY_MODULE_NAME,
+									(char*)"[%s:%d] init_recv_unix_socket." , __FILE__,__LINE__);
+			return -1;
+		}
 	}
 
 	/*msg port:粗拼装接收建议的端口，前端接收建议的端口*/