fujuntang
2021-11-10 c479ef57baaaa28964fc3ec8d80ff99dffa7d49f
src/bus_proxy_start.cpp
@@ -10,6 +10,8 @@
#include <errno.h>
#include <getopt.h>
#include <stdlib.h>
#include "proc_def.h"
#include "msg_mgr.h"
using namespace std;
@@ -44,9 +46,6 @@
  return NULL;
}
void *svr_start(void *skptr) {
  int port = *(int *)skptr;
@@ -105,7 +104,7 @@
      }
    }
    sleep(10);
    sleep(WT_INT);
  }
  return NULL;
@@ -151,6 +150,10 @@
    }
  }
#if defined(MSG_HANDLER)
  msg_init();
#endif
  if (gShm_size == -1) {
    gShm_size = SHM_RES_SIZE;
  }
@@ -169,7 +172,9 @@
  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++) {