Lines Matching refs:mtproto
52 GenAuthKeyActor(Slice name, unique_ptr<mtproto::AuthKeyHandshake> handshake, in GenAuthKeyActor()
53 unique_ptr<mtproto::AuthKeyHandshakeContext> context, in GenAuthKeyActor()
54 Promise<unique_ptr<mtproto::RawConnection>> connection_promise, in GenAuthKeyActor()
55 Promise<unique_ptr<mtproto::AuthKeyHandshake>> handshake_promise, in GenAuthKeyActor()
67 send_closure(std::move(child_), &mtproto::HandshakeActor::close); in on_network()
74 unique_ptr<mtproto::AuthKeyHandshake> handshake_;
75 unique_ptr<mtproto::AuthKeyHandshakeContext> context_;
76 Promise<unique_ptr<mtproto::RawConnection>> connection_promise_;
77 Promise<unique_ptr<mtproto::AuthKeyHandshake>> handshake_promise_;
81 ActorOwn<mtproto::HandshakeActor> child_;
90 … [actor_id = actor_id(this)](Result<unique_ptr<mtproto::RawConnection>> r_raw_connection) { in start_up()
105 void on_connection(Result<unique_ptr<mtproto::RawConnection>> r_raw_connection, bool dummy) { in on_connection()
115 child_ = create_actor_on_scheduler<mtproto::HandshakeActor>( in on_connection()
145 … const mtproto::AuthKey &tmp_auth_key, const vector<mtproto::ServerSalt> &server_salts) in Session()
447 …mtproto::ConnectionManager::connection(static_cast<ActorId<mtproto::ConnectionManager>>(G()->state… in on_connected()
1061 [actor_id = actor_id(this), info = info](Result<unique_ptr<mtproto::RawConnection>> res) { in connection_open()
1070 unique_ptr<mtproto::AuthData> auth_data; in connection_open()
1080 void Session::connection_add(unique_ptr<mtproto::RawConnection> raw_connection) { in connection_add()
1097 Result<unique_ptr<mtproto::RawConnection>> r_raw_connection) { in connection_open_finish()
1120 …raw_connection->get_transport_type().type == mtproto::TransportType::Http ? Mode::Http : Mode::Tcp; in connection_open_finish()
1133 mtproto::SessionConnection::Mode mode; in connection_open_finish()
1136 mode = mtproto::SessionConnection::Mode::Tcp; in connection_open_finish()
1140 mode = mtproto::SessionConnection::Mode::Http; in connection_open_finish()
1143 mode = mtproto::SessionConnection::Mode::HttpLongPoll; in connection_open_finish()
1149 …info->connection_ = make_unique<mtproto::SessionConnection>(mode, std::move(raw_connection), &auth… in connection_open_finish()
1180 …info->wakeup_at_ = info->connection_->flush(static_cast<mtproto::SessionConnection::Callback *>(th… in connection_flush()
1188 info->connection_->force_close(static_cast<mtproto::SessionConnection::Callback *>(this)); in connection_close()
1255 void Session::on_handshake_ready(Result<unique_ptr<mtproto::AuthKeyHandshake>> r_handshake) { in on_handshake_ready()
1309 …info.handshake_ = make_unique<mtproto::AuthKeyHandshake>(dc_id_, is_main && !is_cdn_ ? 0 : 24 * 60… in create_gen_auth_key_actor()
1311 class AuthKeyHandshakeContext final : public mtproto::AuthKeyHandshakeContext { in create_gen_auth_key_actor()
1313 AuthKeyHandshakeContext(mtproto::DhCallback *dh_callback, in create_gen_auth_key_actor()
1314 std::shared_ptr<mtproto::PublicRsaKeyInterface> public_rsa_key) in create_gen_auth_key_actor()
1317 mtproto::DhCallback *get_dh_callback() final { in create_gen_auth_key_actor()
1320 mtproto::PublicRsaKeyInterface *get_public_rsa_key_interface() final { in create_gen_auth_key_actor()
1325 mtproto::DhCallback *dh_callback_; in create_gen_auth_key_actor()
1326 std::shared_ptr<mtproto::PublicRsaKeyInterface> public_rsa_key_; in create_gen_auth_key_actor()
1332 …[self = actor_id(this), guard = callback_](Result<unique_ptr<mtproto::RawConnection>> r_connection… in create_gen_auth_key_actor()
1343 … guard = callback_](Result<unique_ptr<mtproto::AuthKeyHandshake>> handshake) mutable { in create_gen_auth_key_actor()