| /dports/net-p2p/vuze/vuze-5.7.4.0_2/com/aelitis/azureus/core/networkmanager/impl/tcp/ |
| H A D | TCPConnectionManager.java | 156 new TreeSet<ConnectionRequest>(
157 new Comparator<ConnectionRequest>()
161 ConnectionRequest r1,
162 ConnectionRequest r2 )
218 …private final Map<ConnectionRequest,Object> pending_attempts = new HashMap<ConnectionRequest, Obje…
299 ConnectionRequest cr = null; in addNewOutboundRequests()
328 final ConnectionRequest request ) in addNewRequest()
543 ConnectionRequest request ) in finishConnect()
748 ConnectionRequest cr =null; in runSelect()
886 ConnectionRequest request =(ConnectionRequest) pen_it.next(); in requestNewConnection()
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/webrtc/p2p/base/ |
| H A D | connection.h | 57 class ConnectionRequest : public StunRequest {
59 explicit ConnectionRequest(Connection* connection);
346 virtual void OnConnectionRequestResponse(ConnectionRequest* req,
348 void OnConnectionRequestErrorResponse(ConnectionRequest* req,
350 void OnConnectionRequestTimeout(ConnectionRequest* req);
351 void OnConnectionRequestSent(ConnectionRequest* req);
385 void MaybeUpdateLocalCandidate(ConnectionRequest* request,
463 friend class ConnectionRequest; variable
|
| H A D | connection.cc | 166 ConnectionRequest::ConnectionRequest(Connection* connection) in ConnectionRequest() function in cricket::ConnectionRequest
169 void ConnectionRequest::Prepare(StunMessage* request) { in Prepare()
259 void ConnectionRequest::OnResponse(StunMessage* response) { in OnResponse()
263 void ConnectionRequest::OnErrorResponse(StunMessage* response) { in OnErrorResponse()
267 void ConnectionRequest::OnTimeout() { in OnTimeout()
271 void ConnectionRequest::OnSent() { in OnSent()
278 int ConnectionRequest::resend_delay() { in resend_delay()
843 ConnectionRequest* req = new ConnectionRequest(this); in Ping()
1052 void Connection::OnConnectionRequestResponse(ConnectionRequest* request, in OnConnectionRequestResponse()
1145 void Connection::OnConnectionRequestSent(ConnectionRequest* request) { in OnConnectionRequestSent()
[all …]
|
| /dports/net-im/tg_owt/tg_owt-d578c76/src/p2p/base/ |
| H A D | connection.h | 57 class ConnectionRequest : public StunRequest {
59 explicit ConnectionRequest(Connection* connection);
348 virtual void OnConnectionRequestResponse(ConnectionRequest* req,
350 void OnConnectionRequestErrorResponse(ConnectionRequest* req,
352 void OnConnectionRequestTimeout(ConnectionRequest* req);
353 void OnConnectionRequestSent(ConnectionRequest* req);
388 void MaybeUpdateLocalCandidate(ConnectionRequest* request,
466 friend class ConnectionRequest; variable
|
| H A D | connection.cc | 166 ConnectionRequest::ConnectionRequest(Connection* connection) in ConnectionRequest() function in cricket::ConnectionRequest
169 void ConnectionRequest::Prepare(StunMessage* request) { in Prepare()
259 void ConnectionRequest::OnResponse(StunMessage* response) { in OnResponse()
263 void ConnectionRequest::OnErrorResponse(StunMessage* response) { in OnErrorResponse()
267 void ConnectionRequest::OnTimeout() { in OnTimeout()
271 void ConnectionRequest::OnSent() { in OnSent()
278 int ConnectionRequest::resend_delay() { in resend_delay()
843 ConnectionRequest* req = new ConnectionRequest(this); in Ping()
1071 void Connection::OnConnectionRequestResponse(ConnectionRequest* request, in OnConnectionRequestResponse()
1164 void Connection::OnConnectionRequestSent(ConnectionRequest* request) { in OnConnectionRequestSent()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/webrtc/p2p/base/ |
| H A D | connection.h | 57 class ConnectionRequest : public StunRequest {
59 explicit ConnectionRequest(Connection* connection);
346 virtual void OnConnectionRequestResponse(ConnectionRequest* req,
348 void OnConnectionRequestErrorResponse(ConnectionRequest* req,
350 void OnConnectionRequestTimeout(ConnectionRequest* req);
351 void OnConnectionRequestSent(ConnectionRequest* req);
385 void MaybeUpdateLocalCandidate(ConnectionRequest* request,
463 friend class ConnectionRequest; variable
|
| H A D | connection.cc | 166 ConnectionRequest::ConnectionRequest(Connection* connection) in ConnectionRequest() function in cricket::ConnectionRequest
169 void ConnectionRequest::Prepare(StunMessage* request) { in Prepare()
259 void ConnectionRequest::OnResponse(StunMessage* response) { in OnResponse()
263 void ConnectionRequest::OnErrorResponse(StunMessage* response) { in OnErrorResponse()
267 void ConnectionRequest::OnTimeout() { in OnTimeout()
271 void ConnectionRequest::OnSent() { in OnSent()
278 int ConnectionRequest::resend_delay() { in resend_delay()
844 ConnectionRequest* req = new ConnectionRequest(this); in Ping()
1072 void Connection::OnConnectionRequestResponse(ConnectionRequest* request, in OnConnectionRequestResponse()
1165 void Connection::OnConnectionRequestSent(ConnectionRequest* request) { in OnConnectionRequestSent()
[all …]
|
| /dports/databases/libcouchbase/libcouchbase-2.10.7/src/lcbio/ |
| H A D | ioutils.h | 126 class ConnectionRequest {
129 virtual ~ConnectionRequest() {} in ~ConnectionRequest()
130 static void cancel(ConnectionRequest **pp) { in cancel()
|
| H A D | connect.h | 30 class ConnectionRequest; variable
33 typedef lcb::io::ConnectionRequest* lcbio_pCONNSTART;
34 typedef lcb::io::ConnectionRequest lcbio_MGRREQ;
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/device/bluetooth/bluez/ |
| H A D | bluetooth_socket_bluez.h | 173 struct ConnectionRequest { struct
174 ConnectionRequest();
175 ~ConnectionRequest();
184 base::queue<std::unique_ptr<ConnectionRequest>> connection_request_queue_; argument
|
| H A D | bluetooth_socket_bluez.cc | 72 BluetoothSocketBlueZ::ConnectionRequest::ConnectionRequest() in ConnectionRequest() function in bluez::BluetoothSocketBlueZ::ConnectionRequest
75 BluetoothSocketBlueZ::ConnectionRequest::~ConnectionRequest() = default;
378 auto request = std::make_unique<ConnectionRequest>(); in NewConnection()
413 ConnectionRequest* request = connection_request_queue_.front().get(); in Cancel()
430 ConnectionRequest* request = connection_request_queue_.front().get(); in AcceptConnectionRequest()
504 std::unique_ptr<ConnectionRequest> request = in OnNewConnection()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/device/bluetooth/bluez/ |
| H A D | bluetooth_socket_bluez.h | 173 struct ConnectionRequest { struct
174 ConnectionRequest();
175 ~ConnectionRequest();
184 base::queue<std::unique_ptr<ConnectionRequest>> connection_request_queue_; argument
|
| H A D | bluetooth_socket_bluez.cc | 72 BluetoothSocketBlueZ::ConnectionRequest::ConnectionRequest() in ConnectionRequest() function in bluez::BluetoothSocketBlueZ::ConnectionRequest
75 BluetoothSocketBlueZ::ConnectionRequest::~ConnectionRequest() = default;
369 auto request = std::make_unique<ConnectionRequest>(); in NewConnection()
404 ConnectionRequest* request = connection_request_queue_.front().get(); in Cancel()
421 ConnectionRequest* request = connection_request_queue_.front().get(); in AcceptConnectionRequest()
495 std::unique_ptr<ConnectionRequest> request = in OnNewConnection()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/content/browser/indexed_db/ |
| H A D | indexed_db_connection_coordinator.cc | 56 class IndexedDBConnectionCoordinator::ConnectionRequest { class in content::IndexedDBConnectionCoordinator
58 ConnectionRequest(IndexedDBOriginStateHandle origin_state_handle, in ConnectionRequest() function in content::IndexedDBConnectionCoordinator::ConnectionRequest
67 virtual ~ConnectionRequest() {} in ~ConnectionRequest()
121 DISALLOW_COPY_AND_ASSIGN(ConnectionRequest);
125 : public IndexedDBConnectionCoordinator::ConnectionRequest {
132 : ConnectionRequest(std::move(origin_state_handle), in OpenRequest()
388 : public IndexedDBConnectionCoordinator::ConnectionRequest {
396 : ConnectionRequest(std::move(origin_state_handle), in DeleteRequest()
548 base::queue<std::unique_ptr<ConnectionRequest>> requests_to_still_run; in PruneTasksForForceClose()
551 std::unique_ptr<ConnectionRequest> request = in PruneTasksForForceClose()
|
| H A D | indexed_db_connection_coordinator.h | 95 class ConnectionRequest; variable
103 base::queue<std::unique_ptr<ConnectionRequest>> request_queue_;
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/content/browser/indexed_db/ |
| H A D | indexed_db_connection_coordinator.cc | 56 class IndexedDBConnectionCoordinator::ConnectionRequest { class in content::IndexedDBConnectionCoordinator
58 ConnectionRequest(IndexedDBOriginStateHandle origin_state_handle, in ConnectionRequest() function in content::IndexedDBConnectionCoordinator::ConnectionRequest
67 virtual ~ConnectionRequest() {} in ~ConnectionRequest()
121 DISALLOW_COPY_AND_ASSIGN(ConnectionRequest);
125 : public IndexedDBConnectionCoordinator::ConnectionRequest {
132 : ConnectionRequest(std::move(origin_state_handle), in OpenRequest()
388 : public IndexedDBConnectionCoordinator::ConnectionRequest {
396 : ConnectionRequest(std::move(origin_state_handle), in DeleteRequest()
548 base::queue<std::unique_ptr<ConnectionRequest>> requests_to_still_run; in PruneTasksForForceClose()
551 std::unique_ptr<ConnectionRequest> request = in PruneTasksForForceClose()
|
| H A D | indexed_db_connection_coordinator.h | 95 class ConnectionRequest; variable
103 base::queue<std::unique_ptr<ConnectionRequest>> request_queue_;
|
| /dports/net-im/kopete/kopete-21.12.3/protocols/jabber/libjingle/talk/p2p/base/ |
| H A D | port.h | 53 class ConnectionRequest; variable
377 void OnConnectionRequestResponse(ConnectionRequest* req,
379 void OnConnectionRequestErrorResponse(ConnectionRequest* req,
381 void OnConnectionRequestTimeout(ConnectionRequest* req);
415 friend class ConnectionRequest; variable
|
| H A D | port.cc | 488 class ConnectionRequest : public StunRequest { class
490 explicit ConnectionRequest(Connection* connection) : connection_(connection) { in ConnectionRequest() function in cricket::ConnectionRequest
493 virtual ~ConnectionRequest() { in ~ConnectionRequest()
763 ConnectionRequest *req = new ConnectionRequest(this); in Ping()
809 void Connection::OnConnectionRequestResponse(ConnectionRequest* request, in OnConnectionRequestResponse()
835 void Connection::OnConnectionRequestErrorResponse(ConnectionRequest* request, in OnConnectionRequestErrorResponse()
855 void Connection::OnConnectionRequestTimeout(ConnectionRequest* request) { in OnConnectionRequestTimeout()
|
| /dports/lang/spidermonkey60/firefox-60.9.0/media/webrtc/trunk/webrtc/p2p/base/ |
| H A D | port.h | 39 class ConnectionRequest; variable
622 virtual void OnConnectionRequestResponse(ConnectionRequest* req,
624 void OnConnectionRequestErrorResponse(ConnectionRequest* req,
626 void OnConnectionRequestTimeout(ConnectionRequest* req);
627 void OnConnectionRequestSent(ConnectionRequest* req);
656 void MaybeUpdateLocalCandidate(ConnectionRequest* request,
701 friend class ConnectionRequest; variable
|
| H A D | port.cc | 746 class ConnectionRequest : public StunRequest { class
748 explicit ConnectionRequest(Connection* connection) in ConnectionRequest() function in cricket::ConnectionRequest
753 virtual ~ConnectionRequest() { in ~ConnectionRequest()
1221 ConnectionRequest *req = new ConnectionRequest(this); in Ping()
1349 void Connection::OnConnectionRequestResponse(ConnectionRequest* request, in OnConnectionRequestResponse()
1373 void Connection::OnConnectionRequestErrorResponse(ConnectionRequest* request, in OnConnectionRequestErrorResponse()
1402 void Connection::OnConnectionRequestTimeout(ConnectionRequest* request) { in OnConnectionRequestTimeout()
1410 void Connection::OnConnectionRequestSent(ConnectionRequest* request) { in OnConnectionRequestSent()
1488 void Connection::MaybeUpdateLocalCandidate(ConnectionRequest* request, in MaybeUpdateLocalCandidate()
|
| /dports/www/firefox-legacy/firefox-52.8.0esr/media/webrtc/trunk/webrtc/p2p/base/ |
| H A D | port.h | 36 class ConnectionRequest; variable
556 void OnConnectionRequestResponse(ConnectionRequest* req,
558 void OnConnectionRequestErrorResponse(ConnectionRequest* req,
560 void OnConnectionRequestTimeout(ConnectionRequest* req);
601 void MaybeAddPrflxCandidate(ConnectionRequest* request,
608 friend class ConnectionRequest; variable
|
| H A D | port.cc | 763 class ConnectionRequest : public StunRequest { class
765 explicit ConnectionRequest(Connection* connection) in ConnectionRequest() function in cricket::ConnectionRequest
770 virtual ~ConnectionRequest() { in ~ConnectionRequest()
1184 ConnectionRequest *req = new ConnectionRequest(this); in Ping()
1253 void Connection::OnConnectionRequestResponse(ConnectionRequest* request, in OnConnectionRequestResponse()
1296 void Connection::OnConnectionRequestErrorResponse(ConnectionRequest* request, in OnConnectionRequestErrorResponse()
1327 void Connection::OnConnectionRequestTimeout(ConnectionRequest* request) { in OnConnectionRequestTimeout()
1405 void Connection::MaybeAddPrflxCandidate(ConnectionRequest* request, in MaybeAddPrflxCandidate()
|
| /dports/lang/spidermonkey60/firefox-60.9.0/mobile/android/thirdparty/ch/boye/httpclientandroidlib/impl/conn/ |
| H A D | BasicHttpClientConnectionManager.java | 48 import ch.boye.httpclientandroidlib.conn.ConnectionRequest;
187 public final ConnectionRequest requestConnection( in requestConnection()
191 return new ConnectionRequest() { in requestConnection()
|
| /dports/www/firefox-legacy/firefox-52.8.0esr/mobile/android/thirdparty/ch/boye/httpclientandroidlib/impl/conn/ |
| H A D | BasicHttpClientConnectionManager.java | 48 import ch.boye.httpclientandroidlib.conn.ConnectionRequest;
187 public final ConnectionRequest requestConnection( in requestConnection()
191 return new ConnectionRequest() { in requestConnection()
|