net: Make UploadDataStream::Init() asynchronous.

chrome_frame/urlmon_upload_data_stream.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 "chrome_frame/urlmon_upload_data_stream.h"
 
 #include "net/base/io_buffer.h"
 #include "net/base/net_errors.h"
 
 void UrlmonUploadDataStream::Initialize(net::UploadData* upload_data) {
   upload_data_ = upload_data;
   request_body_stream_.reset(
       new net::UploadDataStream(upload_data));
-  const int result = request_body_stream_->Init();
+  const int result = request_body_stream_->InitSync();
   DCHECK_EQ(net::OK, result);
 }
 
 STDMETHODIMP UrlmonUploadDataStream::Read(void* pv, ULONG cb, ULONG* read) {
   if (pv == NULL) {
     NOTREACHED();
     return E_POINTER;
   }
 
   // Have we already read past the end of the stream?
@@ skipping 38 matching lines @@
   return S_OK;
 }
 
 STDMETHODIMP UrlmonUploadDataStream::Seek(LARGE_INTEGER move, DWORD origin,
                                           ULARGE_INTEGER* new_pos) {
   // UploadDataStream is really not very seek-able, so for now allow
   // STREAM_SEEK_SETs to work with a 0 offset, but fail on everything else.
   if (origin == STREAM_SEEK_SET && move.QuadPart == 0) {
     if (request_body_stream_->position() != 0) {
       request_body_stream_.reset(new net::UploadDataStream(upload_data_));
-      const int result = request_body_stream_->Init();
+      const int result = request_body_stream_->InitSync();
       DCHECK_EQ(net::OK, result);
     }
     if (new_pos) {
       new_pos->QuadPart = 0;
     }
     return S_OK;
   }
 
   DCHECK(false) << __FUNCTION__;
   return STG_E_INVALIDFUNCTION;
 }
 
 STDMETHODIMP UrlmonUploadDataStream::Stat(STATSTG *stat_stg,
                                           DWORD grf_stat_flag) {
   if (stat_stg == NULL)
     return E_POINTER;
 
   memset(stat_stg, 0, sizeof(STATSTG));
   if (0 == (grf_stat_flag & STATFLAG_NONAME)) {
     const wchar_t kStreamBuffer[] = L"PostStream";
     stat_stg->pwcsName =
         static_cast<wchar_t*>(::CoTaskMemAlloc(sizeof(kStreamBuffer)));
     lstrcpy(stat_stg->pwcsName, kStreamBuffer);
   }
   stat_stg->type = STGTY_STREAM;
   stat_stg->cbSize.QuadPart = upload_data_->GetContentLengthSync();
   return S_OK;
 }