Index: chrome/browser/chromeos/gdata/test_servers/http_connection.cc |
diff --git a/chrome/browser/chromeos/gdata/test_servers/http_connection.cc b/chrome/browser/chromeos/gdata/test_servers/http_connection.cc |
new file mode 100644 |
index 0000000000000000000000000000000000000000..c9c637e4bf63458b76df5b789a40caf008c1dc99 |
--- /dev/null |
+++ b/chrome/browser/chromeos/gdata/test_servers/http_connection.cc |
@@ -0,0 +1,64 @@ |
+// Copyright (c) 2012 The Chromium Authors. All rights reserved. |
+// Use of this source code is governed by a BSD-style license that can be |
+// found in the LICENSE file. |
+ |
+#include "chrome/browser/chromeos/gdata/test_servers/http_connection.h" |
+ |
+#include <string> |
+#include <sstream> |
+#include "base/basictypes.h" |
+#include "chrome/browser/chromeos/gdata/test_servers/http_request.h" |
+#include "chrome/browser/chromeos/gdata/test_servers/http_response.h" |
+ |
+namespace gdata { |
+namespace test_servers { |
+ |
+HttpConnection::HttpConnection(net::StreamListenSocket* socket, |
+ HttpConnectionDelegate* delegate) : |
+ socket_(socket), |
+ delegate_(delegate) { |
+} |
+ |
+HttpConnection::~HttpConnection() { |
+ |
+} |
+ |
+void HttpConnection::SendResponse(scoped_ptr<HttpResponse> response) { |
+ // TODO(mtomasz): This is just a stub. Replace with better response sending. |
+ |
+ // Response line with headers. |
+ std::stringstream response_builder; |
satorux1
2012/10/12 08:29:18
like google3, we don't use streams. Please use Str
mtomasz
2012/10/12 11:09:46
Done.
|
+ response_builder << "HTTP/1.1 " << response->code << " OK\r\n"; |
+ std::map<std::string, std::string>::iterator it; |
+ response_builder << "Content-Length: " |
+ << response->content.length() << "\r\n"; |
+ response_builder << "Content-Type: " << response->content_type << "\r\n"; |
+ for (it = response->custom_headers.begin(); |
+ it != response->custom_headers.end(); |
+ it++) { |
+ response_builder << it->first << ": " << it->second << "\r\n"; |
+ } |
+ response_builder << "\r\n"; |
+ std::string response_text = response_builder.str(); |
+ socket_->Send(response_text.c_str(), response_text.length()); |
+ |
+ // Response content. |
+ socket_->Send(response->content.c_str(), response->content.length()); |
+} |
+ |
+bool HttpConnection::ReceiveData(const char* data, int length) { |
+ request_parser_.ProcessChunk(data, length); |
+ HttpRequestParser::STATE parser_state; |
+ while ((parser_state = request_parser_.ParseRequest()) == |
satorux1
2012/10/12 08:29:18
assignment in while() looks a bit tricky. maybe ju
mtomasz
2012/10/12 11:09:46
I know that this while is non-trivial, but persona
satorux1
2012/10/16 03:12:18
Then that's fine.
|
+ HttpRequestParser::READY) { |
satorux1
2012/10/12 08:29:18
indentation is off? should look like:
while ((par
mtomasz
2012/10/12 11:09:46
Here I made a 4-spaces indentation as for too long
satorux1
2012/10/16 03:12:18
In conditionals, we should align vertically.
satorux1
2012/10/16 03:19:25
Not only in conditionals, if stuff in parens is lo
|
+ if (!delegate_->HandleRequest(*this, request_parser_.GetRequest().Pass())) { |
+ // Delegate did not accept the request, so we will drop the connection. |
+ return false; |
+ } |
+ } |
+ // If syntax error occured, then we drop the connection. |
+ return parser_state != HttpRequestParser::SYNTAX_ERROR; |
+} |
+ |
+} // namespace test_servers |
+} // namespace gdata |