Home
last modified time | relevance | path

Searched refs:net_query (Results 1 – 25 of 39) sorted by relevance

12

/dports/net-im/tdlib/td-a53cb30e99f937cfd64e0266fa558785a184a553/td/telegram/net/
H A DNetQueryDispatcher.cpp58 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 DNetQuery.h34 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 DSession.cpp269 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 DNetQueryDispatcher.h44 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 DPublicRsaKeyWatchdog.cpp84 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 DSession.h66 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 DPublicRsaKeyWatchdog.h42 void on_result(NetQueryPtr net_query) final;
H A DNetQuery.cpp18 int VERBOSITY_NAME(net_query) = VERBOSITY_NAME(INFO);
/dports/net-im/tdlib/td-a53cb30e99f937cfd64e0266fa558785a184a553/td/telegram/files/
H A DFileDownloader.cpp153 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 DFileHashUploader.cpp117 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 DFileUploader.cpp277 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 DFileDownloader.h86 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 DFileLoader.h74 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 DFileHashUploader.h79 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 DDelayDispatcher.cpp36 …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 DDeviceTokenManager.cpp380 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 DPrivacyManager.cpp432 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 DPhoneNumberManager.cpp157 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 DDelayDispatcher.h32 NetQueryPtr net_query; member
H A DCallbackQueriesManager.cpp68 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 DPhoneNumberManager.h57 void start_net_query(NetQueryType net_query_type, NetQueryPtr net_query);
/dports/net-im/tdlib/td-a53cb30e99f937cfd64e0266fa558785a184a553/test/
H A Dsecret.cpp826 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 DMakefile.am49 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 DMakefile.am45 net_query.c net_query.h \
95 net_query.c net_query.h \
197 net_query.c net_query.h \
H A DMakefile.in129 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 …]

12