| 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()) { |
| 314 | return; |
| 315 | } |
| 316 | auto it2 = out_queries_.find(id); |
| 317 | if (it2 != out_queries_.end()) { |
| 318 | td::actor::send_closure(it2->second, &TcpOutboundQuery::answer_error, std::move(error)); |
| 319 | } |
| 320 | } |
| 321 | void process_query(ConnectionId connection_id, QueryId id, td::BufferSlice data) { |
| 322 | LOG(DEBUG) << "tcp: processing query from " << connection_id; |
| 323 | auto it = active_connections_.find(connection_id); |
nothing calls this directly
no outgoing calls
no test coverage detected