HTTP2 draft 14 support

net/spdy/spdy_session_unittest.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/spdy/spdy_session.h"
 
 #include "base/bind.h"
 #include "base/callback.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/run_loop.h"
@@ skipping 4934 matching lines @@
   data.RunFor(1);
   EXPECT_EQ(1u, session->num_active_streams());
   EXPECT_EQ(0u, session->num_created_streams());
   EXPECT_EQ(0u, session->num_pushed_streams());
   EXPECT_EQ(0u, session->num_active_pushed_streams());
 
   // Read EOF.
   data.RunFor(2);
 }
 
+TEST_P(SpdySessionTest, RejectInvalidUnknownFrames) {
+  session_deps_.host_resolver->set_synchronous_mode(true);
+
+  MockRead reads[] = {
+      MockRead(SYNCHRONOUS, ERR_IO_PENDING)  // Stall forever.
+  };
+
+  StaticSocketDataProvider data(reads, arraysize(reads), NULL, 0);
+
+  MockConnect connect_data(SYNCHRONOUS, OK);
+  data.set_connect_data(connect_data);
+  session_deps_.socket_factory->AddSocketDataProvider(&data);
+
+  CreateNetworkSession();
+  base::WeakPtr<SpdySession> session =
+      CreateInsecureSpdySession(http_session_, key_, BoundNetLog());
+
+  session->stream_hi_water_mark_ = 5;
+  // Low client (odd) ids are fine.
+  EXPECT_TRUE(session->OnUnknownFrame(3, 0));
+  // Client id exceeding watermark.
+  EXPECT_FALSE(session->OnUnknownFrame(9, 0));
+  // Currently we do not keep track of server initiated (even) ids.
+  EXPECT_TRUE(session->OnUnknownFrame(2, 0));
+  EXPECT_TRUE(session->OnUnknownFrame(8, 0));
+}
+
 TEST(MapFramerErrorToProtocolError, MapsValues) {
   CHECK_EQ(
       SPDY_ERROR_INVALID_CONTROL_FRAME,
       MapFramerErrorToProtocolError(SpdyFramer::SPDY_INVALID_CONTROL_FRAME));
   CHECK_EQ(
       SPDY_ERROR_INVALID_DATA_FRAME_FLAGS,
       MapFramerErrorToProtocolError(SpdyFramer::SPDY_INVALID_DATA_FRAME_FLAGS));
   CHECK_EQ(
       SPDY_ERROR_GOAWAY_FRAME_CORRUPT,
       MapFramerErrorToProtocolError(SpdyFramer::SPDY_GOAWAY_FRAME_CORRUPT));
@@ skipping 30 matching lines @@
   CHECK_EQ(GOAWAY_PROTOCOL_ERROR,
            MapNetErrorToGoAwayStatus(ERR_SPDY_PROTOCOL_ERROR));
   CHECK_EQ(GOAWAY_COMPRESSION_ERROR,
            MapNetErrorToGoAwayStatus(ERR_SPDY_COMPRESSION_ERROR));
   CHECK_EQ(GOAWAY_FRAME_SIZE_ERROR,
            MapNetErrorToGoAwayStatus(ERR_SPDY_FRAME_SIZE_ERROR));
   CHECK_EQ(GOAWAY_PROTOCOL_ERROR, MapNetErrorToGoAwayStatus(ERR_UNEXPECTED));
 }
 
 }  // namespace net