| /external/webrtc/p2p/base/ |
| D | basic_ice_controller.h | 32 void SetSelectedConnection(const Connection* selected_connection) override;
33 void AddConnection(const Connection* connection) override;
34 void OnConnectionDestroyed(const Connection* connection) override;
35 rtc::ArrayView<const Connection*> connections() const override { in connections()
36 return rtc::ArrayView<const Connection*>( in connections()
37 const_cast<const Connection**>(connections_.data()), in connections()
45 bool GetUseCandidateAttr(const Connection* conn,
50 const Connection* connection) override;
53 std::vector<const Connection*> PruneConnections() override;
56 const Connection* FindNextPingableConnection() override;
[all …]
|
| D | basic_ice_controller.cc | 18 bool IsRelayRelay(const cricket::Connection* conn) { in IsRelayRelay()
23 bool IsUdp(const cricket::Connection* conn) { in IsUdp()
34 const cricket::Connection* conn, in LocalCandidateUsesPreferredNetwork()
41 const cricket::Connection* a, in CompareCandidatePairsByNetworkPreference()
42 const cricket::Connection* b, in CompareCandidatePairsByNetworkPreference()
73 const Connection* selected_connection) { in SetSelectedConnection()
77 void BasicIceController::AddConnection(const Connection* connection) { in AddConnection()
82 void BasicIceController::OnConnectionDestroyed(const Connection* connection) { in OnConnectionDestroyed()
90 return absl::c_any_of(connections_, [this, now](const Connection* c) { in HasPingableConnection()
101 absl::c_any_of(connections_, [](const Connection* conn) { in SelectConnectionToPing()
[all …]
|
| D | ice_controller_interface.h | 78 absl::optional<const Connection*> connection;
84 std::vector<const Connection*> connections_to_forget_state_on;
89 PingResult(const Connection* conn, int _recheck_delay_ms) in PingResult()
93 const absl::optional<const Connection*> connection;
109 virtual void SetSelectedConnection(const Connection* selected_connection) = 0;
110 virtual void AddConnection(const Connection* connection) = 0;
111 virtual void OnConnectionDestroyed(const Connection* connection) = 0;
114 virtual rtc::ArrayView<const Connection*> connections() const = 0;
125 virtual bool GetUseCandidateAttr(const Connection* conn,
131 virtual const Connection* FindNextPingableConnection() = 0;
[all …]
|
| D | connection.cc | 42 const std::vector<cricket::Connection::SentPing>& pings_since_last_response, in TooManyFailures()
59 const std::vector<cricket::Connection::SentPing>& pings_since_last_response, in TooLongWithoutResponse()
166 ConnectionRequest::ConnectionRequest(Connection* connection) in ConnectionRequest()
282 Connection::Connection(Port* port, in Connection() function in cricket::Connection
311 requests_.SignalSendPacket.connect(this, &Connection::OnSendStunPacket); in Connection()
315 Connection::~Connection() {} in ~Connection()
317 const Candidate& Connection::local_candidate() const { in local_candidate()
322 const Candidate& Connection::remote_candidate() const { in remote_candidate()
326 const rtc::Network* Connection::network() const { in network()
330 int Connection::generation() const { in generation()
[all …]
|
| D | p2p_transport_channel.h | 141 const Connection* selected_connection() const override;
146 const Connection* best_connection() const { in best_connection()
180 Connection* FindNextPingableConnection();
181 void MarkConnectionPinged(Connection* conn);
184 rtc::ArrayView<Connection*> connections() const;
220 bool ReadyToSend(Connection* connection) const;
221 bool PresumedWritable(const Connection* conn) const;
231 void SwitchSelectedConnection(Connection* conn, IceControllerEvent reason);
248 bool FindConnection(const Connection* connection) const;
254 void PingConnection(Connection* conn);
[all …]
|
| D | connection.h | 44 class Connection; variable
59 explicit ConnectionRequest(Connection* connection);
68 Connection* connection_;
73 class Connection : public CandidatePairInterface,
86 ~Connection() override;
145 sigslot::signal1<Connection*> SignalStateChange;
149 sigslot::signal1<Connection*> SignalDestroyed;
161 sigslot::signal4<Connection*, const char*, size_t, int64_t> SignalReadPacket;
163 sigslot::signal1<Connection*> SignalReadyToSend;
264 sigslot::signal1<Connection*> SignalNominated;
[all …]
|
| /external/libbrillo/brillo/http/ |
| D | http_connection_curl.cc | 55 Connection::Connection(CURL* curl_handle, in Connection() function in brillo::http::curl::Connection
59 : http::Connection(transport), in Connection()
69 Connection::~Connection() { in ~Connection()
76 bool Connection::SendHeaders(const HeaderList& headers, in SendHeaders()
82 bool Connection::SetRequestData(StreamPtr stream, in SetRequestData()
88 void Connection::SetResponseData(StreamPtr stream) { in SetResponseData()
92 void Connection::PrepareRequest() { in PrepareRequest()
121 curl_handle_, CURLOPT_READFUNCTION, &Connection::read_callback); in PrepareRequest()
145 curl_handle_, CURLOPT_WRITEFUNCTION, &Connection::write_callback); in PrepareRequest()
151 curl_handle_, CURLOPT_HEADERFUNCTION, &Connection::header_callback); in PrepareRequest()
[all …]
|
| D | http_connection_fake.cc | 18 Connection::Connection(const std::string& url, in Connection() function in brillo::http::fake::Connection
21 : http::Connection(transport), request_(url, method) { in Connection()
25 Connection::~Connection() { in ~Connection()
29 bool Connection::SendHeaders(const HeaderList& headers, in SendHeaders()
35 bool Connection::SetRequestData(StreamPtr stream, in SetRequestData()
41 bool Connection::FinishRequest(brillo::ErrorPtr* /* error */) { in FinishRequest()
60 RequestID Connection::FinishRequestAsync( in FinishRequestAsync()
65 auto connection = std::static_pointer_cast<Connection>(shared_from_this()); in FinishRequestAsync()
66 auto callback = [](std::shared_ptr<Connection> connection, in FinishRequestAsync()
79 void Connection::FinishRequestAsyncHelper( in FinishRequestAsyncHelper()
[all …]
|
| D | http_connection.h | 43 class BRILLO_EXPORT Connection
44 : public std::enable_shared_from_this<Connection> {
46 explicit Connection(const std::shared_ptr<Transport>& transport) in Connection() function
48 virtual ~Connection() = default;
102 DISALLOW_COPY_AND_ASSIGN(Connection);
|
| D | http_connection_fake.h | 23 class Connection : public http::Connection {
25 Connection(const std::string& url,
28 ~Connection() override;
57 DISALLOW_COPY_AND_ASSIGN(Connection);
|
| D | http_transport_curl.h | 23 class Connection; variable
45 std::shared_ptr<http::Connection> CreateConnection(
56 RequestID StartAsyncTransfer(http::Connection* connection,
104 void OnTransferComplete(http::curl::Connection* connection,
109 void CleanAsyncConnection(http::curl::Connection* connection);
134 std::map<RequestID, Connection*> request_id_map_;
138 std::map<Connection*, std::unique_ptr<AsyncRequestData>> async_requests_;
|
| /external/openscreen/osp/impl/presentation/ |
| D | presentation_connection.cc | 36 Connection::Connection(const PresentationInfo& info, in Connection() function in openscreen::osp::Connection
46 Connection::~Connection() { in ~Connection()
54 void Connection::OnConnecting() { in OnConnecting()
59 void Connection::OnConnected( in OnConnected()
73 bool Connection::OnClosed() { in OnClosed()
83 void Connection::OnClosedByError(Error cause) { in OnClosedByError()
91 void Connection::OnClosedByRemote() { in OnClosedByRemote()
96 void Connection::OnTerminated() { in OnTerminated()
104 Error Connection::SendString(absl::string_view message) { in SendString()
120 Error Connection::SendBinary(std::vector<uint8_t>&& data) { in SendBinary()
[all …]
|
| D | presentation_connection_unittest.cc | 30 class MockParentDelegate : public Connection::ParentDelegate {
35 MOCK_METHOD2(CloseConnection, Error(Connection*, Connection::CloseReason));
38 MOCK_METHOD1(OnConnectionDestroyed, void(Connection*));
106 Connection controller(Connection::PresentationInfo{id, url}, in TEST_F()
108 Connection receiver(Connection::PresentationInfo{id, url}, in TEST_F()
118 [&receiver](Connection* connection, Connection::CloseReason reason) { in TEST_F()
129 .WillByDefault(Invoke([&controller](Connection* connection, in TEST_F()
130 Connection::CloseReason reason) { in TEST_F()
140 EXPECT_EQ(Connection::State::kConnecting, controller.state()); in TEST_F()
141 EXPECT_EQ(Connection::State::kConnecting, receiver.state()); in TEST_F()
[all …]
|
| /external/rust/crates/quiche/src/h3/ |
| D | ffi.rs | 79 quic_conn: &mut Connection, config: &mut h3::Config, in quiche_h3_conn_new_with_transport() argument
80 ) -> *mut h3::Connection { in quiche_h3_conn_new_with_transport() argument
81 match h3::Connection::with_transport(quic_conn, config) { in quiche_h3_conn_new_with_transport()
90 conn: &mut h3::Connection, quic_conn: &mut Connection, in quiche_h3_conn_poll() argument
182 conn: &mut h3::Connection, quic_conn: &mut Connection, in quiche_h3_send_request() argument
196 conn: &mut h3::Connection, quic_conn: &mut Connection, stream_id: u64, in quiche_h3_send_response() argument
210 conn: &mut h3::Connection, quic_conn: &mut Connection, stream_id: u64, in quiche_h3_send_response_with_priority() argument
232 conn: &mut h3::Connection, quic_conn: &mut Connection, stream_id: u64, in quiche_h3_send_body() argument
250 conn: &mut h3::Connection, quic_conn: &mut Connection, stream_id: u64, in quiche_h3_recv_body() argument
268 conn: &mut h3::Connection, quic_conn: &mut Connection, flow_id: u64, in quiche_h3_send_dgram() argument
[all …]
|
| /external/llvm-project/lldb/include/lldb/Utility/ |
| D | Connection.h | 41 class Connection {
44 Connection() = default;
48 virtual ~Connection();
178 Connection(const Connection &) = delete;
179 const Connection &operator=(const Connection &) = delete;
|
| /external/rust/crates/rusqlite/src/ |
| D | transaction.rs | 1 use crate::{Connection, Result};
63 conn: &'conn Connection,
91 conn: &'conn Connection,
105 pub fn new(conn: &mut Connection, behavior: TransactionBehavior) -> Result<Transaction<'_>> { in new() argument
115 conn: &Connection, in new_unchecked() argument
220 type Target = Connection;
222 fn deref(&self) -> &Connection { in deref() argument
236 conn: &Connection, in with_depth_and_name() argument
251 fn with_depth(conn: &Connection, depth: u32) -> Result<Savepoint<'_>> { in with_depth() argument
257 pub fn new(conn: &mut Connection) -> Result<Savepoint<'_>> { in new()
[all …]
|
| D | backup.rs | 43 use crate::{Connection, DatabaseName, Result};
45 impl Connection { impl
67 let mut dst = Connection::open(dst_path)?; in backup()
105 let src = Connection::open(src_path)?; in restore()
168 phantom_from: PhantomData<&'a Connection>,
169 phantom_to: PhantomData<&'b Connection>,
183 pub fn new<'a, 'b>(from: &'a Connection, to: &'b mut Connection) -> Result<Backup<'a, 'b>> { in new() argument
197 from: &'a Connection, in new_with_names() argument
199 to: &'b mut Connection, in new_with_names() argument
309 use crate::{Connection, DatabaseName, NO_PARAMS};
[all …]
|
| D | collation.rs | 9 use crate::{str_to_cstring, Connection, InnerConnection, Result};
16 impl Connection { implementation
30 x_coll_needed: fn(&Connection, &str) -> Result<()>, in collation_needed() argument
101 x_coll_needed: fn(&Connection, &str) -> Result<()>, in collation_needed() argument
118 let callback: fn(&Connection, &str) -> Result<()> = mem::transmute(arg1); in collation_needed()
120 let conn = Connection::from_handle(arg2).unwrap(); in collation_needed()
160 use crate::{Connection, Result, NO_PARAMS};
171 let db = Connection::open_in_memory().unwrap(); in test_unicase()
178 fn collate(db: Connection) { in collate() argument
192 fn collation_needed(db: &Connection, collation_name: &str) -> Result<()> { in collation_needed() argument
[all …]
|
| D | busy.rs | 10 use crate::{Connection, InnerConnection, Result};
12 impl Connection { implementation
85 use crate::{Connection, Error, ErrorCode, Result, TransactionBehavior, NO_PARAMS};
92 let mut db1 = Connection::open(&path).unwrap(); in test_default_busy()
96 let db2 = Connection::open(&path).unwrap(); in test_default_busy()
113 let db2 = Connection::open(&path).unwrap(); in test_busy_timeout()
118 let mut db1 = Connection::open(&path).unwrap(); in test_busy_timeout()
152 let db2 = Connection::open(&path).unwrap(); in test_busy_handler()
157 let mut db1 = Connection::open(&path).unwrap(); in test_busy_handler()
|
| /external/openscreen/osp/public/presentation/ |
| D | presentation_connection.h | 40 class Connection {
101 virtual Error CloseConnection(Connection* connection,
105 virtual void OnConnectionDestroyed(Connection* connection) = 0;
117 Connection(const PresentationInfo& info,
120 ~Connection();
183 OSP_DISALLOW_COPY_AND_ASSIGN(Connection);
190 void AddConnection(Connection* connection);
191 void RemoveConnection(Connection* connection);
201 Connection* GetConnection(uint64_t connection_id);
207 std::map<uint64_t, Connection*> connections_;
|
| D | presentation_controller.h | 29 virtual void OnConnection(std::unique_ptr<Connection> connection) = 0;
53 public Connection::ParentDelegate {
117 Connection::Delegate* conn_delegate);
128 Connection::Delegate* conn_delegate);
134 ConnectRequest ReconnectConnection(std::unique_ptr<Connection> connection,
138 Error CloseConnection(Connection* connection,
139 Connection::CloseReason reason) override;
146 void OnConnectionDestroyed(Connection* connection) override;
167 std::vector<Connection*> connections;
173 void AddConnection(Connection* connection);
[all …]
|
| D | presentation_receiver.h | 46 const Connection::PresentationInfo& info,
62 public Connection::ParentDelegate {
78 Connection* connection,
82 Connection* connection,
86 Error CloseConnection(Connection* connection,
87 Connection::CloseReason reason) override;
92 void OnConnectionDestroyed(Connection* connection) override;
116 std::vector<Connection*> connections;
|
| /external/rust/crates/quiche/src/ |
| D | ffi.rs | 329 ) -> *mut Connection { in quiche_accept() argument
349 ) -> *mut Connection { in quiche_connect() argument
409 ) -> *mut Connection { in quiche_conn_new_with_tls() argument
420 match Connection::with_tls(scid, odcid, config, tls, is_server) { in quiche_conn_new_with_tls()
429 conn: &mut Connection, path: *const c_char, in quiche_conn_set_keylog_path() argument
451 pub extern fn quiche_conn_set_keylog_fd(conn: &mut Connection, fd: c_int) { in quiche_conn_set_keylog_fd() argument
461 conn: &mut Connection, path: *const c_char, log_title: *const c_char, in quiche_conn_set_qlog_path() argument
492 conn: &mut Connection, fd: c_int, log_title: *const c_char, in quiche_conn_set_qlog_fd() argument
510 conn: &mut Connection, buf: *mut u8, buf_len: size_t, in quiche_conn_recv() argument
527 conn: &mut Connection, out: *mut u8, out_len: size_t, in quiche_conn_send() argument
[all …]
|
| /external/python/pyopenssl/tests/ |
| D | test_ssl.py | 89 from OpenSSL.SSL import Context, Session, Connection, SSLeay_version
298 client = Connection(Context(version), socket)
307 server = Connection(ctx, socket)
494 conn = Connection(context, None)
979 clientSSL = Connection(Context(SSLv23_METHOD), client)
992 serverSSL = Connection(context, server)
1005 if not isinstance(conn, Connection)
1039 assert all(isinstance(conn, Connection) for conn, line in called)
1059 clientSSL = Connection(clientContext, client)
1070 serverSSL = Connection(serverContext, server)
[all …]
|
| /external/curl/tests/data/ |
| D | test1141 | 14 Connection: close
21 Connection: close
28 Connection: close
32 Connection: close
62 Proxy-Connection: Keep-Alive
68 Proxy-Connection: Keep-Alive
|