net: Make UploadDataStream::Init() asynchronous.

net/spdy/spdy_http_stream_spdy3_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 "base/memory/scoped_ptr.h"
 #include "base/threading/sequenced_worker_pool.h"
 #include "crypto/ec_private_key.h"
 #include "crypto/ec_signature_creator.h"
@@ skipping 155 matching lines @@
   HttpResponseInfo response;
   HttpRequestHeaders headers;
   BoundNetLog net_log;
   SpdyHttpStream http_stream(session_.get(), true);
   ASSERT_EQ(
       OK,
       http_stream.InitializeStream(&request, net_log, CompletionCallback()));
 
   scoped_ptr<UploadDataStream> upload_stream(
       new UploadDataStream(request.upload_data));
-  ASSERT_EQ(OK, upload_stream->Init());
+  ASSERT_EQ(OK, upload_stream->InitSync());
   EXPECT_EQ(ERR_IO_PENDING, http_stream.SendRequest(
       headers, upload_stream.Pass(), &response, callback.callback()));
   EXPECT_TRUE(http_session_->spdy_session_pool()->HasSession(pair));
 
   // This triggers the MockWrite and read 2
   callback.WaitForResult();
 
   // This triggers read 3. The empty read causes the session to shut down.
   data()->CompleteRead();
   MessageLoop::current()->RunAllPending();
@@ skipping 74 matching lines @@
   BoundNetLog net_log;
   scoped_ptr<SpdyHttpStream> http_stream(
       new SpdyHttpStream(session_.get(), true));
   ASSERT_EQ(OK,
             http_stream->InitializeStream(&request,
                                           net_log,
                                           CompletionCallback()));
 
   scoped_ptr<UploadDataStream> upload_stream(
       new UploadDataStream(request.upload_data));
-  ASSERT_EQ(OK, upload_stream->Init());
+  ASSERT_EQ(OK, upload_stream->InitSync());
 
   request.upload_data->AppendChunk(kUploadData, kUploadDataSize, false);
 
   HttpRequestHeaders headers;
   HttpResponseInfo response;
   // This will attempt to Write() the initial request and headers, which will
   // complete asynchronously.
   EXPECT_EQ(ERR_IO_PENDING,
             http_stream->SendRequest(headers,
                                      upload_stream.Pass(),
@@ skipping 115 matching lines @@
   BoundNetLog net_log;
   scoped_ptr<SpdyHttpStream> http_stream(
       new SpdyHttpStream(session_.get(), true));
   ASSERT_EQ(OK,
             http_stream->InitializeStream(&request,
                                           net_log,
                                           CompletionCallback()));
 
   scoped_ptr<UploadDataStream> upload_stream(
       new UploadDataStream(request.upload_data));
-  ASSERT_EQ(OK, upload_stream->Init());
+  ASSERT_EQ(OK, upload_stream->InitSync());
 
   request.upload_data->AppendChunk(kUploadData, kUploadDataSize, true);
 
   HttpRequestHeaders headers;
   HttpResponseInfo response;
   // This will attempt to Write() the initial request and headers, which will
   // complete asynchronously.
   EXPECT_EQ(ERR_IO_PENDING,
             http_stream->SendRequest(headers,
                                      upload_stream.Pass(),
@@ skipping 321 matching lines @@
 
   sequenced_worker_pool->Shutdown();
 }
 
 #endif  // !defined(USE_OPENSSL)
 
 // TODO(willchan): Write a longer test for SpdyStream that exercises all
 // methods.
 
 }  // namespace net