Method ThreadProcess

phxbinlogsvr/core/repl/replication_base.cpp:35–43

}

void *ReplicationBase::ThreadProcess(void *arg) {
    ReplicationBase *runner = (ReplicationBase *) arg;

    int ret = runner->Process();
    if (ret)
        runner->Close();

    return NULL;
}

}