Clang format slam.

net/tools/quic/quic_dispatcher.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.
 
 #include "net/tools/quic/quic_dispatcher.h"
 
 #include <errno.h>
 
 #include "base/debug/stack_trace.h"
 #include "base/logging.h"
 #include "base/stl_util.h"
 #include "net/quic/quic_blocked_writer_interface.h"
 #include "net/quic/quic_flags.h"
 #include "net/quic/quic_utils.h"
 #include "net/tools/quic/quic_default_packet_writer.h"
 #include "net/tools/quic/quic_epoll_connection_helper.h"
 #include "net/tools/quic/quic_socket_utils.h"
 #include "net/tools/quic/quic_time_wait_list_manager.h"
 
 namespace net {
 
 namespace tools {
 
 using base::StringPiece;
 using std::make_pair;
 
 class DeleteSessionsAlarm : public EpollAlarm {
  public:
   explicit DeleteSessionsAlarm(QuicDispatcher* dispatcher)
-      : dispatcher_(dispatcher) {
-  }
+      : dispatcher_(dispatcher) {}
 
   virtual int64 OnAlarm() OVERRIDE {
     EpollAlarm::OnAlarm();
     dispatcher_->DeleteSessions();
     return 0;
   }
 
  private:
   QuicDispatcher* dispatcher_;
 };
 
 class QuicDispatcher::QuicFramerVisitor : public QuicFramerVisitorInterface {
  public:
   explicit QuicFramerVisitor(QuicDispatcher* dispatcher)
-      : dispatcher_(dispatcher),
-        connection_id_(0) {}
+      : dispatcher_(dispatcher), connection_id_(0) {}
 
   // QuicFramerVisitorInterface implementation
   virtual void OnPacket() OVERRIDE {}
   virtual bool OnUnauthenticatedPublicHeader(
       const QuicPacketPublicHeader& header) OVERRIDE {
     connection_id_ = header.connection_id;
     return dispatcher_->OnUnauthenticatedPublicHeader(header);
   }
   virtual bool OnUnauthenticatedHeader(
       const QuicPacketHeader& header) OVERRIDE {
@@ skipping 29 matching lines @@
       const QuicVersionNegotiationPacket& /*packet*/) OVERRIDE {
     DCHECK(false);
   }
   virtual void OnDecryptedPacket(EncryptionLevel level) OVERRIDE {
     DCHECK(false);
   }
   virtual bool OnPacketHeader(const QuicPacketHeader& /*header*/) OVERRIDE {
     DCHECK(false);
     return false;
   }
-  virtual void OnRevivedPacket() OVERRIDE {
-    DCHECK(false);
-  }
+  virtual void OnRevivedPacket() OVERRIDE { DCHECK(false); }
   virtual void OnFecProtectedPayload(StringPiece /*payload*/) OVERRIDE {
     DCHECK(false);
   }
   virtual bool OnStreamFrame(const QuicStreamFrame& /*frame*/) OVERRIDE {
     DCHECK(false);
     return false;
   }
   virtual bool OnAckFrame(const QuicAckFrame& /*frame*/) OVERRIDE {
     DCHECK(false);
     return false;
@@ skipping 10 matching lines @@
   }
   virtual bool OnPingFrame(const QuicPingFrame& /*frame*/) OVERRIDE {
     DCHECK(false);
     return false;
   }
   virtual bool OnRstStreamFrame(const QuicRstStreamFrame& /*frame*/) OVERRIDE {
     DCHECK(false);
     return false;
   }
   virtual bool OnConnectionCloseFrame(
-      const QuicConnectionCloseFrame & /*frame*/) OVERRIDE {
+      const QuicConnectionCloseFrame& /*frame*/) OVERRIDE {
     DCHECK(false);
     return false;
   }
   virtual bool OnGoAwayFrame(const QuicGoAwayFrame& /*frame*/) OVERRIDE {
     DCHECK(false);
     return false;
   }
-  virtual bool OnWindowUpdateFrame(const QuicWindowUpdateFrame& /*frame*/)
-      OVERRIDE {
+  virtual bool OnWindowUpdateFrame(
+      const QuicWindowUpdateFrame& /*frame*/) OVERRIDE {
     DCHECK(false);
     return false;
   }
   virtual bool OnBlockedFrame(const QuicBlockedFrame& frame) OVERRIDE {
     DCHECK(false);
     return false;
   }
-  virtual void OnFecData(const QuicFecData& /*fec*/) OVERRIDE {
-    DCHECK(false);
-  }
-  virtual void OnPacketComplete() OVERRIDE {
-    DCHECK(false);
-  }
+  virtual void OnFecData(const QuicFecData& /*fec*/) OVERRIDE { DCHECK(false); }
+  virtual void OnPacketComplete() OVERRIDE { DCHECK(false); }
 
  private:
   QuicDispatcher* dispatcher_;
 
   // Latched in OnUnauthenticatedPublicHeader for use later.
   QuicConnectionId connection_id_;
 };
 
 QuicDispatcher::QuicDispatcher(const QuicConfig& config,
                                const QuicCryptoServerConfig& crypto_config,
@@ skipping 21 matching lines @@
 
 void QuicDispatcher::Initialize(int fd) {
   DCHECK(writer_ == NULL);
   writer_.reset(CreateWriter(fd));
   time_wait_list_manager_.reset(CreateQuicTimeWaitListManager());
 
   // Remove all versions > QUIC_VERSION_16 from the
   // supported_versions_no_flow_control_ vector.
   QuicVersionVector::iterator it =
       find(supported_versions_no_flow_control_.begin(),
-           supported_versions_no_flow_control_.end(), QUIC_VERSION_17);
+           supported_versions_no_flow_control_.end(),
+           QUIC_VERSION_17);
   if (it != supported_versions_no_flow_control_.end()) {
     supported_versions_no_flow_control_.erase(
         supported_versions_no_flow_control_.begin(), it + 1);
   }
   CHECK(!supported_versions_no_flow_control_.empty());
 }
 
 void QuicDispatcher::ProcessPacket(const IPEndPoint& server_address,
                                    const IPEndPoint& client_address,
                                    const QuicEncryptedPacket& packet) {
@@ skipping 19 matching lines @@
       return false;
     }
     if (time_wait_list_manager_->IsConnectionIdInTimeWait(connection_id)) {
       return HandlePacketForTimeWait(header);
     }
 
     // Ensure the packet has a version negotiation bit set before creating a new
     // session for it.  All initial packets for a new connection are required to
     // have the flag set.  Otherwise it may be a stray packet.
     if (header.version_flag) {
-      session = CreateQuicSession(connection_id, current_server_address_,
-                                  current_client_address_);
+      session = CreateQuicSession(
+          connection_id, current_server_address_, current_client_address_);
     }
 
     if (session == NULL) {
       DVLOG(1) << "Failed to create session for " << connection_id;
       // Add this connection_id fo the time-wait state, to safely reject future
       // packets.
 
       if (header.version_flag &&
           !framer_.IsSupportedVersion(header.versions.front())) {
         // TODO(ianswett): Produce a no-version version negotiation packet.
         return false;
       }
 
       // Use the version in the packet if possible, otherwise assume the latest.
-      QuicVersion version = header.version_flag ? header.versions.front() :
-          supported_versions_.front();
+      QuicVersion version = header.version_flag ? header.versions.front()
+                                                : supported_versions_.front();
       time_wait_list_manager_->AddConnectionIdToTimeWait(
           connection_id, version, NULL);
       DCHECK(time_wait_list_manager_->IsConnectionIdInTimeWait(connection_id));
       return HandlePacketForTimeWait(header);
     }
     DVLOG(1) << "Created new session for " << connection_id;
     session_map_.insert(make_pair(connection_id, session));
   } else {
     session = it->second;
   }
@@ skipping 11 matching lines @@
   time_wait_list_manager_->ProcessPacket(current_server_address_,
                                          current_client_address_,
                                          header.public_header.connection_id,
                                          header.packet_sequence_number,
                                          *current_packet_);
 }
 
 void QuicDispatcher::CleanUpSession(SessionMap::iterator it) {
   QuicConnection* connection = it->second->connection();
   QuicEncryptedPacket* connection_close_packet =
-          connection->ReleaseConnectionClosePacket();
+      connection->ReleaseConnectionClosePacket();
   write_blocked_list_.erase(connection);
-  time_wait_list_manager_->AddConnectionIdToTimeWait(it->first,
-                                                     connection->version(),
-                                                     connection_close_packet);
+  time_wait_list_manager_->AddConnectionIdToTimeWait(
+      it->first, connection->version(), connection_close_packet);
   session_map_.erase(it);
 }
 
 void QuicDispatcher::DeleteSessions() {
   STLDeleteElements(&closed_session_list_);
 }
 
 void QuicDispatcher::OnCanWrite() {
   // We got an EPOLLOUT: the socket should not be blocked.
   writer_->SetWritable();
@@ skipping 34 matching lines @@
                                         QuicErrorCode error) {
   SessionMap::iterator it = session_map_.find(connection_id);
   if (it == session_map_.end()) {
     LOG(DFATAL) << "ConnectionId " << connection_id
                 << " does not exist in the session map.  "
                 << "Error: " << QuicUtils::ErrorToString(error);
     LOG(DFATAL) << base::debug::StackTrace().ToString();
     return;
   }
 
-  DLOG_IF(INFO, error != QUIC_NO_ERROR) << "Closing connection ("
-                                        << connection_id
-                                        << ") due to error: "
-                                        << QuicUtils::ErrorToString(error);
+  DLOG_IF(INFO, error != QUIC_NO_ERROR)
+      << "Closing connection (" << connection_id
+      << ") due to error: " << QuicUtils::ErrorToString(error);
 
   if (closed_session_list_.empty()) {
-    epoll_server_->RegisterAlarmApproximateDelta(
-        0, delete_sessions_alarm_.get());
+    epoll_server_->RegisterAlarmApproximateDelta(0,
+                                                 delete_sessions_alarm_.get());
   }
   closed_session_list_.push_back(it->second);
   CleanUpSession(it);
 }
 
 void QuicDispatcher::OnWriteBlocked(QuicBlockedWriterInterface* writer) {
   DCHECK(writer_->IsWriteBlocked());
   write_blocked_list_.insert(make_pair(writer, true));
 }
 
@@ skipping 17 matching lines @@
 }
 
 QuicConnection* QuicDispatcher::CreateQuicConnection(
     QuicConnectionId connection_id,
     const IPEndPoint& server_address,
     const IPEndPoint& client_address,
     uint32 initial_flow_control_window) {
   // If we have disabled per-stream flow control, then don't allow new
   // connections to talk QUIC_VERSION_17 or higher.
   if (FLAGS_enable_quic_stream_flow_control_2) {
-    return new QuicConnection(connection_id, client_address, helper_.get(),
-                              writer_.get(), true, supported_versions_,
+    return new QuicConnection(connection_id,
+                              client_address,
+                              helper_.get(),
+                              writer_.get(),
+                              true,
+                              supported_versions_,
                               initial_flow_control_window_bytes_);
   } else {
     DVLOG(1)
         << "Flow control disabled, creating QuicDispatcher WITHOUT version 17";
-    return new QuicConnection(connection_id, client_address, helper_.get(),
-                              writer_.get(), true,
+    return new QuicConnection(connection_id,
+                              client_address,
+                              helper_.get(),
+                              writer_.get(),
+                              true,
                               supported_versions_no_flow_control_,
                               initial_flow_control_window_bytes_);
   }
 }
 
 QuicTimeWaitListManager* QuicDispatcher::CreateQuicTimeWaitListManager() {
   return new QuicTimeWaitListManager(
       writer_.get(), this, epoll_server(), supported_versions());
 }
 
 bool QuicDispatcher::HandlePacketForTimeWait(
     const QuicPacketPublicHeader& header) {
   if (header.reset_flag) {
     // Public reset packets do not have sequence numbers, so ignore the packet.
     return false;
   }
 
   // Switch the framer to the correct version, so that the sequence number can
   // be parsed correctly.
   framer_.set_version(time_wait_list_manager_->GetQuicVersionFromConnectionId(
       header.connection_id));
 
   // Continue parsing the packet to extract the sequence number.  Then
   // send it to the time wait manager in OnUnathenticatedHeader.
   return true;
 }
 
 }  // namespace tools
 }  // namespace net