| | |
| | | free(buf); |
| | | break; |
| | | } else { |
| | | logger->error( "BusServerSocket::run_pubsub_proxy : unrecognized action"); |
| | | logger->error( "BusServerSocket::run_pubsub_proxy : unrecognized action %s", action); |
| | | } |
| | | |
| | | // free(action); |
| | |
| | | void * server_socket = bus_server_socket_wrapper_open(); |
| | | pthread_t tid; |
| | | // 创建一个线程,可以关闭bus |
| | | // pthread_create(&tid, NULL, bus_handler, server_socket); |
| | | pthread_create(&tid, NULL, bus_handler, server_socket); |
| | | if(bus_server_socket_wrapper_start_bus(server_socket) != 0) { |
| | | printf("start bus failed\n"); |
| | | exit(1); |