| 298 | callback_->receive_message(connection_id, std::move(data)); |
| 299 | } |
| 300 | void process_query_answer(ConnectionId connection_id, QueryId id, td::BufferSlice data) { |
| 301 | LOG(DEBUG) << "tcp: processing query answer from " << connection_id; |
| 302 | auto it = active_connections_.find(connection_id); |
| 303 | if (it == active_connections_.end()) { |
| 304 | return; |
| 305 | } |
| 306 | auto it2 = out_queries_.find(id); |
| 307 | if (it2 != out_queries_.end()) { |
| 308 | td::actor::send_closure(it2->second, &TcpOutboundQuery::answer, std::move(data)); |
| 309 | } |
| 310 | } |
| 311 | void process_query_error(ConnectionId connection_id, QueryId id, td::Status error) { |
| 312 | auto it = active_connections_.find(connection_id); |
| 313 | if (it == active_connections_.end()) { |
nothing calls this directly
no outgoing calls
no test coverage detected