Function RoutineRun

phxsqlproxy/phxcoroutine.cpp:28–40

static int g_routine_id = 0;

static void *RoutineRun(void * p) {
    g_routine_id++;
    LogWarning("routine %d running....", g_routine_id);
    //phoenix::SetLogWorkerIdx( g_routine_id );

    Coroutine * routine = (Coroutine *) p;
    routine->SetRoutineIdx(g_routine_id);
    int ret = routine->run();
    if (ret) {
        //do something
    }
    return NULL;
}

Coroutine::Coroutine() {
    routine_ = NULL;