| | |
| | | #include <errno.h> |
| | | #include <getopt.h> |
| | | #include <stdlib.h> |
| | | #include "proc_def.h" |
| | | #include "msg_mgr.h" |
| | | |
| | | using namespace std; |
| | | |
| | |
| | | |
| | | return NULL; |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | void *svr_start(void *skptr) { |
| | | int port = *(int *)skptr; |
| | |
| | | } |
| | | } |
| | | |
| | | sleep(10); |
| | | sleep(WT_INT); |
| | | } |
| | | |
| | | return NULL; |
| | |
| | | } |
| | | } |
| | | |
| | | #if defined(MSG_HANDLER) |
| | | msg_init(); |
| | | #endif |
| | | |
| | | if (gShm_size == -1) { |
| | | gShm_size = SHM_RES_SIZE; |
| | | } |
| | |
| | | if (gBusServer_stat >= 0) { |
| | | pthread_create(&tids[1], NULL, svr_start, (void *)&gPort); |
| | | |
| | | pthread_create(&tids[0], NULL, check_start, NULL); |
| | | pthread_create(&tids[2], NULL, check_start, NULL); |
| | | |
| | | //pthread_create(&tids[3], NULL, sem_msg_handler, NULL); |
| | | } |
| | | |
| | | for (i = 0; i< TOTAL_THREADS; i++) { |