Index: google_apis/gcm/base/socket_stream.cc |
diff --git a/google_apis/gcm/base/socket_stream.cc b/google_apis/gcm/base/socket_stream.cc |
index 8c152c6c5b3604d8c3f14ee51c8260b54069e8cd..14889e1f1180d3e0b45ba3a1db6d517c7f012697 100644 |
--- a/google_apis/gcm/base/socket_stream.cc |
+++ b/google_apis/gcm/base/socket_stream.cc |
@@ -101,12 +101,12 @@ net::Error SocketInputStream::Refresh(const base::Closure& callback, |
} |
DVLOG(1) << "Refreshing input stream, limit of " << byte_limit << " bytes."; |
- int result = socket_->Read( |
- read_buffer_, |
- byte_limit, |
- base::Bind(&SocketInputStream::RefreshCompletionCallback, |
- weak_ptr_factory_.GetWeakPtr(), |
- callback)); |
+ int result = |
+ socket_->Read(read_buffer_.get(), |
+ byte_limit, |
+ base::Bind(&SocketInputStream::RefreshCompletionCallback, |
+ weak_ptr_factory_.GetWeakPtr(), |
+ callback)); |
DVLOG(1) << "Read returned " << result; |
if (result == net::ERR_IO_PENDING) { |
last_error_ = net::ERR_IO_PENDING; |
@@ -256,12 +256,12 @@ net::Error SocketOutputStream::Flush(const base::Closure& callback) { |
} |
DVLOG(1) << "Flushing " << next_pos_ << " bytes into socket."; |
- int result = socket_->Write( |
- write_buffer_, |
- next_pos_, |
- base::Bind(&SocketOutputStream::FlushCompletionCallback, |
- weak_ptr_factory_.GetWeakPtr(), |
- callback)); |
+ int result = |
+ socket_->Write(write_buffer_.get(), |
+ next_pos_, |
+ base::Bind(&SocketOutputStream::FlushCompletionCallback, |
+ weak_ptr_factory_.GetWeakPtr(), |
+ callback)); |
DVLOG(1) << "Write returned " << result; |
if (result == net::ERR_IO_PENDING) { |
last_error_ = net::ERR_IO_PENDING; |