Clang format slam.

net/socket_stream/socket_stream.cc

 // 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.
 //
 // TODO(ukai): code is similar with http_network_transaction.cc.  We should
 //   think about ways to share code, if possible.
 
 #include "net/socket_stream/socket_stream.h"
 
 #include <set>
@@ skipping 32 matching lines @@
 #include "net/ssl/ssl_info.h"
 #include "net/url_request/url_request.h"
 #include "net/url_request/url_request_context.h"
 
 static const int kMaxPendingSendAllowed = 32768;  // 32 kilobytes.
 static const int kReadBufferSize = 4096;
 
 namespace net {
 
 int SocketStream::Delegate::OnStartOpenConnection(
-    SocketStream* socket, const CompletionCallback& callback) {
+    SocketStream* socket,
+    const CompletionCallback& callback) {
   return OK;
 }
 
 void SocketStream::Delegate::OnAuthRequired(SocketStream* socket,
                                             AuthChallengeInfo* auth_info) {
   // By default, no credential is available and close the connection.
   socket->Close();
 }
 
-void SocketStream::Delegate::OnSSLCertificateError(
-    SocketStream* socket,
-    const SSLInfo& ssl_info,
-    bool fatal) {
+void SocketStream::Delegate::OnSSLCertificateError(SocketStream* socket,
+                                                   const SSLInfo& ssl_info,
+                                                   bool fatal) {
   socket->CancelWithSSLError(ssl_info);
 }
 
 bool SocketStream::Delegate::CanGetCookies(SocketStream* socket,
                                            const GURL& url) {
   return true;
 }
 
 bool SocketStream::Delegate::CanSetCookie(SocketStream* request,
                                           const GURL& url,
                                           const std::string& cookie_line,
                                           CookieOptions* options) {
   return true;
 }
 
-SocketStream::ResponseHeaders::ResponseHeaders() : IOBuffer() {}
+SocketStream::ResponseHeaders::ResponseHeaders() : IOBuffer() {
+}
 
 void SocketStream::ResponseHeaders::Realloc(size_t new_size) {
   headers_.reset(static_cast<char*>(realloc(headers_.release(), new_size)));
 }
 
-SocketStream::ResponseHeaders::~ResponseHeaders() { data_ = NULL; }
+SocketStream::ResponseHeaders::~ResponseHeaders() {
+  data_ = NULL;
+}
 
-SocketStream::SocketStream(const GURL& url, Delegate* delegate,
+SocketStream::SocketStream(const GURL& url,
+                           Delegate* delegate,
                            URLRequestContext* context,
                            CookieStore* cookie_store)
     : delegate_(delegate),
       url_(url),
       max_pending_send_allowed_(kMaxPendingSendAllowed),
       context_(context),
       next_state_(STATE_NONE),
       factory_(ClientSocketFactory::GetDefaultFactory()),
       proxy_mode_(kDirectConnection),
       proxy_url_(url),
       pac_request_(NULL),
       connection_(new ClientSocketHandle),
       privacy_mode_(PRIVACY_MODE_DISABLED),
       // Unretained() is required; without it, Bind() creates a circular
       // dependency and the SocketStream object will not be freed.
-      io_callback_(base::Bind(&SocketStream::OnIOCompleted,
-                              base::Unretained(this))),
+      io_callback_(
+          base::Bind(&SocketStream::OnIOCompleted, base::Unretained(this))),
       read_buf_(NULL),
       current_write_buf_(NULL),
       waiting_for_write_completion_(false),
       closing_(false),
       server_closed_(false),
       metrics_(new SocketStreamMetrics(url)),
       cookie_store_(cookie_store) {
   DCHECK(base::MessageLoop::current())
       << "The current base::MessageLoop must exist";
   DCHECK(base::MessageLoopForIO::IsCurrent())
       << "The current base::MessageLoop must be TYPE_IO";
   DCHECK(delegate_);
 
   if (context_) {
     if (!cookie_store_)
       cookie_store_ = context_->cookie_store();
 
-    net_log_ = BoundNetLog::Make(
-        context->net_log(),
-        NetLog::SOURCE_SOCKET_STREAM);
+    net_log_ =
+        BoundNetLog::Make(context->net_log(), NetLog::SOURCE_SOCKET_STREAM);
 
     net_log_.BeginEvent(NetLog::TYPE_REQUEST_ALIVE);
   }
 }
 
-SocketStream::UserData* SocketStream::GetUserData(
-    const void* key) const {
+SocketStream::UserData* SocketStream::GetUserData(const void* key) const {
   UserDataMap::const_iterator found = user_data_.find(key);
   if (found != user_data_.end())
     return found->second.get();
   return NULL;
 }
 
 void SocketStream::SetUserData(const void* key, UserData* data) {
   user_data_[key] = linked_ptr<UserData>(data);
 }
 
@@ skipping 12 matching lines @@
 
   net_log_.EndEvent(NetLog::TYPE_REQUEST_ALIVE);
   net_log_ = BoundNetLog();
 
   context_ = NULL;
   cookie_store_ = NULL;
 }
 
 void SocketStream::CheckPrivacyMode() {
   if (context_ && context_->network_delegate()) {
-    bool enable = context_->network_delegate()->CanEnablePrivacyMode(url_,
-                                                                     url_);
+    bool enable =
+        context_->network_delegate()->CanEnablePrivacyMode(url_, url_);
     privacy_mode_ = enable ? PRIVACY_MODE_ENABLED : PRIVACY_MODE_DISABLED;
     // Disable Channel ID if privacy mode is enabled.
     if (enable)
       server_ssl_config_.channel_id_enabled = false;
   }
 }
 
 void SocketStream::Connect() {
   DCHECK(base::MessageLoop::current())
       << "The current base::MessageLoop must exist";
@@ skipping 27 matching lines @@
   return total_size;
 }
 
 bool SocketStream::SendData(const char* data, int len) {
   DCHECK(base::MessageLoop::current())
       << "The current base::MessageLoop must exist";
   DCHECK(base::MessageLoopForIO::IsCurrent())
       << "The current base::MessageLoop must be TYPE_IO";
   DCHECK_GT(len, 0);
 
-  if (!connection_->socket() ||
-      !connection_->socket()->IsConnected() || next_state_ == STATE_NONE) {
+  if (!connection_->socket() || !connection_->socket()->IsConnected() ||
+      next_state_ == STATE_NONE) {
     return false;
   }
 
   int total_buffered_bytes = len;
   if (current_write_buf_.get()) {
     // Since
     // - the purpose of this check is to limit the amount of buffer used by
     //   this instance.
     // - the DrainableIOBuffer doesn't release consumed memory.
     // we need to use not BytesRemaining() but size() here.
     total_buffered_bytes += current_write_buf_->size();
   }
   total_buffered_bytes += GetTotalSizeOfPendingWriteBufs();
   if (total_buffered_bytes > max_pending_send_allowed_)
     return false;
 
   // TODO(tyoshino): Split data into smaller chunks e.g. 8KiB to free consumed
   // buffer progressively
-  pending_write_bufs_.push_back(make_scoped_refptr(
-      new IOBufferWithSize(len)));
+  pending_write_bufs_.push_back(make_scoped_refptr(new IOBufferWithSize(len)));
   memcpy(pending_write_bufs_.back()->data(), data, len);
 
   // If current_write_buf_ is not NULL, it means that a) there's ongoing write
   // operation or b) the connection is being closed. If a), the buffer we just
   // pushed will be automatically handled when the completion callback runs
   // the loop, and therefore we don't need to enqueue DoLoop(). If b), it's ok
   // to do nothing. If current_write_buf_ is NULL, to make sure DoLoop() is
   // ran soon, enequeue it.
   if (!current_write_buf_.get()) {
     // Send pending data asynchronously, so that delegate won't be called
@@ skipping 48 matching lines @@
   net_log_.AddEvent(NetLog::TYPE_CANCELLED);
   // We don't need to send pending data when client detach the delegate.
   pending_write_bufs_.clear();
   Close();
 }
 
 const ProxyServer& SocketStream::proxy_server() const {
   return proxy_info_.proxy_server();
 }
 
-void SocketStream::SetClientSocketFactory(
-    ClientSocketFactory* factory) {
+void SocketStream::SetClientSocketFactory(ClientSocketFactory* factory) {
   DCHECK(factory);
   factory_ = factory;
 }
 
 void SocketStream::CancelWithError(int error) {
   base::MessageLoop::current()->PostTask(
       FROM_HERE, base::Bind(&SocketStream::DoLoop, this, error));
 }
 
 void SocketStream::CancelWithSSLError(const SSLInfo& ssl_info) {
   CancelWithError(MapCertStatusToNetError(ssl_info.cert_status));
 }
 
 void SocketStream::ContinueDespiteError() {
   base::MessageLoop::current()->PostTask(
       FROM_HERE, base::Bind(&SocketStream::DoLoop, this, OK));
 }
 
 SocketStream::~SocketStream() {
   DetachContext();
   DCHECK(!delegate_);
   DCHECK(!pac_request_);
 }
 
-SocketStream::RequestHeaders::~RequestHeaders() { data_ = NULL; }
+SocketStream::RequestHeaders::~RequestHeaders() {
+  data_ = NULL;
+}
 
 void SocketStream::set_addresses(const AddressList& addresses) {
   addresses_ = addresses;
 }
 
 void SocketStream::DoClose() {
   closing_ = true;
   // If next_state_ is:
   // - STATE_TCP_CONNECT_COMPLETE, it's waiting other socket establishing
   //   connection.
@@ skipping 231 matching lines @@
       default:
         NOTREACHED() << "bad state " << state;
         Finish(result);
         return;
     }
     if (state == STATE_RESOLVE_PROTOCOL && result == ERR_PROTOCOL_SWITCHED)
       continue;
     // If the connection is not established yet and had actual errors,
     // record the error.  In next iteration, it will close the connection.
     if (state != STATE_READ_WRITE && result < ERR_IO_PENDING) {
-      net_log_.EndEventWithNetErrorCode(
-          NetLog::TYPE_SOCKET_STREAM_CONNECT, result);
+      net_log_.EndEventWithNetErrorCode(NetLog::TYPE_SOCKET_STREAM_CONNECT,
+                                        result);
     }
   } while (result != ERR_IO_PENDING);
 }
 
 int SocketStream::DoBeforeConnect() {
   next_state_ = STATE_BEFORE_CONNECT_COMPLETE;
   if (!context_ || !context_->network_delegate())
     return OK;
 
   int result = context_->network_delegate()->NotifyBeforeSocketStreamConnect(
@@ skipping 125 matching lines @@
   else if (result != OK && result != ERR_PROTOCOL_SWITCHED)
     next_state_ = STATE_CLOSE;
   return result;
 }
 
 int SocketStream::DoResolveProtocolComplete(int result) {
   DCHECK_NE(ERR_IO_PENDING, result);
 
   if (result == ERR_PROTOCOL_SWITCHED) {
     next_state_ = STATE_CLOSE;
-    metrics_->OnCountWireProtocolType(
-        SocketStreamMetrics::WIRE_PROTOCOL_SPDY);
+    metrics_->OnCountWireProtocolType(SocketStreamMetrics::WIRE_PROTOCOL_SPDY);
   } else if (result == OK) {
     next_state_ = STATE_TCP_CONNECT;
     metrics_->OnCountWireProtocolType(
         SocketStreamMetrics::WIRE_PROTOCOL_WEBSOCKET);
   } else {
     next_state_ = STATE_CLOSE;
   }
   return result;
 }
 
 int SocketStream::DoTcpConnect(int result) {
   if (result != OK) {
     next_state_ = STATE_CLOSE;
     return result;
   }
   next_state_ = STATE_TCP_CONNECT_COMPLETE;
   DCHECK(factory_);
-  connection_->SetSocket(
-      factory_->CreateTransportClientSocket(addresses_,
-                                            net_log_.net_log(),
-                                            net_log_.source()));
+  connection_->SetSocket(factory_->CreateTransportClientSocket(
+      addresses_, net_log_.net_log(), net_log_.source()));
   metrics_->OnStartConnection();
   return connection_->socket()->Connect(io_callback_);
 }
 
 int SocketStream::DoTcpConnectComplete(int result) {
   // TODO(ukai): if error occured, reconsider proxy after error.
   if (result != OK) {
     next_state_ = STATE_CLOSE;
     return result;
   }
@@ skipping 105 matching lines @@
 
   next_state_ = STATE_READ_TUNNEL_HEADERS_COMPLETE;
 
   if (!tunnel_response_headers_.get()) {
     tunnel_response_headers_ = new ResponseHeaders();
     tunnel_response_headers_capacity_ = kMaxTunnelResponseHeadersSize;
     tunnel_response_headers_->Realloc(tunnel_response_headers_capacity_);
     tunnel_response_headers_len_ = 0;
   }
 
-  int buf_len = tunnel_response_headers_capacity_ -
-      tunnel_response_headers_len_;
+  int buf_len =
+      tunnel_response_headers_capacity_ - tunnel_response_headers_len_;
   tunnel_response_headers_->SetDataOffset(tunnel_response_headers_len_);
   CHECK(tunnel_response_headers_->data());
 
   return connection_->socket()->Read(
       tunnel_response_headers_.get(), buf_len, io_callback_);
 }
 
 int SocketStream::DoReadTunnelHeadersComplete(int result) {
   DCHECK_EQ(kTunnelProxy, proxy_mode_);
 
@@ skipping 36 matching lines @@
       if (is_secure()) {
         DCHECK_EQ(eoh, tunnel_response_headers_len_);
         next_state_ = STATE_SSL_CONNECT;
       } else {
         result = DidEstablishConnection();
         if (result < 0) {
           next_state_ = STATE_CLOSE;
           return result;
         }
         if ((eoh < tunnel_response_headers_len_) && delegate_)
-          delegate_->OnReceivedData(
-              this, tunnel_response_headers_->headers() + eoh,
-              tunnel_response_headers_len_ - eoh);
+          delegate_->OnReceivedData(this,
+                                    tunnel_response_headers_->headers() + eoh,
+                                    tunnel_response_headers_len_ - eoh);
       }
       return OK;
     case 407:  // Proxy Authentication Required.
       if (proxy_mode_ != kTunnelProxy)
         return ERR_UNEXPECTED_PROXY_AUTH;
 
       result = proxy_auth_controller_->HandleAuthChallenge(
           headers, false, true, net_log_);
       if (result != OK)
         return result;
@@ skipping 381 matching lines @@
       return OK;
   }
 
   if (!delegate_)
     return result;
 
   SSLInfo ssl_info;
   ssl_socket->GetSSLInfo(&ssl_info);
 
   TransportSecurityState::DomainState domain_state;
-  const bool fatal = context_->transport_security_state() &&
-      context_->transport_security_state()->GetDomainState(url_.host(),
+  const bool fatal =
+      context_->transport_security_state() &&
+      context_->transport_security_state()->GetDomainState(
+          url_.host(),
           SSLConfigService::IsSNIAvailable(context_->ssl_config_service()),
           &domain_state) &&
       domain_state.ShouldSSLErrorsBeFatal();
 
   delegate_->OnSSLCertificateError(this, ssl_info, fatal);
   return ERR_IO_PENDING;
 }
 
 CookieStore* SocketStream::cookie_store() const {
   return cookie_store_;
 }
 
 }  // namespace net