| 110 | } |
| 111 | |
| 112 | void connect_manager::init(const char* default_addr, const char* addr_list, |
| 113 | size_t count, int conn_timeout /* 30 */, int rw_timeout /* 30 */, |
| 114 | bool sockopt_timeo /* false */) |
| 115 | { |
| 116 | if (addr_list != NULL && *addr_list != 0) { |
| 117 | set_service_list(addr_list, (int) count, conn_timeout, |
| 118 | rw_timeout, sockopt_timeo); |
| 119 | } |
| 120 | |
| 121 | // ����ȱʡ�������ӳض��ö���һͬ�����ܵ����ӳؼ�Ⱥ�� |
| 122 | if (default_addr == NULL || *default_addr == 0) { |
| 123 | logger("no default connection set"); |
| 124 | return; |
| 125 | } |
| 126 | |
| 127 | logger("default_pool: %s", default_addr); |
| 128 | int max = check_addr(default_addr, default_addr_, count); |
| 129 | if (max < 0) { |
| 130 | logger("no default connection set"); |
| 131 | return; |
| 132 | } |
| 133 | |
| 134 | set(default_addr_.c_str(), max, conn_timeout, rw_timeout, sockopt_timeo); |
| 135 | default_pool_ = get(default_addr_); |
| 136 | } |
| 137 | |
| 138 | void connect_manager::set_service_list(const char* addr_list, int count, |
| 139 | int conn_timeout, int rw_timeout, bool sockopt_timeo /* false */) |
nothing calls this directly
no test coverage detected