| 964 | when(wait(delay(FLOW_KNOBS->CONNECTION_MONITOR_TIMEOUT))) { throw connection_failed(); } |
| 965 | } |
| 966 | } catch (Error& e) { |
| 967 | if (e.code() != error_code_actor_cancelled) { |
| 968 | auto iter(g_network->networkInfo.serverTLSConnectionThrottler.find(peerIP)); |
| 969 | if (iter != g_network->networkInfo.serverTLSConnectionThrottler.end()) { |
| 970 | iter->second.first++; |
| 971 | } else { |
| 972 | g_network->networkInfo.serverTLSConnectionThrottler[peerIP] = |
| 973 | std::make_pair(0, now() + FLOW_KNOBS->TLS_SERVER_CONNECTION_THROTTLE_TIMEOUT); |
| 974 | } |
| 975 | } |
| 976 | // Either the connection failed, or was cancelled by the caller |
| 977 | self->closeSocket(); |
| 978 | throw; |
| 979 | } |
| 980 | } |
| 981 | |
| 982 | Future<Void> acceptHandshake() override { return acceptHandshakeWrapper(Reference<SSLConnection>::addRef(this)); } |
nothing calls this directly
no test coverage detected