Log source_dependency in HTTP2_SESSION_SEND_HEADERS.

net/spdy/spdy_http_stream_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_http_stream.h"
 
 #include <stdint.h>
 
 #include <memory>
 #include <string>
 
 #include "base/run_loop.h"
 #include "base/stl_util.h"
 #include "base/threading/thread_task_runner_handle.h"
 #include "crypto/ec_private_key.h"
 #include "crypto/ec_signature_creator.h"
 #include "crypto/signature_creator.h"
 #include "net/base/chunked_upload_data_stream.h"
 #include "net/base/load_timing_info.h"
 #include "net/base/load_timing_info_test_util.h"
 #include "net/base/test_completion_callback.h"
 #include "net/cert/asn1_util.h"
 #include "net/http/http_request_info.h"
 #include "net/http/http_response_headers.h"
 #include "net/http/http_response_info.h"
-#include "net/log/net_log_source.h"
 #include "net/log/net_log_with_source.h"
 #include "net/log/test_net_log.h"
 #include "net/socket/socket_test_util.h"
 #include "net/spdy/spdy_http_utils.h"
 #include "net/spdy/spdy_session.h"
 #include "net/spdy/spdy_test_util_common.h"
 #include "net/ssl/default_channel_id_store.h"
 #include "net/test/cert_test_util.h"
 #include "net/test/gtest_util.h"
 #include "net/test/test_data_directory.h"
@@ skipping 159 matching lines @@
   InitSession(reads, arraysize(reads), writes, arraysize(writes));
 
   HttpRequestInfo request;
   request.method = "GET";
   request.url = url_;
   TestCompletionCallback callback;
   HttpResponseInfo response;
   HttpRequestHeaders headers;
   NetLogWithSource net_log;
   std::unique_ptr<SpdyHttpStream> http_stream(
-      new SpdyHttpStream(session_, true));
+      new SpdyHttpStream(session_, true, net_log.source()));
   // Make sure getting load timing information the stream early does not crash.
   LoadTimingInfo load_timing_info;
   EXPECT_FALSE(http_stream->GetLoadTimingInfo(&load_timing_info));
 
   ASSERT_THAT(http_stream->InitializeStream(&request, DEFAULT_PRIORITY, net_log,
                                             CompletionCallback()),
               IsOk());
   EXPECT_FALSE(http_stream->GetLoadTimingInfo(&load_timing_info));
 
   EXPECT_THAT(http_stream->SendRequest(headers, &response, callback.callback()),
@@ skipping 40 matching lines @@
   };
 
   InitSession(reads, arraysize(reads), writes, arraysize(writes));
 
   HttpRequestInfo request1;
   request1.method = "GET";
   request1.url = url_;
   TestCompletionCallback callback1;
   HttpResponseInfo response1;
   HttpRequestHeaders headers1;
+  NetLogWithSource net_log;
   std::unique_ptr<SpdyHttpStream> http_stream1(
-      new SpdyHttpStream(session_, true));
+      new SpdyHttpStream(session_, true, net_log.source()));
 
   HttpRequestInfo request2;
   request2.method = "GET";
   request2.url = url_;
   TestCompletionCallback callback2;
   HttpResponseInfo response2;
   HttpRequestHeaders headers2;
   std::unique_ptr<SpdyHttpStream> http_stream2(
-      new SpdyHttpStream(session_, true));
+      new SpdyHttpStream(session_, true, net_log.source()));
 
   // First write.
-  ASSERT_THAT(
-      http_stream1->InitializeStream(&request1, DEFAULT_PRIORITY,
-                                     NetLogWithSource(), CompletionCallback()),
-      IsOk());
+  ASSERT_THAT(http_stream1->InitializeStream(&request1, DEFAULT_PRIORITY,
+                                             net_log, CompletionCallback()),
+              IsOk());
   EXPECT_THAT(
       http_stream1->SendRequest(headers1, &response1, callback1.callback()),
       IsError(ERR_IO_PENDING));
   EXPECT_TRUE(HasSpdySession(http_session_->spdy_session_pool(), key_));
 
   EXPECT_LE(0, callback1.WaitForResult());
 
   TestLoadTimingNotReused(*http_stream1);
   LoadTimingInfo load_timing_info1;
   LoadTimingInfo load_timing_info2;
   EXPECT_TRUE(http_stream1->GetLoadTimingInfo(&load_timing_info1));
   EXPECT_FALSE(http_stream2->GetLoadTimingInfo(&load_timing_info2));
 
   // Second write.
-  ASSERT_THAT(
-      http_stream2->InitializeStream(&request2, DEFAULT_PRIORITY,
-                                     NetLogWithSource(), CompletionCallback()),
-      IsOk());
+  ASSERT_THAT(http_stream2->InitializeStream(&request2, DEFAULT_PRIORITY,
+                                             net_log, CompletionCallback()),
+              IsOk());
   EXPECT_THAT(
       http_stream2->SendRequest(headers2, &response2, callback2.callback()),
       IsError(ERR_IO_PENDING));
   EXPECT_TRUE(HasSpdySession(http_session_->spdy_session_pool(), key_));
 
   EXPECT_LE(0, callback2.WaitForResult());
 
   // Perform all async reads.
   base::RunLoop().RunUntilIdle();
 
@@ skipping 54 matching lines @@
   request.upload_data_stream = &upload_stream;
 
   ASSERT_THAT(upload_stream.Init(TestCompletionCallback().callback(),
                                  NetLogWithSource()),
               IsOk());
 
   TestCompletionCallback callback;
   HttpResponseInfo response;
   HttpRequestHeaders headers;
   NetLogWithSource net_log;
-  SpdyHttpStream http_stream(session_, true);
+  SpdyHttpStream http_stream(session_, true, net_log.source());
   ASSERT_THAT(http_stream.InitializeStream(&request, DEFAULT_PRIORITY, net_log,
                                            CompletionCallback()),
               IsOk());
 
   EXPECT_THAT(http_stream.SendRequest(headers, &response, callback.callback()),
               IsError(ERR_IO_PENDING));
   EXPECT_TRUE(HasSpdySession(http_session_->spdy_session_pool(), key_));
 
   EXPECT_THAT(callback.WaitForResult(), IsOk());
 
@@ skipping 34 matching lines @@
   request.upload_data_stream = &upload_stream;
 
   ASSERT_THAT(upload_stream.Init(TestCompletionCallback().callback(),
                                  NetLogWithSource()),
               IsOk());
 
   TestCompletionCallback callback;
   HttpResponseInfo response;
   HttpRequestHeaders headers;
   NetLogWithSource net_log;
-  SpdyHttpStream http_stream(session_, true);
+  SpdyHttpStream http_stream(session_, true, net_log.source());
   ASSERT_THAT(http_stream.InitializeStream(&request, DEFAULT_PRIORITY, net_log,
                                            CompletionCallback()),
               IsOk());
   EXPECT_THAT(http_stream.SendRequest(headers, &response, callback.callback()),
               IsError(ERR_IO_PENDING));
   EXPECT_TRUE(HasSpdySession(http_session_->spdy_session_pool(), key_));
 
   EXPECT_THAT(callback.WaitForResult(), IsOk());
 
   EXPECT_EQ(static_cast<int64_t>(req.size() + chunk.size()),
@@ skipping 33 matching lines @@
   request.upload_data_stream = &upload_stream;
 
   ASSERT_THAT(upload_stream.Init(TestCompletionCallback().callback(),
                                  NetLogWithSource()),
               IsOk());
 
   TestCompletionCallback callback;
   HttpResponseInfo response;
   HttpRequestHeaders headers;
   NetLogWithSource net_log;
-  SpdyHttpStream http_stream(session_, true);
+  SpdyHttpStream http_stream(session_, true, net_log.source());
   ASSERT_THAT(http_stream.InitializeStream(&request, DEFAULT_PRIORITY, net_log,
                                            CompletionCallback()),
               IsOk());
 
   EXPECT_THAT(http_stream.SendRequest(headers, &response, callback.callback()),
               IsError(ERR_IO_PENDING));
   EXPECT_TRUE(HasSpdySession(http_session_->spdy_session_pool(), key_));
 
   EXPECT_THAT(callback.WaitForResult(), IsError(ERR_CONNECTION_CLOSED));
 
@@ skipping 48 matching lines @@
   request.url = url_;
   request.upload_data_stream = &upload_stream;
 
   ASSERT_THAT(upload_stream.Init(TestCompletionCallback().callback(),
                                  NetLogWithSource()),
               IsOk());
   upload_stream.AppendData(kUploadData, kUploadDataSize, false);
 
   NetLogWithSource net_log;
   std::unique_ptr<SpdyHttpStream> http_stream(
-      new SpdyHttpStream(session_, true));
+      new SpdyHttpStream(session_, true, net_log.source()));
   ASSERT_THAT(http_stream->InitializeStream(&request, DEFAULT_PRIORITY, net_log,
                                             CompletionCallback()),
               IsOk());
 
   TestCompletionCallback callback;
   HttpRequestHeaders headers;
   HttpResponseInfo response;
   // This will attempt to Write() the initial request and headers, which will
   // complete asynchronously.
   EXPECT_THAT(http_stream->SendRequest(headers, &response, callback.callback()),
@@ skipping 74 matching lines @@
   request.url = url_;
   request.upload_data_stream = &upload_stream;
 
   ASSERT_THAT(upload_stream.Init(TestCompletionCallback().callback(),
                                  NetLogWithSource()),
               IsOk());
   upload_stream.AppendData(kUploadData, kUploadDataSize, false);
 
   NetLogWithSource net_log;
   std::unique_ptr<SpdyHttpStream> http_stream(
-      new SpdyHttpStream(session_, true));
+      new SpdyHttpStream(session_, true, net_log.source()));
   ASSERT_THAT(http_stream->InitializeStream(&request, DEFAULT_PRIORITY, net_log,
                                             CompletionCallback()),
               IsOk());
 
   TestCompletionCallback callback;
   HttpRequestHeaders headers;
   HttpResponseInfo response;
   // This will attempt to Write() the initial request and headers, which will
   // complete asynchronously.
   EXPECT_THAT(http_stream->SendRequest(headers, &response, callback.callback()),
@@ skipping 63 matching lines @@
   request.url = url_;
   request.upload_data_stream = &upload_stream;
 
   ASSERT_THAT(upload_stream.Init(TestCompletionCallback().callback(),
                                  NetLogWithSource()),
               IsOk());
   upload_stream.AppendData("", 0, true);
 
   NetLogWithSource net_log;
   std::unique_ptr<SpdyHttpStream> http_stream(
-      new SpdyHttpStream(session_, true));
+      new SpdyHttpStream(session_, true, net_log.source()));
   ASSERT_THAT(http_stream->InitializeStream(&request, DEFAULT_PRIORITY, net_log,
                                             CompletionCallback()),
               IsOk());
 
   TestCompletionCallback callback;
   HttpRequestHeaders headers;
   HttpResponseInfo response;
   // This will attempt to Write() the initial request and headers, which will
   // complete asynchronously.
   EXPECT_THAT(http_stream->SendRequest(headers, &response, callback.callback()),
@@ skipping 39 matching lines @@
   InitSession(reads, arraysize(reads), writes, arraysize(writes));
 
   HttpRequestInfo request;
   request.method = "GET";
   request.url = GURL(full_url);
   TestCompletionCallback callback;
   HttpResponseInfo response;
   HttpRequestHeaders headers;
   NetLogWithSource net_log;
   std::unique_ptr<SpdyHttpStream> http_stream(
-      new SpdyHttpStream(session_, true));
+      new SpdyHttpStream(session_, true, net_log.source()));
   ASSERT_THAT(http_stream->InitializeStream(&request, DEFAULT_PRIORITY, net_log,
                                             CompletionCallback()),
               IsOk());
 
   EXPECT_THAT(http_stream->SendRequest(headers, &response, callback.callback()),
               IsError(ERR_IO_PENDING));
 
   EXPECT_EQ(base_url, http_stream->stream()->GetUrlFromHeaders().spec());
 
   callback.WaitForResult();
@@ skipping 32 matching lines @@
   request.method = "POST";
   request.url = url_;
   request.upload_data_stream = &upload_stream;
 
   ASSERT_THAT(upload_stream.Init(TestCompletionCallback().callback(),
                                  NetLogWithSource()),
               IsOk());
 
   NetLogWithSource net_log;
   std::unique_ptr<SpdyHttpStream> http_stream(
-      new SpdyHttpStream(session_, true));
+      new SpdyHttpStream(session_, true, net_log.source()));
   ASSERT_THAT(http_stream->InitializeStream(&request, DEFAULT_PRIORITY, net_log,
                                             CompletionCallback()),
               IsOk());
 
   HttpRequestHeaders headers;
   HttpResponseInfo response;
   // This will attempt to Write() the initial request and headers, which will
   // complete asynchronously.
   TestCompletionCallback callback;
   EXPECT_THAT(http_stream->SendRequest(headers, &response, callback.callback()),
@@ skipping 83 matching lines @@
 
   HttpRequestInfo request;
   request.method = "POST";
   request.url = url_;
   request.upload_data_stream = &upload_data_stream;
 
   TestCompletionCallback callback;
   HttpResponseInfo response;
   HttpRequestHeaders headers;
   NetLogWithSource net_log;
-  SpdyHttpStream http_stream(session_, true);
+  SpdyHttpStream http_stream(session_, true, net_log.source());
   ASSERT_THAT(http_stream.InitializeStream(&request, DEFAULT_PRIORITY, net_log,
                                            CompletionCallback()),
               IsOk());
 
   int result = http_stream.SendRequest(headers, &response, callback.callback());
   EXPECT_THAT(callback.GetResult(result), IsError(ERR_FAILED));
 
   // Run posted SpdyHttpStream::ResetStreamInternal() task.
   base::RunLoop().RunUntilIdle();
 
@@ skipping 32 matching lines @@
 
   HttpRequestInfo request;
   request.method = "POST";
   request.url = url_;
   request.upload_data_stream = &upload_data_stream;
 
   TestCompletionCallback callback;
   HttpResponseInfo response;
   HttpRequestHeaders headers;
   NetLogWithSource net_log;
-  SpdyHttpStream http_stream(session_, true);
+  SpdyHttpStream http_stream(session_, true, net_log.source());
   ASSERT_THAT(http_stream.InitializeStream(&request, DEFAULT_PRIORITY, net_log,
                                            CompletionCallback()),
               IsOk());
 
   int result = http_stream.SendRequest(headers, &response, callback.callback());
   EXPECT_THAT(result, IsError(ERR_IO_PENDING));
   EXPECT_THAT(callback.GetResult(result), IsError(ERR_FAILED));
 
   // Run posted SpdyHttpStream::ResetStreamInternal() task.
   base::RunLoop().RunUntilIdle();
@@ skipping 21 matching lines @@
   ChunkedUploadDataStream upload_stream(0);
   request.upload_data_stream = &upload_stream;
 
   TestCompletionCallback upload_callback;
   ASSERT_THAT(
       upload_stream.Init(upload_callback.callback(), NetLogWithSource()),
       IsOk());
   upload_stream.AppendData("", 0, true);
 
   NetLogWithSource net_log;
-  SpdyHttpStream http_stream(session_, true);
+  SpdyHttpStream http_stream(session_, true, net_log.source());
   ASSERT_THAT(http_stream.InitializeStream(&request, DEFAULT_PRIORITY, net_log,
                                            CompletionCallback()),
               IsOk());
 
   CancelStreamCallback callback(&http_stream);
   HttpRequestHeaders headers;
   HttpResponseInfo response;
   // This will attempt to Write() the initial request and headers, which will
   // complete asynchronously.
   EXPECT_THAT(http_stream.SendRequest(headers, &response, callback.callback()),
               IsError(ERR_IO_PENDING));
   EXPECT_TRUE(HasSpdySession(http_session_->spdy_session_pool(), key_));
 
   // The callback cancels |http_stream|.
   EXPECT_THAT(callback.WaitForResult(), IsOk());
 
   // Finish async network reads/writes.
   base::RunLoop().RunUntilIdle();
 
   EXPECT_FALSE(HasSpdySession(http_session_->spdy_session_pool(), key_));
 }
 
 // TODO(willchan): Write a longer test for SpdyStream that exercises all
 // methods.
 
 }  // namespace test
 
 }  // namespace net