Index: net/socket/ssl_client_socket_openssl.cc |
diff --git a/net/socket/ssl_client_socket_openssl.cc b/net/socket/ssl_client_socket_openssl.cc |
index 12373488f909af5960292cfc2973a70e07a2679d..ea3b629fcecc48f4756657bcafa50cc020085eb8 100644 |
--- a/net/socket/ssl_client_socket_openssl.cc |
+++ b/net/socket/ssl_client_socket_openssl.cc |
@@ -392,7 +392,7 @@ SSLClientSocketOpenSSL::SSLClientSocketOpenSSL( |
transport_recv_busy_(false), |
old_user_connect_callback_(NULL), |
old_user_read_callback_(NULL), |
- user_write_callback_(NULL), |
+ old_user_write_callback_(NULL), |
completed_handshake_(false), |
client_auth_cert_needed_(false), |
cert_verifier_(context.cert_verifier), |
@@ -632,11 +632,19 @@ void SSLClientSocketOpenSSL::DoReadCallback(int rv) { |
void SSLClientSocketOpenSSL::DoWriteCallback(int rv) { |
// Since Run may result in Write being called, clear |user_write_callback_| |
// up front. |
- OldCompletionCallback* c = user_write_callback_; |
- user_write_callback_ = NULL; |
- user_write_buf_ = NULL; |
- user_write_buf_len_ = 0; |
- c->Run(rv); |
+ if (old_user_write_callback_) { |
+ OldCompletionCallback* c = old_user_write_callback_; |
+ old_user_write_callback_ = NULL; |
+ user_write_buf_ = NULL; |
+ user_write_buf_len_ = 0; |
+ c->Run(rv); |
+ } else { |
+ CompletionCallback c = user_write_callback_; |
+ user_write_callback_.Reset(); |
+ user_write_buf_ = NULL; |
+ user_write_buf_len_ = 0; |
+ c.Run(rv); |
+ } |
} |
// StreamSocket methods |
@@ -712,7 +720,8 @@ void SSLClientSocketOpenSSL::Disconnect() { |
user_connect_callback_.Reset(); |
old_user_read_callback_ = NULL; |
user_read_callback_.Reset(); |
- user_write_callback_ = NULL; |
+ old_user_write_callback_ = NULL; |
+ user_write_callback_.Reset(); |
user_read_buf_ = NULL; |
user_read_buf_len_ = 0; |
user_write_buf_ = NULL; |
@@ -1246,6 +1255,23 @@ int SSLClientSocketOpenSSL::Write(IOBuffer* buf, |
int rv = DoWriteLoop(OK); |
if (rv == ERR_IO_PENDING) { |
+ old_user_write_callback_ = callback; |
+ } else { |
+ user_write_buf_ = NULL; |
+ user_write_buf_len_ = 0; |
+ } |
+ |
+ return rv; |
+} |
+int SSLClientSocketOpenSSL::Write(IOBuffer* buf, |
+ int buf_len, |
+ const CompletionCallback& callback) { |
+ user_write_buf_ = buf; |
+ user_write_buf_len_ = buf_len; |
+ |
+ int rv = DoWriteLoop(OK); |
+ |
+ if (rv == ERR_IO_PENDING) { |
user_write_callback_ = callback; |
} else { |
user_write_buf_ = NULL; |