Attn: Mike Belshe

net/spdy/spdy_session.h

 // Copyright (c) 2011 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.
 
 #ifndef NET_SPDY_SPDY_SESSION_H_
 #define NET_SPDY_SPDY_SESSION_H_
 #pragma once
 
 #include <deque>
 #include <list>
 #include <map>
 #include <queue>
 #include <string>
 
 #include "base/gtest_prod_util.h"
 #include "base/memory/linked_ptr.h"
 #include "base/memory/ref_counted.h"
 #include "base/task.h"
 #include "net/base/io_buffer.h"
 #include "net/base/load_states.h"
 #include "net/base/net_errors.h"
 #include "net/base/net_log.h"
 #include "net/base/request_priority.h"
 #include "net/base/ssl_config_service.h"
 #include "net/base/upload_data_stream.h"
 #include "net/socket/client_socket.h"
 #include "net/socket/client_socket_handle.h"
+#include "net/socket/sctp_client_socket_pool.h"
 #include "net/socket/tcp_client_socket_pool.h"
 #include "net/spdy/spdy_framer.h"
 #include "net/spdy/spdy_io_buffer.h"
 #include "net/spdy/spdy_protocol.h"
 #include "net/spdy/spdy_session_pool.h"
 
 namespace net {
 
 // This is somewhat arbitrary and not really fixed, but it will always work
 // reasonably with ethernet. Chop the world into 2-packet chunks.  This is
 // somewhat arbitrary, but is reasonably small and ensures that we elicit
 // ACKs quickly from TCP (because TCP tries to only ACK every other packet).
+// TODO(jtl): Replace kMss with kMss_TCP = 1430 and kMss_SCTP  = 1452 and set
+// MaxSpdyFrameChunkSize appropriately, based on which transport protocol we're
+// using.
 const int kMss = 1430;
 const int kMaxSpdyFrameChunkSize = (2 * kMss) - spdy::SpdyFrame::size();
 
 class BoundNetLog;
 class SpdySettingsStorage;
 class SpdyStream;
 class SSLInfo;
 
 class SpdySession : public base::RefCounted<SpdySession>,
                     public spdy::SpdyFramerVisitorInterface {
  public:
   // Create a new SpdySession.
   // |host_port_proxy_pair| is the host/port that this session connects to, and
   // the proxy configuration settings that it's using.
   // |spdy_session_pool| is the SpdySessionPool that owns us.  Its lifetime must
   // strictly be greater than |this|.
   // |session| is the HttpNetworkSession.  |net_log| is the NetLog that we log
   // network events to.
   SpdySession(const HostPortProxyPair& host_port_proxy_pair,
               SpdySessionPool* spdy_session_pool,
               SpdySettingsStorage* spdy_settings,
               NetLog* net_log);
+  typedef void (SpdySession::*OnTransportConnect)(int result);
+  SpdySession(const HostPortProxyPair& host_port_proxy_pair,
+              SpdySessionPool* spdy_session_pool,
+              SpdySettingsStorage* spdy_settings,
+              OnTransportConnect on_transport_connect,
+              NetLog* net_log);
 
   const HostPortPair& host_port_pair() const {
     return host_port_proxy_pair_.first;
   }
   const HostPortProxyPair& host_port_proxy_pair() const {
     return host_port_proxy_pair_;
   }
 
   // Get a pushed stream for a given |url|.
   // If the server initiates a stream, it might already exist for a given path.
@@ skipping 107 matching lines @@
   bool IsReused() const {
     return frames_received_ > 0;
   }
 
   // Returns true if the underlying transport socket ever had any reads or
   // writes.
   bool WasEverUsed() const {
     return connection_->socket()->WasEverUsed();
   }
 
+  // Returns true if the underling socket's transport protocol is SCTP.
+  bool using_sctp() {
+    if (connection_.get()->is_initialized())
+      return connection_.get()->socket()->protocol() ==
+          IPPROTO_SCTP ? true : false;
+    else
+      // TODO(jtl): return sctp_enabled() here?
+      return false;
+  }
+
+  // Returns true if the underlying socket's transport protocol is SCTP and SPDY
+  // control frames are being sent on SCTP stream 0.
+  bool using_sctp_control_stream() {
+    if (connection_.get()->is_initialized())
+      return connection_.get()->socket()->using_sctp_control_stream();
+    else
+      // TODO(jtl): return sctp_enabled() here?
+      return false;
+  }
+
+  // Maps a SPDY stream number to an SCTP stream ID.
+  uint16 MapSpdyToSctp(uint32 stream_id) {
+    return connection_->socket()->MapSpdyToSctp(stream_id);
+  }
+
   void set_spdy_session_pool(SpdySessionPool* pool) {
     spdy_session_pool_ = NULL;
   }
 
   // Access to the number of active and pending streams.  These are primarily
   // available for testing and diagnostics.
   size_t num_active_streams() const { return active_streams_.size(); }
   size_t num_unclaimed_pushed_streams() const {
       return unclaimed_pushed_streams_.size();
   }
@@ skipping 86 matching lines @@
   // Returns OK on success, or an error on failure.
   net::Error ReadSocket();
 
   // Write current data to the socket.
   void WriteSocketLater();
   void WriteSocket();
 
   // Get a new stream id.
   int GetNewStreamId();
 
+  // Get the SCTP stream ID for this SPDY frame.
+  uint16 GetSctpStreamID(const spdy::SpdyFrame& frame);
+
   // Queue a frame for sending.
   // |frame| is the frame to send.
   // |priority| is the priority for insertion into the queue.
   // |stream| is the stream which this IO is associated with (or NULL).
   void QueueFrame(spdy::SpdyFrame* frame, spdy::SpdyPriority priority,
                   SpdyStream* stream);
 
   // Track active streams in the active stream list.
   void ActivateStream(SpdyStream* stream);
   void DeleteStream(spdy::SpdyStreamId id, int status);
@@ skipping 154 matching lines @@
   const spdy::SpdyControlFlags flags_;
   const spdy::SpdyStreamId id_;
   const spdy::SpdyStreamId associated_stream_;
 
   DISALLOW_COPY_AND_ASSIGN(NetLogSpdySynParameter);
 };
 
 }  // namespace net
 
 #endif  // NET_SPDY_SPDY_SESSION_H_