Searched refs:r_raw_connection (Results 1 – 6 of 6) sorted by relevance
| /dports/net-im/tdlib/td-a53cb30e99f937cfd64e0266fa558785a184a553/test/ |
| H A D | mtproto.cpp | 378 void got_connection(Result<unique_ptr<mtproto::RawConnection>> r_raw_connection, int32 dummy) { in got_connection() argument
381 if (r_raw_connection.is_ok()) { in got_connection()
382 raw_connection_ = r_raw_connection.move_as_ok(); in got_connection()
385 status_ = r_raw_connection.move_as_error(); in got_connection()
561 void got_connection(Result<unique_ptr<mtproto::RawConnection>> r_raw_connection, int32 dummy) { in got_connection() argument
562 if (r_raw_connection.is_error()) { in got_connection()
563 *result_ = r_raw_connection.move_as_error(); in got_connection()
567 connection_ = r_raw_connection.move_as_ok(); in got_connection()
616 …ator::lambda([self = actor_id(this)](Result<unique_ptr<mtproto::RawConnection>> r_raw_connection) { in loop() argument
617 send_closure(self, &FastPingTestActor::got_raw_connection, std::move(r_raw_connection)); in loop()
|
| /dports/net-im/tdlib/td-a53cb30e99f937cfd64e0266fa558785a184a553/td/telegram/net/ |
| H A D | Session.cpp | 90 … [actor_id = actor_id(this)](Result<unique_ptr<mtproto::RawConnection>> r_raw_connection) { in start_up() argument
91 … send_closure(actor_id, &GenAuthKeyActor::on_connection, std::move(r_raw_connection), false); in start_up()
105 void on_connection(Result<unique_ptr<mtproto::RawConnection>> r_raw_connection, bool dummy) { in on_connection() argument
106 if (r_raw_connection.is_error()) { in on_connection()
107 connection_promise_.set_error(r_raw_connection.move_as_error()); in on_connection()
112 auto raw_connection = r_raw_connection.move_as_ok(); in on_connection()
1097 Result<unique_ptr<mtproto::RawConnection>> r_raw_connection) { in connection_open_finish() argument
1103 if (r_raw_connection.is_error()) { in connection_open_finish()
1104 LOG(WARNING) << "Failed to open socket: " << r_raw_connection.error(); in connection_open_finish()
1110 auto raw_connection = r_raw_connection.move_as_ok(); in connection_open_finish()
|
| H A D | ConnectionCreator.cpp | 1022 …or::client_add_connection(size_t hash, Result<unique_ptr<mtproto::RawConnection>> r_raw_connection, in client_add_connection() argument
1032 if (r_raw_connection.is_ok()) { in client_add_connection()
1033 VLOG(connections) << "Add ready connection " << r_raw_connection.ok().get() << " for " in client_add_connection()
1036 client.ready_connections.emplace_back(r_raw_connection.move_as_ok(), Time::now_cached()); in client_add_connection()
1038 if (r_raw_connection.error().code() == -404 && client.auth_data && in client_add_connection()
|
| H A D | ConnectionCreator.h | 224 …_connection(size_t hash, Result<unique_ptr<mtproto::RawConnection>> r_raw_connection, bool check_f…
|
| H A D | Session.h | 244 …ion_open_finish(ConnectionInfo *info, Result<unique_ptr<mtproto::RawConnection>> r_raw_connection);
|
| /dports/net-im/tdlib/td-a53cb30e99f937cfd64e0266fa558785a184a553/td/telegram/ |
| H A D | Td.cpp | 570 void on_handshake_connection(Result<unique_ptr<mtproto::RawConnection>> r_raw_connection) { in on_handshake_connection() argument
571 if (r_raw_connection.is_error()) { in on_handshake_connection()
572 … return promise_.set_error(Status::Error(400, r_raw_connection.move_as_error().public_message())); in on_handshake_connection()
|