| OLD | NEW |
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 // OpenSSL binding for SSLClientSocket. The class layout and general principle | 5 // OpenSSL binding for SSLClientSocket. The class layout and general principle |
| 6 // of operation is derived from SSLClientSocketNSS. | 6 // of operation is derived from SSLClientSocketNSS. |
| 7 | 7 |
| 8 #include "net/socket/ssl_client_socket_openssl.h" | 8 #include "net/socket/ssl_client_socket_openssl.h" |
| 9 | 9 |
| 10 #include <openssl/ssl.h> | 10 #include <openssl/ssl.h> |
| (...skipping 374 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 385 const SSLConfig& ssl_config, | 385 const SSLConfig& ssl_config, |
| 386 const SSLClientSocketContext& context) | 386 const SSLClientSocketContext& context) |
| 387 : ALLOW_THIS_IN_INITIALIZER_LIST(buffer_send_callback_( | 387 : ALLOW_THIS_IN_INITIALIZER_LIST(buffer_send_callback_( |
| 388 this, &SSLClientSocketOpenSSL::BufferSendComplete)), | 388 this, &SSLClientSocketOpenSSL::BufferSendComplete)), |
| 389 ALLOW_THIS_IN_INITIALIZER_LIST(buffer_recv_callback_( | 389 ALLOW_THIS_IN_INITIALIZER_LIST(buffer_recv_callback_( |
| 390 this, &SSLClientSocketOpenSSL::BufferRecvComplete)), | 390 this, &SSLClientSocketOpenSSL::BufferRecvComplete)), |
| 391 transport_send_busy_(false), | 391 transport_send_busy_(false), |
| 392 transport_recv_busy_(false), | 392 transport_recv_busy_(false), |
| 393 old_user_connect_callback_(NULL), | 393 old_user_connect_callback_(NULL), |
| 394 old_user_read_callback_(NULL), | 394 old_user_read_callback_(NULL), |
| 395 old_user_write_callback_(NULL), | 395 user_write_callback_(NULL), |
| 396 completed_handshake_(false), | 396 completed_handshake_(false), |
| 397 client_auth_cert_needed_(false), | 397 client_auth_cert_needed_(false), |
| 398 cert_verifier_(context.cert_verifier), | 398 cert_verifier_(context.cert_verifier), |
| 399 ssl_(NULL), | 399 ssl_(NULL), |
| 400 transport_bio_(NULL), | 400 transport_bio_(NULL), |
| 401 transport_(transport_socket), | 401 transport_(transport_socket), |
| 402 host_and_port_(host_and_port), | 402 host_and_port_(host_and_port), |
| 403 ssl_config_(ssl_config), | 403 ssl_config_(ssl_config), |
| 404 trying_cached_session_(false), | 404 trying_cached_session_(false), |
| 405 npn_status_(kNextProtoUnsupported), | 405 npn_status_(kNextProtoUnsupported), |
| (...skipping 219 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 625 user_read_callback_.Reset(); | 625 user_read_callback_.Reset(); |
| 626 user_read_buf_ = NULL; | 626 user_read_buf_ = NULL; |
| 627 user_read_buf_len_ = 0; | 627 user_read_buf_len_ = 0; |
| 628 c.Run(rv); | 628 c.Run(rv); |
| 629 } | 629 } |
| 630 } | 630 } |
| 631 | 631 |
| 632 void SSLClientSocketOpenSSL::DoWriteCallback(int rv) { | 632 void SSLClientSocketOpenSSL::DoWriteCallback(int rv) { |
| 633 // Since Run may result in Write being called, clear |user_write_callback_| | 633 // Since Run may result in Write being called, clear |user_write_callback_| |
| 634 // up front. | 634 // up front. |
| 635 if (old_user_write_callback_) { | 635 OldCompletionCallback* c = user_write_callback_; |
| 636 OldCompletionCallback* c = old_user_write_callback_; | 636 user_write_callback_ = NULL; |
| 637 old_user_write_callback_ = NULL; | 637 user_write_buf_ = NULL; |
| 638 user_write_buf_ = NULL; | 638 user_write_buf_len_ = 0; |
| 639 user_write_buf_len_ = 0; | 639 c->Run(rv); |
| 640 c->Run(rv); | |
| 641 } else { | |
| 642 CompletionCallback c = user_write_callback_; | |
| 643 user_write_callback_.Reset(); | |
| 644 user_write_buf_ = NULL; | |
| 645 user_write_buf_len_ = 0; | |
| 646 c.Run(rv); | |
| 647 } | |
| 648 } | 640 } |
| 649 | 641 |
| 650 // StreamSocket methods | 642 // StreamSocket methods |
| 651 | 643 |
| 652 int SSLClientSocketOpenSSL::Connect(OldCompletionCallback* callback) { | 644 int SSLClientSocketOpenSSL::Connect(OldCompletionCallback* callback) { |
| 653 net_log_.BeginEvent(NetLog::TYPE_SSL_CONNECT, NULL); | 645 net_log_.BeginEvent(NetLog::TYPE_SSL_CONNECT, NULL); |
| 654 | 646 |
| 655 // Set up new ssl object. | 647 // Set up new ssl object. |
| 656 if (!Init()) { | 648 if (!Init()) { |
| 657 int result = ERR_UNEXPECTED; | 649 int result = ERR_UNEXPECTED; |
| (...skipping 55 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 713 // Null all callbacks, delete all buffers. | 705 // Null all callbacks, delete all buffers. |
| 714 transport_send_busy_ = false; | 706 transport_send_busy_ = false; |
| 715 send_buffer_ = NULL; | 707 send_buffer_ = NULL; |
| 716 transport_recv_busy_ = false; | 708 transport_recv_busy_ = false; |
| 717 recv_buffer_ = NULL; | 709 recv_buffer_ = NULL; |
| 718 | 710 |
| 719 old_user_connect_callback_ = NULL; | 711 old_user_connect_callback_ = NULL; |
| 720 user_connect_callback_.Reset(); | 712 user_connect_callback_.Reset(); |
| 721 old_user_read_callback_ = NULL; | 713 old_user_read_callback_ = NULL; |
| 722 user_read_callback_.Reset(); | 714 user_read_callback_.Reset(); |
| 723 old_user_write_callback_ = NULL; | 715 user_write_callback_ = NULL; |
| 724 user_write_callback_.Reset(); | |
| 725 user_read_buf_ = NULL; | 716 user_read_buf_ = NULL; |
| 726 user_read_buf_len_ = 0; | 717 user_read_buf_len_ = 0; |
| 727 user_write_buf_ = NULL; | 718 user_write_buf_ = NULL; |
| 728 user_write_buf_len_ = 0; | 719 user_write_buf_len_ = 0; |
| 729 | 720 |
| 730 server_cert_verify_result_.Reset(); | 721 server_cert_verify_result_.Reset(); |
| 731 completed_handshake_ = false; | 722 completed_handshake_ = false; |
| 732 | 723 |
| 733 client_certs_.clear(); | 724 client_certs_.clear(); |
| 734 client_auth_cert_needed_ = false; | 725 client_auth_cert_needed_ = false; |
| (...skipping 513 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1248 | 1239 |
| 1249 int SSLClientSocketOpenSSL::Write(IOBuffer* buf, | 1240 int SSLClientSocketOpenSSL::Write(IOBuffer* buf, |
| 1250 int buf_len, | 1241 int buf_len, |
| 1251 OldCompletionCallback* callback) { | 1242 OldCompletionCallback* callback) { |
| 1252 user_write_buf_ = buf; | 1243 user_write_buf_ = buf; |
| 1253 user_write_buf_len_ = buf_len; | 1244 user_write_buf_len_ = buf_len; |
| 1254 | 1245 |
| 1255 int rv = DoWriteLoop(OK); | 1246 int rv = DoWriteLoop(OK); |
| 1256 | 1247 |
| 1257 if (rv == ERR_IO_PENDING) { | 1248 if (rv == ERR_IO_PENDING) { |
| 1258 old_user_write_callback_ = callback; | |
| 1259 } else { | |
| 1260 user_write_buf_ = NULL; | |
| 1261 user_write_buf_len_ = 0; | |
| 1262 } | |
| 1263 | |
| 1264 return rv; | |
| 1265 } | |
| 1266 int SSLClientSocketOpenSSL::Write(IOBuffer* buf, | |
| 1267 int buf_len, | |
| 1268 const CompletionCallback& callback) { | |
| 1269 user_write_buf_ = buf; | |
| 1270 user_write_buf_len_ = buf_len; | |
| 1271 | |
| 1272 int rv = DoWriteLoop(OK); | |
| 1273 | |
| 1274 if (rv == ERR_IO_PENDING) { | |
| 1275 user_write_callback_ = callback; | 1249 user_write_callback_ = callback; |
| 1276 } else { | 1250 } else { |
| 1277 user_write_buf_ = NULL; | 1251 user_write_buf_ = NULL; |
| 1278 user_write_buf_len_ = 0; | 1252 user_write_buf_len_ = 0; |
| 1279 } | 1253 } |
| 1280 | 1254 |
| 1281 return rv; | 1255 return rv; |
| 1282 } | 1256 } |
| 1283 | 1257 |
| 1284 int SSLClientSocketOpenSSL::DoWriteLoop(int result) { | 1258 int SSLClientSocketOpenSSL::DoWriteLoop(int result) { |
| (...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1329 net_log_.AddByteTransferEvent(NetLog::TYPE_SSL_SOCKET_BYTES_SENT, rv, | 1303 net_log_.AddByteTransferEvent(NetLog::TYPE_SSL_SOCKET_BYTES_SENT, rv, |
| 1330 user_write_buf_->data()); | 1304 user_write_buf_->data()); |
| 1331 return rv; | 1305 return rv; |
| 1332 } | 1306 } |
| 1333 | 1307 |
| 1334 int err = SSL_get_error(ssl_, rv); | 1308 int err = SSL_get_error(ssl_, rv); |
| 1335 return MapOpenSSLError(err, err_tracer); | 1309 return MapOpenSSLError(err, err_tracer); |
| 1336 } | 1310 } |
| 1337 | 1311 |
| 1338 } // namespace net | 1312 } // namespace net |
| OLD | NEW |