Home
last modified time | relevance | path

Searched refs:close_flag_ (Results 1 – 25 of 27) sorted by relevance

12

/dports/net-im/tdlib/td-a53cb30e99f937cfd64e0266fa558785a184a553/td/telegram/
H A DSecretChatActor.cpp77 if (close_flag_) { in update_chat()
86 if (close_flag_) { in create_chat()
114 if (close_flag_) { in on_result_resendable()
147 if (close_flag_) { in replay_create_chat()
159 if (close_flag_) { in add_inbound_message()
171 if (close_flag_) { in replay_inbound_message()
194 if (close_flag_) { in replay_outbound_message()
236 if (close_flag_) { in send_message()
246 if (close_flag_) { in send_message_impl()
291 if (close_flag_) { in send_message_action()
[all …]
H A DSecretChatsManager.cpp168 if (dummy_mode_ || close_flag_) { in on_update_chat()
187 if (dummy_mode_ || close_flag_) { in on_new_message()
412 close_flag_ = true; in hangup()
433 if (close_flag_ && id_to_actor_.empty()) { in hangup_shared()
443 if (close_flag_ || dummy_mode_) { in flush_pending_chat_updates()
H A DGlobal.h383 close_flag_ = true; in set_close_flag()
386 return close_flag_.load(); in close_flag()
464 std::atomic<bool> close_flag_{false};
H A DCallManager.cpp159 close_flag_ = true; in hangup()
178 if (close_flag_ && id_to_actor_.empty()) { in hangup_shared()
H A DCallManager.h42 bool close_flag_ = false;
H A DSecretChatsManager.h56 bool close_flag_ = false; variable
H A DTd.h129 LOG_CHECK(close_flag_ < 1) << close_flag_ in create_net_actor()
238 LOG_CHECK(close_flag_ < 2) << close_flag_ in create_handler()
295 int close_flag_ = 0; variable
H A DTd.cpp3200 if (close_flag_ > 1) { in on_update()
3223 if (close_flag_ > 1) { in on_result()
3281 if (close_flag_) { in on_config_option_updated()
3421 LOG_CHECK(close_flag_ == 5) << close_flag_; in tear_down()
3461 close_flag_ = 3; in dec_actor_refcnt()
3526 close_flag_ = 4; in dec_actor_refcnt()
3537 close_flag_ = 5; in on_closed()
3589 close_flag_ = 2; in clear()
3713 if (close_flag_) { in close_impl()
3724 close_flag_ = 4; in close_impl()
[all …]
H A DConfigManager.cpp740 bool close_flag_{false}; member in td::ConfigRecoverer
751 close_flag_ = true; in hangup()
768 if (close_flag_) { in loop()
/dports/net-im/tdlib/td-a53cb30e99f937cfd64e0266fa558785a184a553/tdutils/td/utils/port/
H A DStdStreams.cpp92 close_flag_ = true; in close()
118 std::atomic<bool> close_flag_{false}; member in td::detail::BufferedStdinImpl
123 while (!close_flag_) { in read_loop()
H A DServerSocketFd.cpp96 bool close_flag_{false}; member in td::detail::ServerSocketFdImpl
107 close_flag_ = true; in on_close()
177 if (dec_refcnt() || close_flag_) { in on_iocp()
H A DSocketFd.cpp168 bool close_flag_{false}; member in td::detail::SocketFdImpl
198 if (close_flag_ || need_close_after_write_) { in loop_read()
259 if (dec_refcnt() || close_flag_) { in on_iocp()
337 close_flag_ = true; in on_close()
H A DUdpSocketFd.cpp161 bool close_flag_{false}; member in td::detail::UdpSocketFdImpl
194 if (close_flag_) { in loop_receive()
246 if (dec_refcnt() || close_flag_) { in on_iocp()
325 close_flag_ = true; in on_close()
/dports/net-im/tdlib/td-a53cb30e99f937cfd64e0266fa558785a184a553/test/
H A Dsecret.cpp488 , close_flag_(std::move(close_flag)) in FakeSecretChatContext()
503 return *close_flag_; in close_flag()
560 std::shared_ptr<bool> close_flag_; member in td::FakeSecretChatContext
578 close_flag_ = std::make_shared<bool>(false); in SecretChatProxy()
583 …td::make_unique<FakeSecretChatContext>(binlog_, key_value_, close_flag_, std::move(parent)), true); in SecretChatProxy()
644 *close_flag_ = false; in on_closed()
664 td::make_unique<FakeSecretChatContext>(binlog_, key_value_, close_flag_, in on_closed()
714 std::shared_ptr<bool> close_flag_; member in td::Master::SecretChatProxy
743 *close_flag_ = true; in timeout_expired()
/dports/net-im/tdlib/td-a53cb30e99f937cfd64e0266fa558785a184a553/td/telegram/net/
H A DDcAuthManager.h51 bool close_flag_{false};
H A DSession.cpp388 close_flag_ = true; in close()
503 if (!close_flag_ && is_main_) { in on_closed()
616 close_flag_ = true; in on_session_failed()
1087 if (close_flag_ || info->state_ != ConnectionInfo::State::Ready) { in connection_check_mode()
1098 if (close_flag_ || info->state_ != ConnectionInfo::State::Connecting) { in connection_open_finish()
1223 …return !close_flag_ && !need_check_main_key_ && (!auth_data_.use_pfs() || auth_data_.get_bind_flag… in need_send_query()
1392 if (!close_flag_ && long_poll_connection_.state_ == ConnectionInfo::State::Empty) { in loop()
1429 if (!close_flag_ && main_connection_.state_ == ConnectionInfo::State::Empty) { in loop()
H A DDcAuthManager.cpp223 if (close_flag_) { in loop()
H A DConnectionCreator.h178 bool close_flag_{false};
H A DSession.h168 bool close_flag_ = false; variable
H A DConnectionCreator.cpp296 CHECK(!close_flag_); in ping_proxy()
832 if (close_flag_) { in client_loop()
1194 close_flag_ = true; in hangup()
/dports/net-im/tdlib/td-a53cb30e99f937cfd64e0266fa558785a184a553/td/telegram/files/
H A DFileGenerateManager.h63 bool close_flag_ = false; variable
H A DFileGenerateManager.cpp478 close_flag_ = true; in hangup()
486 if (close_flag_ && query_id_to_query_.empty()) { in loop()
/dports/net-im/tdlib/td-a53cb30e99f937cfd64e0266fa558785a184a553/tdactor/td/actor/impl/
H A DScheduler.cpp177 << info->get_name() << " " << scheduler_->close_flag_; in ~EventGuard()
237 close_flag_ = true; in clear()
306 … << actor_info->migrate_dest() << " " << actor_info->is_running() << close_flag_; in register_migrated_actor()
H A DScheduler-decl.h220 bool close_flag_ = false; variable
H A DScheduler.h184 if (unlikely(actor_info == nullptr || close_flag_)) { in send_impl()

12