| 187 | } |
| 188 | |
| 189 | void InsertToSending(TConnection* connection) { |
| 190 | Y_ABORT_UNLESS(connection, "null connection inserted\n"); |
| 191 | if (connection->Sending == false) { |
| 192 | SendingConnectionList.insert(SendingConnectionList.end(), connection); |
| 193 | } |
| 194 | connection->Sending = true; |
| 195 | } |
| 196 | |
| 197 | template <typename F> |
| 198 | void ForEachActiveConnection(const F& function) { |
no test coverage detected