Method ProcessWithMasterMsg

phxbinlogsvr/core/repl/replication_slave.cpp:168–212

}

int ReplicationSlave::ProcessWithMasterMsg() {
    do {
        LogVerbose("%s get msg status %d", __func__, status_);
        vector < string > send_buffer;
        int ret = OK;
        switch (status_) {
            case CommandStatus::MSG:
                ret = DealWithSingalMsg(send_buffer);
                break;
            case CommandStatus::QUERY:
                ret = DealWithQuery(send_buffer);
                break;
            case CommandStatus::EVENT:
                ret = DealWithEvent(send_buffer);
                break;
            case CommandStatus::RUNNING:
                return OK;
            default:
                break;
        }

        if (status_ == CommandStatus::RUNNING && send_buffer.size() == 0) {
            return OK;
        }

        if (send_buffer.size() == 0) {
            return DATA_EMPTY;
        }

        if (ret == OK) {
            for (size_t i = 0; i < send_buffer.size(); ++i) {
                const string &recv_buff = send_buffer[i];
                ret = NetIO::Send(ctx_->GetSlaveFD(), recv_buff);
                if (ret) {
                    ColorLogError("%s send to slave fail, ret %d", __func__, ret);
                    STATISTICS(ReplSendDataFail());
                    break;
                }
            }
        }
        if (ret)
            return ret;
    } while (status_ == CommandStatus::EVENT);
    return OK;
}

int ReplicationSlave::DealWithSingalMsg(vector<string> &send_buffer) {
    string recv_buff;