| /external/libbrillo/brillo/http/ |
| D | http_connection_curl.cc | 53 Connection::Connection(CURL* curl_handle, in Connection() function in brillo::http::curl::Connection
57 : http::Connection(transport), in Connection()
67 Connection::~Connection() { in ~Connection()
74 bool Connection::SendHeaders(const HeaderList& headers, in SendHeaders()
80 bool Connection::SetRequestData(StreamPtr stream, in SetRequestData()
86 void Connection::SetResponseData(StreamPtr stream) { in SetResponseData()
90 void Connection::PrepareRequest() { in PrepareRequest()
119 curl_handle_, CURLOPT_READFUNCTION, &Connection::read_callback); in PrepareRequest()
143 curl_handle_, CURLOPT_WRITEFUNCTION, &Connection::write_callback); in PrepareRequest()
149 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()
73 void Connection::FinishRequestAsyncHelper( in FinishRequestAsyncHelper()
85 int Connection::GetResponseStatusCode() const { in GetResponseStatusCode()
[all …]
|
| D | http_transport_curl.h | 21 class Connection; variable
43 std::shared_ptr<http::Connection> CreateConnection(
54 RequestID StartAsyncTransfer(http::Connection* connection,
89 void OnTransferComplete(http::curl::Connection* connection,
94 void CleanAsyncConnection(http::curl::Connection* connection);
119 std::map<RequestID, Connection*> request_id_map_;
123 std::map<Connection*, std::unique_ptr<AsyncRequestData>> async_requests_;
|
| 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 | 21 class Connection : public http::Connection {
23 Connection(const std::string& url,
26 ~Connection() override;
55 DISALLOW_COPY_AND_ASSIGN(Connection);
|
| D | http_connection_curl.h | 23 class BRILLO_EXPORT Connection : public http::Connection {
25 Connection(CURL* curl_handle,
29 ~Connection() override;
96 DISALLOW_COPY_AND_ASSIGN(Connection);
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/ |
| D | Internal.java | 20 import com.squareup.okhttp.Connection;
54 public abstract Transport newTransport(Connection connection, HttpEngine httpEngine) in newTransport()
57 public abstract boolean clearOwner(Connection connection); in clearOwner()
59 public abstract void closeIfOwnedBy(Connection connection, Object owner) throws IOException; in closeIfOwnedBy()
61 public abstract int recycleCount(Connection connection); in recycleCount()
63 public abstract void setProtocol(Connection connection, Protocol protocol); in setProtocol()
65 public abstract void setOwner(Connection connection, HttpEngine httpEngine); in setOwner()
67 public abstract boolean isReadable(Connection pooled); in isReadable()
77 public abstract void recycle(ConnectionPool pool, Connection connection); in recycle()
85 public abstract void connectAndSetOwner(OkHttpClient client, Connection connection, in connectAndSetOwner()
[all …]
|
| /external/webrtc/webrtc/base/ |
| D | httpserver.cc | 48 Connection* connection = new Connection(connection_id, this); in HandleConnection()
57 if (Connection* connection = Find(connection_id)) { in Respond()
68 if (Connection* connection = Find(connection_id)) { in Close()
80 std::list<Connection*> connections; in CloseAll()
85 for (std::list<Connection*>::const_iterator it = connections.begin(); in CloseAll()
91 HttpServer::Connection*
106 Connection* connection = it->second; in Remove()
120 HttpServer::Connection::Connection(int connection_id, HttpServer* server) in Connection() function in rtc::HttpServer::Connection
125 HttpServer::Connection::~Connection() { in ~Connection()
132 HttpServer::Connection::BeginProcess(StreamInterface* stream) { in BeginProcess()
[all …]
|
| D | httpserver.h | 80 class Connection : private IHttpNotify {
82 Connection(int connection_id, HttpServer* server);
83 ~Connection() override;
103 Connection* Find(int connection_id);
106 friend class Connection; variable
107 typedef std::map<int,Connection*> ConnectionMap;
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| D | ConnectionPool.java | 78 private final LinkedList<Connection> connections = new LinkedList<>();
124 for (Connection connection : connections) { in getMultiplexedConnectionCount()
136 public synchronized Connection get(Address address) { in get()
137 Connection foundConnection = null; in get()
138 for (ListIterator<Connection> i = connections.listIterator(connections.size()); in get()
140 Connection connection = i.previous(); in get()
174 void recycle(Connection connection) { in recycle()
204 private void addConnection(Connection connection) { in addConnection()
218 void share(Connection connection) { in share()
228 List<Connection> toEvict; in evictAll()
[all …]
|
| D | OkHttpClient.java | 68 Connection connection, HttpEngine httpEngine) throws IOException {
72 @Override public boolean clearOwner(Connection connection) {
76 @Override public void closeIfOwnedBy(Connection connection, Object owner) throws IOException {
80 @Override public int recycleCount(Connection connection) {
84 @Override public void setProtocol(Connection connection, Protocol protocol) {
88 @Override public void setOwner(Connection connection, HttpEngine httpEngine) {
92 @Override public boolean isReadable(Connection pooled) {
112 @Override public void recycle(ConnectionPool pool, Connection connection) {
128 @Override public void connectAndSetOwner(OkHttpClient client, Connection connection,
142 @Override public Connection callEngineGetConnection(Call call) {
[all …]
|
| /external/webrtc/webrtc/p2p/base/ |
| D | p2ptransportchannel.h | 105 const Connection* best_connection() const { return best_connection_; } in best_connection()
171 Connection* FindNextPingableConnection();
174 const std::vector<Connection*>& connections() const { return connections_; } in connections()
196 void SwitchBestConnectionTo(Connection* conn);
202 Connection* GetBestConnectionOnNetwork(rtc::Network* network) const;
208 bool FindConnection(cricket::Connection* connection) const;
214 bool IsPingable(Connection* conn, uint32_t now);
215 void PingConnection(Connection* conn);
217 void AddConnection(Connection* connection);
232 void OnConnectionStateChange(Connection* connection);
[all …]
|
| D | p2ptransportchannel.cc | 43 int CompareConnectionCandidates(cricket::Connection* a, in CompareConnectionCandidates()
44 cricket::Connection* b) { in CompareConnectionCandidates()
58 int CompareConnectionStates(cricket::Connection* a, cricket::Connection* b) { in CompareConnectionStates()
95 if (a->write_state() == cricket::Connection::STATE_WRITABLE && in CompareConnectionStates()
96 b->write_state() == cricket::Connection::STATE_WRITABLE) { in CompareConnectionStates()
107 int CompareConnections(cricket::Connection* a, cricket::Connection* b) { in CompareConnections()
120 bool operator()(const cricket::Connection *ca, in operator ()()
121 const cricket::Connection *cb) { in operator ()()
122 cricket::Connection* a = const_cast<cricket::Connection*>(ca); in operator ()()
123 cricket::Connection* b = const_cast<cricket::Connection*>(cb); in operator ()()
[all …]
|
| D | port.cc | 32 const std::vector<cricket::Connection::SentPing>& pings_since_last_response, in TooManyFailures()
49 const std::vector<cricket::Connection::SentPing>& pings_since_last_response, in TooLongWithoutResponse()
205 std::vector<Connection*> list; in ~Port()
217 Connection* Port::GetConnection(const rtc::SocketAddress& remote_addr) { in GetConnection()
264 void Port::AddConnection(Connection* conn) { in AddConnection()
580 Connection* conn = GetConnection(addr); in SendBindingResponse()
642 void Port::OnConnectionDestroyed(Connection* conn) { in OnConnectionDestroyed()
671 explicit ConnectionRequest(Connection* connection) in ConnectionRequest()
757 Connection* connection_;
764 Connection::Connection(Port* port, in Connection() function in cricket::Connection
[all …]
|
| D | port.h | 35 class Connection; variable
215 typedef std::map<rtc::SocketAddress, Connection*> AddressMap;
219 virtual Connection* GetConnection(
223 sigslot::signal2<Port*, Connection*> SignalConnectionCreated;
320 void AddConnection(Connection* conn);
352 void OnConnectionDestroyed(Connection* conn);
398 friend class Connection; variable
403 class Connection : public rtc::MessageHandler,
422 virtual ~Connection();
469 sigslot::signal1<Connection*> SignalStateChange;
[all …]
|
| D | turnport_unittest.cc | 36 using cricket::Connection;
106 TestConnectionWrapper(Connection* conn) : connection_(conn) { in TestConnectionWrapper()
111 Connection* connection() { return connection_; } in connection()
114 void OnConnectionDestroyed(Connection* conn) { in OnConnectionDestroyed()
119 Connection* connection_;
186 void OnTurnReadPacket(Connection* conn, const char* data, size_t size, in OnTurnReadPacket()
193 void OnUdpReadPacket(Connection* conn, const char* data, size_t size, in OnUdpReadPacket()
197 void OnConnectionDestroyed(Connection* conn) { connection_destroyed_ = true; } in OnConnectionDestroyed()
284 void ConnectConnectionDestroyedSignal(Connection* conn) { in ConnectConnectionDestroyedSignal()
403 Connection* conn1 = udp_port_->CreateConnection( in TestTurnConnection()
[all …]
|
| /external/curl/tests/data/ |
| D | test1314 | 18 Connection: close
27 Connection: close
37 Connection: close
42 Connection: close
70 Proxy-Connection: Keep-Alive
75 Proxy-Connection: Keep-Alive
|
| D | test25 | 17 Connection: close
26 Connection: close
32 Connection: close
38 Connection: close
44 Connection: close
50 Connection: close
56 Connection: close
|
| D | test55 | 14 Connection: close
20 Connection: close
28 Connection: close
32 Connection: close
|
| D | test1074 | 16 Connection: Keep-Alive
23 Connection: close
52 Connection: Keep-Alive
57 Connection: close
|
| D | test1413 | 16 Connection: close
23 Connection: close
31 Connection: close
36 Connection: close
|
| D | test193 | 18 Connection: close
27 Connection: close
69 Connection: close
75 Connection: close
|
| D | test1021 | 19 Connection: close
47 Connection: close
66 Connection: close
79 Connection: close
122 Proxy-Connection: Keep-Alive
127 Proxy-Connection: Keep-Alive
132 Proxy-Connection: Keep-Alive
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| D | ConnectionPoolTest.java | 67 private Connection httpA;
68 private Connection httpB;
69 private Connection httpC;
70 private Connection httpD;
71 private Connection httpE;
72 private Connection spdyA;
109 httpA = new Connection(pool, httpRoute); in setUp()
111 httpB = new Connection(pool, httpRoute); in setUp()
113 httpC = new Connection(pool, httpRoute); in setUp()
115 httpD = new Connection(pool, httpRoute); in setUp()
[all …]
|
| /external/jetty/src/java/org/eclipse/jetty/server/ |
| D | BlockingHttpConnection.java | 27 import org.eclipse.jetty.io.Connection;
56 public Connection handle() throws IOException in handle()
58 Connection connection = this; in handle()
107 … Connection switched=(Connection)_request.getAttribute("org.eclipse.jetty.io.Connection"); in handle()
|