Method WriteToDest

phxsqlproxy/io_channel.cpp:128–153

}

int IOChannel::WriteToDest(int dest_fd, const char * buf, int write_size) {
    MonitorPluginEntry::GetDefault()->GetMonitorPlugin()->WriteNetwork(write_size);
    //for debug
    //
    if (config_->OpenDebugMode()) {
        std::string debug_str;
        GetMysqlBufDebugString(buf, write_size, debug_str);
        LOG_DEBUG("dest %d command [%s]", dest_fd, debug_str.c_str());
    }
    //for debug end

    int written_once = 0;
    int total_written = 0;
    while (total_written < write_size) {
        written_once = RoutineWriteWithTimeout(dest_fd, buf + total_written, write_size - total_written,
                                               config_->WriteTimeoutMs());
        if (written_once < 0) {
            LOG_ERR("write to %d buf size [%d] failed, ret %d, errno (%d:%s)",
                    dest_fd, write_size, written_once, errno, strerror(errno));
            MonitorPluginEntry::GetDefault()->GetMonitorPlugin()->WriteNetworkFail(write_size);
            return -__LINE__;
        }
        total_written += written_once;
    }
    return total_written;
}

int IOChannel::TransMsgDirect(int source_fd, int dest_fd, struct pollfd pf[], int nfds) {
    int byte_size = 0;