MCPcopy Create free account
hub / github.com/TelegramMessenger/cocoon / process_query_answer

Method process_query_answer

net/TcpClient.hpp:300–310  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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()) {

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected