/dports/net-im/tdlib/td-a53cb30e99f937cfd64e0266fa558785a184a553/td/telegram/net/ |
H A D | NetQueryDispatcher.cpp | 58 if (net_query->is_ready()) { in dispatch() 59 if (net_query->is_error()) { in dispatch() 62 try_fix_migrate(net_query); in dispatch() 64 net_query->resend(); in dispatch() 72 if (!net_query->is_ready()) { in dispatch() 86 if (net_query->is_ready()) { in dispatch() 90 if (net_query->dispatch_ttl_ > 0) { in dispatch() 91 net_query->dispatch_ttl_--; in dispatch() 96 switch (net_query->type()) { in dispatch() 195 dispatch(std::move(net_query)); in dispatch_with_callback() [all …]
|
H A D | NetQuery.h | 34 extern int VERBOSITY_NAME(net_query); 81 VLOG(net_query) << "Resend" << *this; in resend() 131 VLOG(net_query) << "Got answer " << *this; in set_ok() 370 stream << tag("id", net_query.id()); 372 if (!net_query.is_ready()) { 374 } else if (net_query.is_error()) { 376 stream << net_query.error(); 377 } else if (net_query.is_ok()) { 438 net_query->start_migrate(sched_id); in start_migrate() 441 inline void finish_migrate(NetQueryPtr &net_query) { in finish_migrate() argument [all …]
|
H A D | Session.cpp | 269 VLOG(net_query) << "Got query " << query; in send() 975 net_query->debug("Session: pending"); in add_query() 978 pending_queries_.push(std::move(net_query)); in add_query() 986 if (net_query->update_is_ready()) { in connection_send_query() 1007 …info->connection_->send_query(net_query->query().clone(), net_query->gzip_flag() == NetQuery::Gzip… in connection_send_query() 1010 net_query->on_net_write(net_query->query().size()); in connection_send_query() 1021 …VLOG(net_query) << "Send query to connection " << net_query << " [msg_id:" << format::as_hex(messa… in connection_send_query() 1023 net_query->set_message_id(message_id); in connection_send_query() 1024 net_query->cancel_slot_.clear_event(); in connection_send_query() 1027 auto lock = net_query->lock(); in connection_send_query() [all …]
|
H A D | NetQueryDispatcher.h | 44 void dispatch(NetQueryPtr net_query); 45 void dispatch_with_callback(NetQueryPtr net_query, ActorShared<NetQueryCallback> callback); 94 static void complete_net_query(NetQueryPtr net_query); 96 void try_fix_migrate(NetQueryPtr &net_query);
|
H A D | PublicRsaKeyWatchdog.cpp | 84 void PublicRsaKeyWatchdog::on_result(NetQueryPtr net_query) { in on_result() argument 87 if (net_query->is_error()) { in on_result() 88 LOG(ERROR) << "Receive error for GetCdnConfig: " << net_query->move_as_error(); in on_result() 93 auto buf = net_query->move_as_ok(); in on_result()
|
H A D | Session.h | 66 virtual void on_result(NetQueryPtr net_query) = 0; 238 void add_query(NetQueryPtr &&net_query); 249 void connection_send_query(ConnectionInfo *info, NetQueryPtr &&net_query, uint64 message_id = 0);
|
H A D | PublicRsaKeyWatchdog.h | 42 void on_result(NetQueryPtr net_query) final;
|
H A D | NetQuery.cpp | 18 int VERBOSITY_NAME(net_query) = VERBOSITY_NAME(INFO);
|
/dports/net-im/tdlib/td-a53cb30e99f937cfd64e0266fa558785a184a553/td/telegram/files/ |
H A D | FileDownloader.cpp | 153 if (net_query->is_error()) { in should_restart_part() 239 NetQueryPtr net_query; in start_part() local 250 net_query = remote_.is_web() in start_part() 272 net_query = in start_part() 278 net_query = G()->net_query_creator().create( in start_part() 285 return std::make_pair(std::move(net_query), false); in start_part() 289 if (net_query->is_error()) { in check_net_query() 290 auto error = net_query->move_as_error(); in check_net_query() 302 TRY_STATUS(check_net_query(net_query)); in process_part() 414 TRY_STATUS(check_net_query(net_query)); in process_check_query() [all …]
|
H A D | FileHashUploader.cpp | 117 void FileHashUploader::on_result(NetQueryPtr net_query) { in on_result() argument 118 auto status = on_result_impl(std::move(net_query)); in on_result() 126 Status FileHashUploader::on_result_impl(NetQueryPtr net_query) { in on_result_impl() argument 127 if (net_query->is_error()) { in on_result_impl() 128 return net_query->move_as_error(); in on_result_impl() 130 TRY_RESULT(res, fetch_result<telegram_api::messages_getDocumentByHash>(net_query->ok())); in on_result_impl()
|
H A D | FileUploader.cpp | 277 NetQueryPtr net_query; in start_part() local 281 net_query = G()->net_query_creator().create(query, DcId::main(), NetQuery::Type::Upload); in start_part() 284 net_query = G()->net_query_creator().create(query, DcId::main(), NetQuery::Type::Upload); in start_part() 286 net_query->file_type_ = narrow_cast<int32>(file_type_); in start_part() 287 return std::make_pair(std::move(net_query), false); in start_part() 290 Result<size_t> FileUploader::process_part(Part part, NetQueryPtr net_query) { in process_part() argument 291 if (net_query->is_error()) { in process_part() 292 return std::move(net_query->error()); in process_part() 296 return fetch_result<telegram_api::upload_saveBigFilePart>(net_query->ok()); in process_part() 298 return fetch_result<telegram_api::upload_saveFilePart>(net_query->ok()); in process_part()
|
H A D | FileDownloader.h | 86 Result<bool> should_restart_part(Part part, NetQueryPtr &net_query) final TD_WARN_UNUSED_RESULT; 89 Result<size_t> process_part(Part part, NetQueryPtr net_query) final TD_WARN_UNUSED_RESULT; 92 Status process_check_query(NetQueryPtr net_query) final; 101 Status check_net_query(NetQueryPtr &net_query);
|
H A D | FileLoader.h | 74 virtual Result<size_t> process_part(Part part, NetQueryPtr net_query) TD_WARN_UNUSED_RESULT = 0; 90 …virtual Result<bool> should_restart_part(Part part, NetQueryPtr &net_query) TD_WARN_UNUSED_RESULT { in should_restart_part() argument 94 virtual Status process_check_query(NetQueryPtr net_query) { in process_check_query() argument
|
H A D | FileHashUploader.h | 79 void on_result(NetQueryPtr net_query) final; 81 Status on_result_impl(NetQueryPtr net_query);
|
/dports/net-im/tdlib/td-a53cb30e99f937cfd64e0266fa558785a184a553/td/telegram/ |
H A D | DelayDispatcher.cpp | 36 …G()->net_query_dispatcher().dispatch_with_callback(std::move(query.net_query), std::move(query.cal… in loop() 51 query.net_query->clear(); in close_silent() 60 query.net_query->set_error(Global::request_aborted_error()); in tear_down() 61 … send_closure(std::move(query.callback), &NetQueryCallback::on_result, std::move(query.net_query)); in tear_down()
|
H A D | DeviceTokenManager.cpp | 380 NetQueryPtr net_query; in loop() local 382 net_query = G()->net_query_creator().create( in loop() 386 net_query = G()->net_query_creator().create( in loop() 390 info.net_query_id = net_query->id(); in loop() 391 …G()->net_query_dispatcher().dispatch_with_callback(std::move(net_query), actor_shared(this, token_… in loop() 395 void DeviceTokenManager::on_result(NetQueryPtr net_query) { in on_result() argument 399 if (info.net_query_id != net_query->id()) { in on_result() 400 net_query->clear(); in on_result() 409 auto r_flag = fetch_result<telegram_api::account_registerDevice>(std::move(net_query)); in on_result()
|
H A D | PrivacyManager.cpp | 432 auto net_query = in get_privacy() local 435 send_with_promise(std::move(net_query), in get_privacy() 438 TRY_RESULT(net_query, std::move(x_net_query)); in get_privacy() 439 … TRY_RESULT(rules, fetch_result<telegram_api::account_getPrivacy>(std::move(net_query))); in get_privacy() 456 auto net_query = G()->net_query_creator().create(telegram_api::account_setPrivacy( in set_privacy() local 461 …std::move(net_query), PromiseCreator::lambda([this, user_privacy_setting, promise = std::move(prom… in set_privacy() 465 TRY_RESULT(net_query, std::move(x_net_query)); in set_privacy() 466 TRY_RESULT(rules, fetch_result<telegram_api::account_setPrivacy>(std::move(net_query))); in set_privacy()
|
H A D | PhoneNumberManager.cpp | 157 void PhoneNumberManager::start_net_query(NetQueryType net_query_type, NetQueryPtr net_query) { in start_net_query() argument 160 net_query_id_ = net_query->id(); in start_net_query() 161 G()->net_query_dispatcher().dispatch_with_callback(std::move(net_query), actor_shared(this)); in start_net_query()
|
H A D | DelayDispatcher.h | 32 NetQueryPtr net_query; member
|
H A D | CallbackQueriesManager.cpp | 68 auto net_query = G()->net_query_creator().create(telegram_api::messages_getBotCallbackAnswer( in send() local 71 net_query->need_resend_on_503_ = false; in send() 72 send_query(std::move(net_query)); in send()
|
H A D | PhoneNumberManager.h | 57 void start_net_query(NetQueryType net_query_type, NetQueryPtr net_query);
|
/dports/net-im/tdlib/td-a53cb30e99f937cfd64e0266fa558785a184a553/test/ |
H A D | secret.cpp | 826 void process_net_query(my_api::messages_getDhConfig &&get_dh_config, NetQueryPtr net_query, in process_net_query() argument 837 net_query->set_ok(std::move(answer)); in process_net_query() 838 send_closure(std::move(callback), &NetQueryCallback::on_result, std::move(net_query)); in process_net_query() 848 net_query->clear(); in process_net_query() 862 net_query->set_ok(std::move(answer)); in process_net_query() 863 send_closure(std::move(callback), &NetQueryCallback::on_result, std::move(net_query)); in process_net_query() 891 void process_net_query(my_api::messages_sendEncryptedService &&message, NetQueryPtr net_query, in process_net_query() argument 895 void process_net_query(my_api::messages_sendEncrypted &&message, NetQueryPtr net_query, in process_net_query() argument 899 void process_net_query_send_encrypted(BufferSlice data, NetQueryPtr net_query, in process_net_query_send_encrypted() argument 904 net_query->set_ok(std::move(answer)); in process_net_query_send_encrypted() [all …]
|
/dports/games/crispy-doom/crispy-doom-crispy-doom-5.10.3/src/ |
H A D | Makefile.am | 49 net_query.c net_query.h \ 103 net_query.c net_query.h \ 207 net_query.c net_query.h \
|
/dports/games/chocolate-doom/chocolate-doom-3.0.1/src/ |
H A D | Makefile.am | 45 net_query.c net_query.h \ 95 net_query.c net_query.h \ 197 net_query.c net_query.h \
|
H A D | Makefile.in | 129 net_loop.h net_packet.c net_packet.h net_query.c net_query.h \ 187 net_query.c net_query.h net_sdl.c net_sdl.h net_server.c \ 219 net_query.c net_query.h net_sdl.c net_sdl.h net_server.c \ 236 net_query.$(OBJEXT) net_server.$(OBJEXT) \ 275 net_query.c net_query.h net_sdl.c net_sdl.h net_server.c \ 356 ./$(DEPDIR)/net_packet.Po ./$(DEPDIR)/net_query.Po \ 623 net_query.c net_query.h \ 672 net_query.c net_query.h \ 736 net_query.c net_query.h \ 1327 -rm -f ./$(DEPDIR)/net_query.Po [all …]
|