| 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;
|
|
|