OLD | NEW |
1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file |
2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
4 | 4 |
5 #include "bin/secure_socket.h" | 5 #include "bin/secure_socket.h" |
6 | 6 |
7 #include <errno.h> | 7 #include <errno.h> |
8 #include <fcntl.h> | 8 #include <fcntl.h> |
9 #include <sys/stat.h> | 9 #include <sys/stat.h> |
10 #include <stdio.h> | 10 #include <stdio.h> |
(...skipping 254 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
265 start_validity_date, | 265 start_validity_date, |
266 end_validity_date }; | 266 end_validity_date }; |
267 return Dart_New(x509_class, Dart_Null(), 4, arguments); | 267 return Dart_New(x509_class, Dart_Null(), 4, arguments); |
268 } | 268 } |
269 | 269 |
270 | 270 |
271 void SSLFilter::Init(Dart_Handle dart_this) { | 271 void SSLFilter::Init(Dart_Handle dart_this) { |
272 if (!library_initialized_) { | 272 if (!library_initialized_) { |
273 InitializeLibrary(NULL, "", true, false); | 273 InitializeLibrary(NULL, "", true, false); |
274 } | 274 } |
275 string_start_ = ThrowIfError( | 275 string_start_ = Dart_NewPersistentHandle(DartUtils::NewString("start")); |
276 Dart_NewPersistentHandle(DartUtils::NewString("start"))); | 276 ASSERT(string_start_ != NULL); |
277 string_length_ = ThrowIfError( | 277 string_length_ = Dart_NewPersistentHandle(DartUtils::NewString("length")); |
278 Dart_NewPersistentHandle(DartUtils::NewString("length"))); | 278 ASSERT(string_length_ != NULL); |
279 | 279 |
280 InitializeBuffers(dart_this); | 280 InitializeBuffers(dart_this); |
281 filter_ = memio_CreateIOLayer(kMemioBufferSize); | 281 filter_ = memio_CreateIOLayer(kMemioBufferSize); |
282 } | 282 } |
283 | 283 |
284 | 284 |
285 void SSLFilter::InitializeBuffers(Dart_Handle dart_this) { | 285 void SSLFilter::InitializeBuffers(Dart_Handle dart_this) { |
286 // Create SSLFilter buffers as ExternalUint8Array objects. | 286 // Create SSLFilter buffers as ExternalUint8Array objects. |
287 Dart_Handle dart_buffers_object = ThrowIfError( | 287 Dart_Handle dart_buffers_object = ThrowIfError( |
288 Dart_GetField(dart_this, DartUtils::NewString("buffers"))); | 288 Dart_GetField(dart_this, DartUtils::NewString("buffers"))); |
(...skipping 17 matching lines...) Expand all Loading... |
306 Dart_ThrowException(DartUtils::NewString( | 306 Dart_ThrowException(DartUtils::NewString( |
307 "Invalid encrypted buffer size in _ExternalBuffer")); | 307 "Invalid encrypted buffer size in _ExternalBuffer")); |
308 } | 308 } |
309 buffer_size_ = static_cast<int>(buffer_size); | 309 buffer_size_ = static_cast<int>(buffer_size); |
310 encrypted_buffer_size_ = static_cast<int>(encrypted_buffer_size); | 310 encrypted_buffer_size_ = static_cast<int>(encrypted_buffer_size); |
311 | 311 |
312 | 312 |
313 Dart_Handle data_identifier = DartUtils::NewString("data"); | 313 Dart_Handle data_identifier = DartUtils::NewString("data"); |
314 for (int i = 0; i < kNumBuffers; ++i) { | 314 for (int i = 0; i < kNumBuffers; ++i) { |
315 int size = isEncrypted(i) ? encrypted_buffer_size_ : buffer_size_; | 315 int size = isEncrypted(i) ? encrypted_buffer_size_ : buffer_size_; |
316 dart_buffer_objects_[i] = ThrowIfError( | 316 dart_buffer_objects_[i] = |
317 Dart_NewPersistentHandle(Dart_ListGetAt(dart_buffers_object, i))); | 317 Dart_NewPersistentHandle(Dart_ListGetAt(dart_buffers_object, i)); |
| 318 ASSERT(dart_buffer_objects_[i] != NULL); |
318 buffers_[i] = new uint8_t[size]; | 319 buffers_[i] = new uint8_t[size]; |
319 Dart_Handle data = ThrowIfError( | 320 Dart_Handle data = ThrowIfError( |
320 Dart_NewExternalTypedData(kUint8, buffers_[i], size, NULL, NULL)); | 321 Dart_NewExternalTypedData(kUint8, buffers_[i], size)); |
321 ThrowIfError(Dart_SetField(dart_buffer_objects_[i], | 322 ThrowIfError(Dart_SetField(Dart_NewHandleFromPersistent(dart_buffer_objects_
[i]), |
322 data_identifier, | 323 data_identifier, |
323 data)); | 324 data)); |
324 } | 325 } |
325 } | 326 } |
326 | 327 |
327 | 328 |
328 void SSLFilter::RegisterHandshakeCompleteCallback(Dart_Handle complete) { | 329 void SSLFilter::RegisterHandshakeCompleteCallback(Dart_Handle complete) { |
329 ASSERT(NULL == handshake_complete_); | 330 ASSERT(NULL == handshake_complete_); |
330 handshake_complete_ = ThrowIfError(Dart_NewPersistentHandle(complete)); | 331 handshake_complete_ = Dart_NewPersistentHandle(complete); |
| 332 ASSERT(handshake_complete_ != NULL); |
331 } | 333 } |
332 | 334 |
333 | 335 |
334 void SSLFilter::RegisterBadCertificateCallback(Dart_Handle callback) { | 336 void SSLFilter::RegisterBadCertificateCallback(Dart_Handle callback) { |
335 if (NULL != bad_certificate_callback_) { | 337 if (NULL != bad_certificate_callback_) { |
336 Dart_DeletePersistentHandle(bad_certificate_callback_); | 338 Dart_DeletePersistentHandle(bad_certificate_callback_); |
337 } | 339 } |
338 bad_certificate_callback_ = ThrowIfError(Dart_NewPersistentHandle(callback)); | 340 bad_certificate_callback_ = Dart_NewPersistentHandle(callback); |
| 341 ASSERT(bad_certificate_callback_ != NULL); |
339 } | 342 } |
340 | 343 |
341 static const char* builtin_roots_module = | 344 static const char* builtin_roots_module = |
342 #if defined(TARGET_OS_LINUX) || defined(TARGET_OS_ANDROID) | 345 #if defined(TARGET_OS_LINUX) || defined(TARGET_OS_ANDROID) |
343 "name=\"Root Certs\" library=\"libnssckbi.so\""; | 346 "name=\"Root Certs\" library=\"libnssckbi.so\""; |
344 #elif defined(TARGET_OS_MACOS) | 347 #elif defined(TARGET_OS_MACOS) |
345 "name=\"Root Certs\" library=\"libnssckbi.dylib\""; | 348 "name=\"Root Certs\" library=\"libnssckbi.dylib\""; |
346 #elif defined(TARGET_OS_WINDOWS) | 349 #elif defined(TARGET_OS_WINDOWS) |
347 "name=\"Root Certs\" library=\"nssckbi.dll\""; | 350 "name=\"Root Certs\" library=\"nssckbi.dll\""; |
348 #else | 351 #else |
(...skipping 226 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
575 | 578 |
576 memio_SetPeerName(filter_, &host_address); | 579 memio_SetPeerName(filter_, &host_address); |
577 PR_FreeAddrInfo(info); | 580 PR_FreeAddrInfo(info); |
578 } | 581 } |
579 | 582 |
580 | 583 |
581 void SSLFilter::Handshake() { | 584 void SSLFilter::Handshake() { |
582 SECStatus status = SSL_ForceHandshake(filter_); | 585 SECStatus status = SSL_ForceHandshake(filter_); |
583 if (status == SECSuccess) { | 586 if (status == SECSuccess) { |
584 if (in_handshake_) { | 587 if (in_handshake_) { |
585 ThrowIfError(Dart_InvokeClosure(handshake_complete_, 0, NULL)); | 588 ThrowIfError(Dart_InvokeClosure(Dart_NewHandleFromPersistent(handshake_com
plete_), 0, NULL)); |
586 in_handshake_ = false; | 589 in_handshake_ = false; |
587 } | 590 } |
588 } else { | 591 } else { |
589 PRErrorCode error = PR_GetError(); | 592 PRErrorCode error = PR_GetError(); |
590 if (error == PR_WOULD_BLOCK_ERROR) { | 593 if (error == PR_WOULD_BLOCK_ERROR) { |
591 if (!in_handshake_) { | 594 if (!in_handshake_) { |
592 in_handshake_ = true; | 595 in_handshake_ = true; |
593 } | 596 } |
594 } else { | 597 } else { |
595 if (is_server_) { | 598 if (is_server_) { |
(...skipping 18 matching lines...) Expand all Loading... |
614 Dart_DeletePersistentHandle(bad_certificate_callback_); | 617 Dart_DeletePersistentHandle(bad_certificate_callback_); |
615 } | 618 } |
616 free(client_certificate_name_); | 619 free(client_certificate_name_); |
617 | 620 |
618 PR_Close(filter_); | 621 PR_Close(filter_); |
619 } | 622 } |
620 | 623 |
621 | 624 |
622 intptr_t SSLFilter::ProcessBuffer(int buffer_index) { | 625 intptr_t SSLFilter::ProcessBuffer(int buffer_index) { |
623 int size = isEncrypted(buffer_index) ? encrypted_buffer_size_ : buffer_size_; | 626 int size = isEncrypted(buffer_index) ? encrypted_buffer_size_ : buffer_size_; |
624 Dart_Handle buffer_object = dart_buffer_objects_[buffer_index]; | 627 Dart_Handle buffer_object = Dart_NewHandleFromPersistent(dart_buffer_objects_[
buffer_index]); |
625 Dart_Handle start_object = ThrowIfError( | 628 Dart_Handle start_object = ThrowIfError( |
626 Dart_GetField(buffer_object, string_start_)); | 629 Dart_GetField(buffer_object, Dart_NewHandleFromPersistent(string_start_)))
; |
627 Dart_Handle length_object = ThrowIfError( | 630 Dart_Handle length_object = ThrowIfError( |
628 Dart_GetField(buffer_object, string_length_)); | 631 Dart_GetField(buffer_object, Dart_NewHandleFromPersistent(string_length_))
); |
629 int64_t unsafe_start = DartUtils::GetIntegerValue(start_object); | 632 int64_t unsafe_start = DartUtils::GetIntegerValue(start_object); |
630 int64_t unsafe_length = DartUtils::GetIntegerValue(length_object); | 633 int64_t unsafe_length = DartUtils::GetIntegerValue(length_object); |
631 ASSERT(unsafe_start >= 0); | 634 ASSERT(unsafe_start >= 0); |
632 ASSERT(unsafe_start < size); | 635 ASSERT(unsafe_start < size); |
633 ASSERT(unsafe_length >= 0); | 636 ASSERT(unsafe_length >= 0); |
634 ASSERT(unsafe_length <= size); | 637 ASSERT(unsafe_length <= size); |
635 int start = static_cast<int>(unsafe_start); | 638 int start = static_cast<int>(unsafe_start); |
636 int length = static_cast<int>(unsafe_length); | 639 int length = static_cast<int>(unsafe_length); |
637 uint8_t* buffer = buffers_[buffer_index]; | 640 uint8_t* buffer = buffers_[buffer_index]; |
638 | 641 |
(...skipping 75 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
714 bytes_processed = 0; | 717 bytes_processed = 0; |
715 } | 718 } |
716 break; | 719 break; |
717 } | 720 } |
718 } | 721 } |
719 return bytes_processed; | 722 return bytes_processed; |
720 } | 723 } |
721 | 724 |
722 } // namespace bin | 725 } // namespace bin |
723 } // namespace dart | 726 } // namespace dart |
OLD | NEW |