Home
last modified time | relevance | path

Searched refs:HttpConnection (Results 1 – 21 of 21) sorted by relevance

/external/chromium_org/net/server/
Dhttp_connection_unittest.cc25 scoped_refptr<HttpConnection::ReadIOBuffer> buffer( in TEST()
26 new HttpConnection::ReadIOBuffer); in TEST()
27 EXPECT_EQ(HttpConnection::ReadIOBuffer::kInitialBufSize + 0, in TEST()
29 EXPECT_EQ(HttpConnection::ReadIOBuffer::kInitialBufSize + 0, in TEST()
33 const int kNewCapacity = HttpConnection::ReadIOBuffer::kInitialBufSize + 128; in TEST()
41 scoped_refptr<HttpConnection::ReadIOBuffer> buffer( in TEST()
42 new HttpConnection::ReadIOBuffer); in TEST()
43 EXPECT_EQ(HttpConnection::ReadIOBuffer::kInitialBufSize + 0, in TEST()
45 EXPECT_EQ(HttpConnection::ReadIOBuffer::kInitialBufSize + 0, in TEST()
50 GetTestString(HttpConnection::ReadIOBuffer::kInitialBufSize)); in TEST()
[all …]
Dhttp_connection.cc13 HttpConnection::ReadIOBuffer::ReadIOBuffer() in ReadIOBuffer()
19 HttpConnection::ReadIOBuffer::~ReadIOBuffer() { in ~ReadIOBuffer()
23 int HttpConnection::ReadIOBuffer::GetCapacity() const { in GetCapacity()
27 void HttpConnection::ReadIOBuffer::SetCapacity(int capacity) { in SetCapacity()
33 bool HttpConnection::ReadIOBuffer::IncreaseCapacity() { in IncreaseCapacity()
48 char* HttpConnection::ReadIOBuffer::StartOfBuffer() const { in StartOfBuffer()
52 int HttpConnection::ReadIOBuffer::GetSize() const { in GetSize()
56 void HttpConnection::ReadIOBuffer::DidRead(int bytes) { in DidRead()
62 int HttpConnection::ReadIOBuffer::RemainingCapacity() const { in RemainingCapacity()
66 void HttpConnection::ReadIOBuffer::DidConsume(int bytes) { in DidConsume()
[all …]
Dhttp_server.h19 class HttpConnection; variable
77 typedef std::map<int, HttpConnection*> IdToConnectionMap;
83 void DoReadLoop(HttpConnection* connection);
85 int HandleReadResult(HttpConnection* connection, int rv);
87 void DoWriteLoop(HttpConnection* connection);
89 int HandleWriteResult(HttpConnection* connection, int rv);
99 HttpConnection* FindConnection(int connection_id);
102 bool HasClosedConnection(HttpConnection* connection);
Dhttp_server.cc44 HttpConnection* connection = FindConnection(connection_id); in AcceptWebSocket()
53 HttpConnection* connection = FindConnection(connection_id); in SendOverWebSocket()
61 HttpConnection* connection = FindConnection(connection_id); in SendRaw()
100 HttpConnection* connection = FindConnection(connection_id); in Close()
119 HttpConnection* connection = FindConnection(connection_id); in SetReceiveBufferSize()
125 HttpConnection* connection = FindConnection(connection_id); in SetSendBufferSize()
153 HttpConnection* connection = in HandleAcceptResult()
154 new HttpConnection(++last_id_, accepted_socket_.Pass()); in HandleAcceptResult()
162 void HttpServer::DoReadLoop(HttpConnection* connection) { in DoReadLoop()
165 HttpConnection::ReadIOBuffer* read_buf = connection->read_buf(); in DoReadLoop()
[all …]
Dweb_socket.h15 class HttpConnection; variable
29 HttpConnection* connection,
47 WebSocket(HttpServer* server, HttpConnection* connection);
50 HttpConnection* const connection_;
Dhttp_connection.h23 class HttpConnection {
113 HttpConnection(int id, scoped_ptr<StreamSocket> socket);
114 ~HttpConnection();
132 DISALLOW_COPY_AND_ASSIGN(HttpConnection);
Dweb_socket.cc48 HttpConnection* connection, in Create()
91 HttpConnection::ReadIOBuffer* read_buf = connection_->read_buf(); in Read()
118 HttpConnection* connection, in WebSocketHixie76()
183 HttpConnection* connection, in Create()
221 HttpConnection::ReadIOBuffer* read_buf = connection_->read_buf(); in Read()
242 HttpConnection* connection, in WebSocketHybi17()
275 HttpConnection* connection, in CreateWebSocket()
418 WebSocket::WebSocket(HttpServer* server, HttpConnection* connection) in WebSocket()
/external/chromium_org/net/test/embedded_test_server/
Dhttp_connection.cc13 HttpConnection::HttpConnection(scoped_ptr<StreamListenSocket> socket, in HttpConnection() function in net::test_server::HttpConnection
19 HttpConnection::~HttpConnection() { in ~HttpConnection()
22 void HttpConnection::SendResponse(scoped_ptr<HttpResponse> response) const { in SendResponse()
27 void HttpConnection::ReceiveData(const base::StringPiece& data) { in ReceiveData()
Dhttp_connection.h19 class HttpConnection; variable
24 typedef base::Callback<void(HttpConnection* connection,
30 class HttpConnection {
32 HttpConnection(scoped_ptr<StreamListenSocket> socket,
34 ~HttpConnection();
51 DISALLOW_COPY_AND_ASSIGN(HttpConnection);
Dembedded_test_server.h29 class HttpConnection; variable
165 void HandleRequest(HttpConnection* connection,
176 HttpConnection* FindConnection(StreamListenSocket* socket);
189 std::map<StreamListenSocket*, HttpConnection*> connections_;
Dembedded_test_server.cc225 void EmbeddedTestServer::HandleRequest(HttpConnection* connection, in HandleRequest()
278 HttpConnection* http_connection = new HttpConnection( in DidAccept()
291 HttpConnection* http_connection = FindConnection(connection); in DidRead()
302 HttpConnection* http_connection = FindConnection(connection); in DidClose()
311 HttpConnection* EmbeddedTestServer::FindConnection( in FindConnection()
315 std::map<StreamListenSocket*, HttpConnection*>::iterator it = in FindConnection()
/external/apache-http/src/org/apache/http/impl/conn/
DIdleConnectionHandler.java40 import org.apache.http.HttpConnection;
62 private final Map<HttpConnection,TimeValues> connectionToTimes;
67 connectionToTimes = new HashMap<HttpConnection,TimeValues>(); in IdleConnectionHandler()
78 public void add(HttpConnection connection, long validDuration, TimeUnit unit) { in add()
97 public boolean remove(HttpConnection connection) { in remove()
129 Iterator<HttpConnection> connectionIter = in closeIdleConnections()
133 HttpConnection conn = connectionIter.next(); in closeIdleConnections()
157 Iterator<HttpConnection> connectionIter = in closeExpiredConnections()
161 HttpConnection conn = connectionIter.next(); in closeExpiredConnections()
/external/apache-http/src/org/apache/http/protocol/
DRequestTargetHost.java37 import org.apache.http.HttpConnection;
79 HttpConnection conn = (HttpConnection) context in process()
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/
DConnection.java22 import com.squareup.okhttp.internal.http.HttpConnection;
72 private HttpConnection httpConnection;
157 httpConnection = new HttpConnection(pool, this, socket); in connect()
222 httpConnection = new HttpConnection(pool, this, socket); in upgradeToTls()
353 HttpConnection tunnelConnection = new HttpConnection(pool, this, socket); in makeTunnel()
/external/apache-http/src/org/apache/http/impl/
DDefaultConnectionReuseStrategy.java35 import org.apache.http.HttpConnection;
94 HttpConnection conn = (HttpConnection) in keepAlive()
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/
DHttpTransport.java28 private final HttpConnection httpConnection;
30 public HttpTransport(HttpEngine httpEngine, HttpConnection httpConnection) { in HttpTransport()
DHttpConnection.java61 public final class HttpConnection { class
83 public HttpConnection(ConnectionPool pool, Connection connection, Socket socket) in HttpConnection() method in HttpConnection
/external/apache-http/src/org/apache/http/
DHttpInetConnection.java50 public interface HttpInetConnection extends HttpConnection {
DHttpConnection.java50 public interface HttpConnection { interface
DHttpServerConnection.java51 public interface HttpServerConnection extends HttpConnection {
DHttpClientConnection.java53 public interface HttpClientConnection extends HttpConnection {