Method ReadConfig

phxsqlproxy/phxsqlproxyconfig.cpp:33–64

}

void PHXSqlProxyConfig::ReadConfig() {
    svr_port_ = GetInteger("Server", "Port", 0);
    svr_ip_ = Get("Server", "IP", "");
    if (svr_ip_ == "$InnerIP") {
        svr_ip_ = GetInnerIP();
    }
    phxsql_plugin_config_ = Get("Server", "PluginConfigFile", "");
    is_open_debug_mode_ = GetInteger("Server", "OpenDebugMode", 0);
    is_only_proxy_ = GetInteger("Server", "OnlyProxy", 0);
    is_master_enable_read_port_ = GetInteger("Server", "MasterEnableReadPort", 0);
    is_enable_try_best_ = GetInteger("Server", "TryBestIfBinlogsvrDead", 0);
    freqctrl_config_ = Get("Server", "FreqCtrlConfig", "");
    log_level_ = GetInteger("Server", "LogLevel", 3);
    log_file_max_size_ = GetInteger("Server", "LogFileMaxSize", 1600);
    log_path_ = Get("Server", "LogFilePath", "/tmp/");
    sleep_ = GetInteger("Server", "Sleep", 0);
    connect_timeout_ms_ = GetInteger("Server", "ConnectTimeoutMs", 200);
    write_timeout_ms_ = GetInteger("Server", "WriteTimeoutMs", 1000);
    proxy_protocol_ = GetInteger("Server", "ProxyProtocol", 0);
    proxy_protocol_timeout_ms_ = GetInteger("Server", "ProxyProtocolTimeoutMs", 1000);

    /*
     phxsql_config_ = PhxMySqlConfig :: GetDefault();
     if ( phxsql_plugin_config_ != "" )
     {
     phxsql_config_->ReadFileWithConfigDirPath( phxsql_plugin_config_.c_str() );
     }
     */
    ReadMasterWorkerConfig(&master_worker_config_);
    ReadSlaveWorkerConfig(&slave_worker_config_);
    LogWarning("read plugin config [%s]", phxsql_plugin_config_.c_str());
}

const char * PHXSqlProxyConfig::GetMysqlIP() {
    return Option::GetDefault()->GetMySqlConfig()->GetMySQLIP();