| 2939 | } |
| 2940 | |
| 2941 | void Socket::OnProgressiveReadCompleted() { |
| 2942 | if (is_read_progressive() && |
| 2943 | (_controller_released_socket.load(butil::memory_order_relaxed) || |
| 2944 | _controller_released_socket.exchange( |
| 2945 | true, butil::memory_order_relaxed))) { |
| 2946 | if (_connection_type_for_progressive_read == CONNECTION_TYPE_POOLED) { |
| 2947 | ReturnToPool(); |
| 2948 | } else if (_connection_type_for_progressive_read == CONNECTION_TYPE_SHORT) { |
| 2949 | SetFailed(EUNUSED, "[%s]Close short connection", __FUNCTION__); |
| 2950 | } |
| 2951 | } |
| 2952 | } |
| 2953 | |
| 2954 | SocketSSLContext::SocketSSLContext() |
| 2955 | : raw_ctx(NULL) |
no test coverage detected