blob: 3f7bbf02a5e7d8077a3ee24f6402e1514d285b12 [file] [log] [blame]
b.liub17525e2025-05-14 17:22:29 +08001#include <stdio.h>
2#include <stdlib.h>
3#include <unistd.h>
4#include "dispatch.h"
5#include "lynq.h"
6dispatch_manager *g_dispatch;
7
8int init_msg_dispatch(char * socket_name,int token)
9{
10 int ret;
11 g_dispatch = new dispatch_manager;
12 if(g_dispatch == NULL)
13 {
14 printf("[%s][%d] new class fail!\n",__FUNCTION__,__LINE__);
15 return -1;
16 }
17 ret = g_dispatch->init_socket(socket_name);
18 if(ret!=LYNQ_E_SUCCESS)
19 {
20 printf("[%s][%d] create socket fail!\n",__FUNCTION__,__LINE__);
21 return ret;
22 }
23 g_dispatch->start_main_loop();
24 return LYNQ_E_SUCCESS;
25}
26int main(int argc,char*argv[])
27{
28 printf("[%s][%d] enter\n",__FUNCTION__,__LINE__);
29 int ret = 0;
30 char socket_name[64]={0};
31
32 system("rm -rf /var/run/socket");
33 system("mkdir -p /var/run/socket");
34
35 if(argc < 3)
36 {
37 printf("[%s][%d] please input socket name and token\n",__FUNCTION__,__LINE__);
38 exit(1);
39 }
40 if((argv[1] != NULL) && (argv[2]!=NULL))
41 {
42 sprintf(socket_name,"/var/run/socket/%s",argv[1]);
43 if(LYNQ_E_SUCCESS != init_msg_dispatch(socket_name, atoi(argv[2])))
44 {
45 exit(1);
46 }
47 }
48 else
49 {
50 printf("[%s][%d] param fail!\n",__FUNCTION__,__LINE__);
51 exit(1);
52 }
53 while (1)
54 {
55 sleep(1);
56 }
57 return 0;
58}