Brushed up listen socket:

chrome_frame/test/test_server.cc

 // Copyright (c) 2006-2008 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 "base/logging.h"
 #include "base/registry.h"
 #include "base/string_util.h"
 
 #include "chrome_frame/test/test_server.h"
 
@@ skipping 154 matching lines @@
   }
   return NULL;
 }
 
 void SimpleWebServer::DidAccept(ListenSocket* server,
                                 ListenSocket* connection) {
   connections_.push_back(new Connection(connection));
 }
 
 void SimpleWebServer::DidRead(ListenSocket* connection,
-                              const std::string& data) {
+                              const char* data,
+                              int len) {
   Connection* c = FindConnection(connection);
   DCHECK(c);
   Request& r = c->request();
-  r.OnDataReceived(data);
+  std::string str(data, len);
+  r.OnDataReceived(str);
   if (r.AllContentReceived()) {
     const Request& request = c->request();
     Response* response = FindResponse(request);
     if (response) {
       std::string headers;
       if (!response->GetCustomHeaders(&headers)) {
         std::string content_type;
         if (!response->GetContentType(&content_type))
           content_type = kDefaultContentType;
         headers = StringPrintf(kDefaultHeaderTemplate, kStatusOk,
@@ skipping 50 matching lines @@
   ConnectionList::iterator it = FindConnection(socket);
   if (it != connection_list_.end())
     return *it;
   return NULL;
 }
 
 void HTTPTestServer::DidAccept(ListenSocket* server, ListenSocket* socket) {
   connection_list_.push_back(new ConfigurableConnection(socket));
 }
 
-void HTTPTestServer::DidRead(ListenSocket* socket, const std::string& data) {
+void HTTPTestServer::DidRead(ListenSocket* socket,
+                             const char* data,
+                             int len) {
   scoped_refptr<ConfigurableConnection> connection =
       ConnectionFromSocket(socket);
   if (connection) {
-    connection->r_.OnDataReceived(data);
+    std::string str(data, len);
+    connection->r_.OnDataReceived(str);
     if (connection->r_.AllContentReceived()) {
       if (LowerCaseEqualsASCII(connection->r_.method(), "post"))
         this->Post(connection, connection->r_.path(), connection->r_);
       else
         this->Get(connection, connection->r_.path(), connection->r_);
     }
   }
 }
 
 void HTTPTestServer::DidClose(ListenSocket* socket) {
@@ skipping 58 matching lines @@
     data_ = headers;
     data_.append(content_length_header);
     data_.append("\r\n");
   }
 
   MessageLoop::current()->PostDelayedTask(FROM_HERE,
       NewRunnableMethod(this, &ConfigurableConnection::SendChunk),
                         options.timeout_);
 }
 }  // namespace test_server