| /dports/net-im/tdlib/td-a53cb30e99f937cfd64e0266fa558785a184a553/td/mtproto/ |
| H A D | Ping.cpp | 75 if (!raw_connection) { in create_ping_actor()
82 if (raw_connection->stats_callback()) { in create_ping_actor()
83 raw_connection->stats_callback()->on_error(); in create_ping_actor()
85 raw_connection->close(); in create_ping_actor()
88 raw_connection->extra().rtt = ping_connection_->rtt(); in create_ping_actor()
89 if (raw_connection->stats_callback()) { in create_ping_actor()
90 raw_connection->stats_callback()->on_pong(); in create_ping_actor()
92 promise_.set_value(std::move(raw_connection)); in create_ping_actor()
95 if (raw_connection->stats_callback()) { in create_ping_actor()
96 raw_connection->stats_callback()->on_error(); in create_ping_actor()
[all …]
|
| H A D | HandshakeActor.cpp | 74 auto raw_connection = connection_->move_as_raw_connection(); in return_connection() local
75 if (!raw_connection) { in return_connection()
85 if (raw_connection->stats_callback()) { in return_connection()
86 raw_connection->stats_callback()->on_error(); in return_connection()
88 raw_connection->close(); in return_connection()
91 if (raw_connection->stats_callback()) { in return_connection()
92 raw_connection->stats_callback()->on_pong(); in return_connection()
94 raw_connection_promise_.set_value(std::move(raw_connection)); in return_connection()
97 if (raw_connection->stats_callback()) { in return_connection()
98 raw_connection->stats_callback()->on_error(); in return_connection()
[all …]
|
| H A D | PingConnection.cpp | 34 PingConnectionReqPQ(unique_ptr<RawConnection> raw_connection, size_t ping_count) in PingConnectionReqPQ() argument
35 : raw_connection_(std::move(raw_connection)), ping_count_(ping_count) { in PingConnectionReqPQ()
93 PingConnectionPingPong(unique_ptr<RawConnection> raw_connection, unique_ptr<AuthData> auth_data) in PingConnectionPingPong() argument
98 …make_unique<SessionConnection>(SessionConnection::Mode::Tcp, std::move(raw_connection), auth_data_… in PingConnectionPingPong()
191 unique_ptr<PingConnection> PingConnection::create_req_pq(unique_ptr<RawConnection> raw_connection, … in create_req_pq() argument
192 return make_unique<detail::PingConnectionReqPQ>(std::move(raw_connection), ping_count); in create_req_pq()
195 …ique_ptr<PingConnection> PingConnection::create_ping_pong(unique_ptr<RawConnection> raw_connection, in create_ping_pong() argument
197 …return make_unique<detail::PingConnectionPingPong>(std::move(raw_connection), std::move(auth_data)… in create_ping_pong()
|
| H A D | PingConnection.h | 28 …static unique_ptr<PingConnection> create_req_pq(unique_ptr<RawConnection> raw_connection, size_t p…
29 static unique_ptr<PingConnection> create_ping_pong(unique_ptr<RawConnection> raw_connection,
|
| H A D | HandshakeConnection.h | 31 HandshakeConnection(unique_ptr<RawConnection> raw_connection, AuthKeyHandshake *handshake, in HandshakeConnection() argument
33 …: raw_connection_(std::move(raw_connection)), handshake_(handshake), context_(std::move(context)) { in HandshakeConnection()
|
| /dports/security/vaultwarden/vaultwarden-1.23.1/cargo-crates/diesel-1.4.8/src/sqlite/connection/ |
| H A D | stmt.rs | 21 pub fn prepare(raw_connection: &RawConnection, sql: &str) -> QueryResult<Self> { in prepare()
26 raw_connection.internal_connection.as_ptr(), in prepare()
54 ensure_sqlite_ok(result, self.raw_connection()) in bind()
83 _ => Err(last_error(self.raw_connection())), in step()
92 fn raw_connection(&self) -> *mut ffi::sqlite3 { in raw_connection() method
101 Err(last_error(raw_connection)) in ensure_sqlite_ok()
105 fn last_error(raw_connection: *mut ffi::sqlite3) -> Error { in last_error()
106 let error_message = last_error_message(raw_connection); in last_error()
108 let error_kind = match last_error_code(raw_connection) { in last_error()
131 let raw_connection = self.raw_connection(); in drop() localVariable
[all …]
|
| H A D | mod.rs | 33 raw_connection: RawConnection, field
44 self.raw_connection.exec(query) in batch_execute()
55 let raw_connection = RawConnection::establish(database_url)?; in establish() localVariable
58 raw_connection, in establish()
69 Ok(self.raw_connection.rows_affected_by_last_query()) in execute()
106 Ok(self.raw_connection.rows_affected_by_last_query()) in execute_returning_count()
218 Statement::prepare(&self.raw_connection, sql) in cached_prepared_statement()
236 &self.raw_connection, in register_sql_function()
247 &self.raw_connection, in register_diesel_sql_functions()
|
| /dports/audio/gnome-podcasts/podcasts-c86f7bfdef7692bbf20f315a90450321f6ca9ce7/cargo-crates/diesel-1.4.8/src/sqlite/connection/ |
| H A D | stmt.rs | 21 pub fn prepare(raw_connection: &RawConnection, sql: &str) -> QueryResult<Self> { in prepare()
26 raw_connection.internal_connection.as_ptr(), in prepare()
54 ensure_sqlite_ok(result, self.raw_connection()) in bind()
83 _ => Err(last_error(self.raw_connection())), in step()
92 fn raw_connection(&self) -> *mut ffi::sqlite3 { in raw_connection() method
101 Err(last_error(raw_connection)) in ensure_sqlite_ok()
105 fn last_error(raw_connection: *mut ffi::sqlite3) -> Error { in last_error()
106 let error_message = last_error_message(raw_connection); in last_error()
108 let error_kind = match last_error_code(raw_connection) { in last_error()
131 let raw_connection = self.raw_connection(); in drop() localVariable
[all …]
|
| H A D | mod.rs | 33 raw_connection: RawConnection, field
44 self.raw_connection.exec(query) in batch_execute()
55 let raw_connection = RawConnection::establish(database_url)?; in establish() localVariable
58 raw_connection, in establish()
69 Ok(self.raw_connection.rows_affected_by_last_query()) in execute()
106 Ok(self.raw_connection.rows_affected_by_last_query()) in execute_returning_count()
218 Statement::prepare(&self.raw_connection, sql) in cached_prepared_statement()
236 &self.raw_connection, in register_sql_function()
247 &self.raw_connection, in register_diesel_sql_functions()
|
| /dports/security/vaultwarden/vaultwarden-1.23.1/cargo-crates/diesel-1.4.8/src/mysql/connection/ |
| H A D | mod.rs | 21 raw_connection: RawConnection, field
30 self.raw_connection in batch_execute()
31 .enable_multi_statements(|| self.raw_connection.execute(query)) in batch_execute()
42 let raw_connection = RawConnection::new(); in establish() localVariable
44 raw_connection.connect(&connection_options)?; in establish()
46 raw_connection: raw_connection, in establish()
57 self.raw_connection in execute()
59 .map(|_| self.raw_connection.affected_rows()) in execute()
122 .cached_statement(source, &[], |sql| self.raw_connection.prepare(sql))?; in prepare_query()
|
| H A D | raw.rs | 17 let raw_connection = unsafe { ffi::mysql_init(ptr::null_mut()) }; in new() localVariable
20 let raw_connection = in new() localVariable
21 NonNull::new(raw_connection).expect("Insufficient memory to allocate connection"); in new()
22 let result = RawConnection(raw_connection); in new()
|
| /dports/audio/gnome-podcasts/podcasts-c86f7bfdef7692bbf20f315a90450321f6ca9ce7/cargo-crates/diesel-1.4.8/src/mysql/connection/ |
| H A D | mod.rs | 21 raw_connection: RawConnection, field
30 self.raw_connection in batch_execute()
31 .enable_multi_statements(|| self.raw_connection.execute(query)) in batch_execute()
42 let raw_connection = RawConnection::new(); in establish() localVariable
44 raw_connection.connect(&connection_options)?; in establish()
46 raw_connection: raw_connection, in establish()
57 self.raw_connection in execute()
59 .map(|_| self.raw_connection.affected_rows()) in execute()
122 .cached_statement(source, &[], |sql| self.raw_connection.prepare(sql))?; in prepare_query()
|
| H A D | raw.rs | 17 let raw_connection = unsafe { ffi::mysql_init(ptr::null_mut()) }; in new() localVariable
20 let raw_connection = in new() localVariable
21 NonNull::new(raw_connection).expect("Insufficient memory to allocate connection"); in new()
22 let result = RawConnection(raw_connection); in new()
|
| /dports/databases/postgresql-libpqxx/libpqxx-7.2.0/src/ |
| H A D | largeobject.cxx | 67 m_id = lo_creat(raw_connection(t), 0); in largeobject()
80 m_id = lo_import(raw_connection(t), file.data()); in largeobject()
102 if (lo_export(raw_connection(t), id(), file.data()) == -1) in to_file()
120 if (lo_unlink(raw_connection(t), id()) == -1) in remove()
133 pqxx::largeobject::raw_connection(dbtransaction const &t) in raw_connection() function in pqxx::largeobject
136 .raw_connection(); in raw_connection()
207 return std::max(lo_write(raw_connection(), m_fd, buf, len), -1); in cwrite()
214 return std::max(lo_read(raw_connection(), m_fd, buf, len), -1); in cread()
221 return lo_tell64(raw_connection(), m_fd); in ctell()
276 m_fd = lo_open(raw_connection(), id(), std_mode_to_pq_mode(mode)); in open()
[all …]
|
| /dports/security/vaultwarden/vaultwarden-1.23.1/cargo-crates/diesel-1.4.8/src/pg/connection/ |
| H A D | mod.rs | 29 raw_connection: RawConnection, field
39 let inner_result = unsafe { self.raw_connection.exec(query.as_ptr()) }; in batch_execute()
52 raw_connection: raw_conn, in establish()
77 .execute(&self.raw_connection, ¶ms) in query_by_index()
89 .execute(&self.raw_connection, ¶ms) in query_by_name()
100 .execute(&self.raw_connection, ¶ms) in execute_returning_count()
159 &self.raw_connection, in prepare_query()
170 let query = Statement::prepare(&self.raw_connection, query, None, &[])?; in execute_inner()
171 query.execute(&self.raw_connection, &Vec::new()) in execute_inner()
177 self.raw_connection in set_config_options()
|
| /dports/audio/gnome-podcasts/podcasts-c86f7bfdef7692bbf20f315a90450321f6ca9ce7/cargo-crates/diesel-1.4.8/src/pg/connection/ |
| H A D | mod.rs | 29 raw_connection: RawConnection, field
39 let inner_result = unsafe { self.raw_connection.exec(query.as_ptr()) }; in batch_execute()
52 raw_connection: raw_conn, in establish()
77 .execute(&self.raw_connection, ¶ms) in query_by_index()
89 .execute(&self.raw_connection, ¶ms) in query_by_name()
100 .execute(&self.raw_connection, ¶ms) in execute_returning_count()
159 &self.raw_connection, in prepare_query()
170 let query = Statement::prepare(&self.raw_connection, query, None, &[])?; in execute_inner()
171 query.execute(&self.raw_connection, &Vec::new()) in execute_inner()
177 self.raw_connection in set_config_options()
|
| /dports/net-im/purple-discord/purple-discord-6c5a778/purple2compat/ |
| H A D | purple-socket.c | 53 PurpleProxyConnectData *raw_connection; member
178 ps->raw_connection = NULL; in _purple_socket_connected_raw()
273 ps->raw_connection = purple_proxy_connect(ps->gc, account, in purple_socket_connect()
278 ps->raw_connection == NULL) in purple_socket_connect()
383 if (ps->raw_connection != NULL) in purple_socket_cancel()
384 purple_proxy_connect_cancel(ps->raw_connection); in purple_socket_cancel()
385 ps->raw_connection = NULL; in purple_socket_cancel()
|
| /dports/net-im/purple-facebook/purple-facebook-0.9.6/pidgin/libpurple/ |
| H A D | purple-socket.c | 48 PurpleProxyConnectData *raw_connection; member
171 ps->raw_connection = NULL; in _purple_socket_connected_raw()
266 ps->raw_connection = purple_proxy_connect(ps->gc, account, in purple_socket_connect()
271 ps->raw_connection == NULL) in purple_socket_connect()
376 if (ps->raw_connection != NULL) in purple_socket_cancel()
377 purple_proxy_connect_cancel(ps->raw_connection); in purple_socket_cancel()
378 ps->raw_connection = NULL; in purple_socket_cancel()
|
| /dports/net-im/purple-mattermost/purple-mattermost-2.0/purple2compat/ |
| H A D | purple-socket.c | 53 PurpleProxyConnectData *raw_connection; member
176 ps->raw_connection = NULL; in _purple_socket_connected_raw()
271 ps->raw_connection = purple_proxy_connect(ps->gc, account, in purple_socket_connect()
276 ps->raw_connection == NULL) in purple_socket_connect()
381 if (ps->raw_connection != NULL) in purple_socket_cancel()
382 purple_proxy_connect_cancel(ps->raw_connection); in purple_socket_cancel()
383 ps->raw_connection = NULL; in purple_socket_cancel()
|
| /dports/net-im/purple-googlechat/purple-googlechat-56ba7f7/purple2compat/ |
| H A D | purple-socket.c | 53 PurpleProxyConnectData *raw_connection; member
178 ps->raw_connection = NULL; in _purple_socket_connected_raw()
273 ps->raw_connection = purple_proxy_connect(ps->gc, account, in purple_socket_connect()
278 ps->raw_connection == NULL) in purple_socket_connect()
383 if (ps->raw_connection != NULL) in purple_socket_cancel()
384 purple_proxy_connect_cancel(ps->raw_connection); in purple_socket_cancel()
385 ps->raw_connection = NULL; in purple_socket_cancel()
|
| /dports/net-im/pidgin-icyque/icyque-4fc08a0/purple2compat/ |
| H A D | purple-socket.c | 53 PurpleProxyConnectData *raw_connection; member
178 ps->raw_connection = NULL; in _purple_socket_connected_raw()
273 ps->raw_connection = purple_proxy_connect(ps->gc, account, in purple_socket_connect()
278 ps->raw_connection == NULL) in purple_socket_connect()
383 if (ps->raw_connection != NULL) in purple_socket_cancel()
384 purple_proxy_connect_cancel(ps->raw_connection); in purple_socket_cancel()
385 ps->raw_connection = NULL; in purple_socket_cancel()
|
| /dports/net-im/pidgin-skypeweb/skype4pidgin-1.7/skypeweb/purple2compat/ |
| H A D | purple-socket.c | 53 PurpleProxyConnectData *raw_connection; member
178 ps->raw_connection = NULL; in _purple_socket_connected_raw()
273 ps->raw_connection = purple_proxy_connect(ps->gc, account, in purple_socket_connect()
278 ps->raw_connection == NULL) in purple_socket_connect()
383 if (ps->raw_connection != NULL) in purple_socket_cancel()
384 purple_proxy_connect_cancel(ps->raw_connection); in purple_socket_cancel()
385 ps->raw_connection = NULL; in purple_socket_cancel()
|
| /dports/net-im/purple-hangouts/purple-hangouts-55b9f01/purple2compat/ |
| H A D | purple-socket.c | 53 PurpleProxyConnectData *raw_connection; member
178 ps->raw_connection = NULL; in _purple_socket_connected_raw()
273 ps->raw_connection = purple_proxy_connect(ps->gc, account, in purple_socket_connect()
278 ps->raw_connection == NULL) in purple_socket_connect()
383 if (ps->raw_connection != NULL) in purple_socket_cancel()
384 purple_proxy_connect_cancel(ps->raw_connection); in purple_socket_cancel()
385 ps->raw_connection = NULL; in purple_socket_cancel()
|
| /dports/databases/postgresql-libpqxx/libpqxx-7.2.0/include/pqxx/internal/gates/ |
| H A D | connection-largeobject.hxx | 20 pq::PGconn *raw_connection() const { return home().raw_connection(); } in raw_connection() function in pqxx::internal::gate::connection_largeobject
|
| /dports/net-im/tdlib/td-a53cb30e99f937cfd64e0266fa558785a184a553/td/telegram/net/ |
| H A D | Session.cpp | 112 auto raw_connection = r_raw_connection.move_as_ok(); in on_connection() local
113 VLOG(dc) << "Receive raw connection " << raw_connection.get(); in on_connection()
114 network_generation_ = raw_connection->extra().extra; in on_connection()
506 auto raw_connection = current_info_->connection_->move_as_raw_connection(); in on_closed() local
508 raw_connection->close(); in on_closed()
1081 VLOG(dc) << "Cache connection " << raw_connection.get(); in connection_add()
1082 cached_connection_ = std::move(raw_connection); in connection_add()
1110 auto raw_connection = r_raw_connection.move_as_ok(); in connection_open_finish() local
1111 VLOG(dc) << "Receive raw connection " << raw_connection.get(); in connection_open_finish()
1112 if (raw_connection->extra().extra != network_generation_) { in connection_open_finish()
[all …]
|