b.liu | b17525e | 2025-05-14 17:22:29 +0800 | [diff] [blame] | 1 | #include <stdio.h> |
| 2 | #include <stdlib.h> |
| 3 | #include <unistd.h> |
| 4 | #include "dispatch.h" |
| 5 | #include "lynq.h" |
| 6 | dispatch_manager *g_dispatch; |
| 7 | |
| 8 | int 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 | } |
| 26 | int 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 | } |