| 165 | } |
| 166 | |
| 167 | int Acceptor::Initialize() { |
| 168 | if (_socket_map.init(INITIAL_CONNECTION_CAP) != 0) { |
| 169 | LOG(WARNING) << "Fail to initialize FlatMap, size=" |
| 170 | << INITIAL_CONNECTION_CAP; |
| 171 | } |
| 172 | return 0; |
| 173 | } |
| 174 | |
| 175 | // NOTE: Join() can happen before StopAccept() |
| 176 | void Acceptor::Join() { |