Function main

phxsqlproxy/test/testsqlproxy.cpp:157–181

}

int main(int argc, char ** argv) {
    //RoutineSetSpecificCallback(co_getspecific, co_setspecific);
    if (argc < 4) {
        showUsage(argc, argv);
        exit(-1);
    }

    signal(SIGPIPE, SIG_IGN);
    phxsqlproxy::PHXSqlProxyConfig config;
    if (config.ReadConfig(argv[1]) != 0) {
        printf("ReadConfig [%s] failed\n", argv[1]);
        showUsage(argc, argv);
        exit(-1);
    }

    int thread_num = atoi(argv[2]);
    int routine_num = atoi(argv[3]);

    for (int i = 0; i < thread_num; ++i) {
        TestPHXSqlProxyThread * thread = new TestPHXSqlProxyThread(&config, i, routine_num);
        thread->start();
    }
    co_eventloop(co_get_epoll_ct(), 0, 0);
    return 0;
}