| 277 | } |
| 278 | } |
| 279 | void send_query_answer_error(ConnectionId connection_id, td::int64 query_id, td::Status error) { |
| 280 | auto it = active_connections_.find(connection_id); |
| 281 | if (it != active_connections_.end()) { |
| 282 | td::actor::send_closure(it->second.connection, &TcpClientConnection::send_query_answer_error, query_id, |
| 283 | std::move(error)); |
| 284 | } |
| 285 | } |
| 286 | void send_packet(ConnectionId connection_id, td::BufferSlice data) override { |
| 287 | auto it = active_connections_.find(connection_id); |
| 288 | if (it != active_connections_.end()) { |
nothing calls this directly
no outgoing calls
no test coverage detected