Index: chrome/test/chromedriver/net/test_http_server.cc |
diff --git a/chrome/test/chromedriver/net/test_http_server.cc b/chrome/test/chromedriver/net/test_http_server.cc |
index 1d19524d9157f6f22918f880a5742ff21611ee5f..f8795cc992c4b961be33a83f2585d52f79e823f1 100644 |
--- a/chrome/test/chromedriver/net/test_http_server.cc |
+++ b/chrome/test/chromedriver/net/test_http_server.cc |
@@ -16,6 +16,8 @@ |
#include "net/socket/tcp_server_socket.h" |
#include "testing/gtest/include/gtest/gtest.h" |
+const int kBufferSize = 100 * 1024 * 1024; // 100 MB |
+ |
TestHttpServer::TestHttpServer() |
: thread_("ServerThread"), |
all_closed_event_(false, true), |
@@ -73,9 +75,19 @@ GURL TestHttpServer::web_socket_url() const { |
return web_socket_url_; |
} |
+void TestHttpServer::OnHttpRequest( |
+ int connection_id, |
+ const net::HttpServerRequestInfo& info) { |
+ server_->SetSendBufferSize(connection_id, kBufferSize); |
+ server_->SetReceiveBufferSize(connection_id, kBufferSize); |
+} |
+ |
void TestHttpServer::OnWebSocketRequest( |
int connection_id, |
const net::HttpServerRequestInfo& info) { |
+ server_->SetSendBufferSize(connection_id, kBufferSize); |
+ server_->SetReceiveBufferSize(connection_id, kBufferSize); |
+ |
WebSocketRequestAction action; |
{ |
base::AutoLock lock(action_lock_); |
@@ -99,6 +111,8 @@ void TestHttpServer::OnWebSocketRequest( |
void TestHttpServer::OnWebSocketMessage(int connection_id, |
const std::string& data) { |
+ server_->SetSendBufferSize(connection_id, kBufferSize); |
+ server_->SetReceiveBufferSize(connection_id, kBufferSize); |
WebSocketMessageAction action; |
{ |
base::AutoLock lock(action_lock_); |