Method Process

phxbinlogsvr/core/repl/replication_impl.cpp:61–89

}

int ReplicationImpl::Process() {
	if(ctx_->GetSlaveFD()<0){
		ColorLogInfo("%s slave fd %d close", __func__, ctx_->GetSlaveFD());
		return SOCKET_FAIL;
	}

    int master_fd = InitFakeMaster();
    if (master_fd < 0) {
        return SOCKET_FAIL;
    }

    ColorLogInfo("%p process master fd %d, slave fd %d", this, master_fd, ctx_->GetSlaveFD());

    ctx_->SetMasterFD(master_fd);

    ReplicationSlave *slave = new ReplicationSlave(ctx_);
    ReplicationTransfer *transfer = new ReplicationTransfer(ctx_);

    slave->Run();
    transfer->Run();

    slave->WaitStop();
    transfer->WaitStop();

    delete slave;
    delete transfer;

    return OK;
}

int ReplicationImpl::InitFakeMaster() {
    MasterInfo info;