OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 #include "ppapi/native_client/src/trusted/plugin/pnacl_coordinator.h" | 5 #include "ppapi/native_client/src/trusted/plugin/pnacl_coordinator.h" |
6 | 6 |
7 #include <utility> | 7 #include <utility> |
8 #include <vector> | 8 #include <vector> |
9 | 9 |
10 #include "native_client/src/include/checked_cast.h" | 10 #include "native_client/src/include/checked_cast.h" |
(...skipping 323 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
334 translate_notify_callback_.Run(PP_ERROR_FAILED); | 334 translate_notify_callback_.Run(PP_ERROR_FAILED); |
335 } else { | 335 } else { |
336 PLUGIN_PRINTF(("PnaclCoordinator::ExitWithError an earlier error was " | 336 PLUGIN_PRINTF(("PnaclCoordinator::ExitWithError an earlier error was " |
337 "already reported -- Skipping.\n")); | 337 "already reported -- Skipping.\n")); |
338 } | 338 } |
339 } | 339 } |
340 | 340 |
341 // Signal that Pnacl translation completed normally. | 341 // Signal that Pnacl translation completed normally. |
342 void PnaclCoordinator::TranslateFinished(int32_t pp_error) { | 342 void PnaclCoordinator::TranslateFinished(int32_t pp_error) { |
343 PLUGIN_PRINTF(("PnaclCoordinator::TranslateFinished (pp_error=%" | 343 PLUGIN_PRINTF(("PnaclCoordinator::TranslateFinished (pp_error=%" |
344 NACL_PRId32")\n", pp_error)); | 344 NACL_PRId32 ")\n", pp_error)); |
345 // Bail out if there was an earlier error (e.g., pexe load failure). | 345 // Bail out if there was an earlier error (e.g., pexe load failure). |
346 if (translate_finish_error_ != PP_OK) { | 346 if (translate_finish_error_ != PP_OK) { |
347 ExitWithError(); | 347 ExitWithError(); |
348 return; | 348 return; |
349 } | 349 } |
350 // Bail out if there is an error from the translation thread. | 350 // Bail out if there is an error from the translation thread. |
351 if (pp_error != PP_OK) { | 351 if (pp_error != PP_OK) { |
352 ExitWithError(); | 352 ExitWithError(); |
353 return; | 353 return; |
354 } | 354 } |
(...skipping 113 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
468 char buf[kCopyBufSize]; | 468 char buf[kCopyBufSize]; |
469 int32_t num_read = | 469 int32_t num_read = |
470 nacl::assert_cast<int32_t>(read_wrapper->Read(buf, sizeof buf)); | 470 nacl::assert_cast<int32_t>(read_wrapper->Read(buf, sizeof buf)); |
471 // Hit EOF or something. | 471 // Hit EOF or something. |
472 if (num_read == 0) { | 472 if (num_read == 0) { |
473 NexeWasCopiedToCache(PP_OK); | 473 NexeWasCopiedToCache(PP_OK); |
474 return; | 474 return; |
475 } | 475 } |
476 if (num_read < 0) { | 476 if (num_read < 0) { |
477 PLUGIN_PRINTF(("PnaclCoordinator::CachedNexeOpenedForWrite read failed " | 477 PLUGIN_PRINTF(("PnaclCoordinator::CachedNexeOpenedForWrite read failed " |
478 "(error=%"NACL_PRId32")\n", num_read)); | 478 "(error=%" NACL_PRId32 ")\n", num_read)); |
479 NexeWasCopiedToCache(PP_ERROR_FAILED); | 479 NexeWasCopiedToCache(PP_ERROR_FAILED); |
480 return; | 480 return; |
481 } | 481 } |
482 pp::CompletionCallback cb = callback_factory_.NewCallback( | 482 pp::CompletionCallback cb = callback_factory_.NewCallback( |
483 &PnaclCoordinator::DidCopyNexeToCachePartial, num_read, cur_offset); | 483 &PnaclCoordinator::DidCopyNexeToCachePartial, num_read, cur_offset); |
484 cached_nexe_file_->write_file_io()->Write(cur_offset, buf, num_read, cb); | 484 cached_nexe_file_->write_file_io()->Write(cur_offset, buf, num_read, cb); |
485 } | 485 } |
486 | 486 |
487 void PnaclCoordinator::DidCopyNexeToCachePartial(int32_t pp_error, | 487 void PnaclCoordinator::DidCopyNexeToCachePartial(int32_t pp_error, |
488 int32_t num_read_prev, | 488 int32_t num_read_prev, |
489 int64_t cur_offset) { | 489 int64_t cur_offset) { |
490 PLUGIN_PRINTF(("PnaclCoordinator::DidCopyNexeToCachePartial " | 490 PLUGIN_PRINTF(("PnaclCoordinator::DidCopyNexeToCachePartial " |
491 "(pp_error=%"NACL_PRId32", num_read_prev=%"NACL_PRId32"" | 491 "(pp_error=%" NACL_PRId32 ", num_read_prev=%" NACL_PRId32 |
492 ", cur_offset=%"NACL_PRId64").\n", | 492 ", cur_offset=%" NACL_PRId64 ").\n", |
493 pp_error, num_read_prev, cur_offset)); | 493 pp_error, num_read_prev, cur_offset)); |
494 // Assume we are done. | 494 // Assume we are done. |
495 if (pp_error == PP_OK) { | 495 if (pp_error == PP_OK) { |
496 NexeWasCopiedToCache(PP_OK); | 496 NexeWasCopiedToCache(PP_OK); |
497 return; | 497 return; |
498 } | 498 } |
499 if (pp_error < PP_OK) { | 499 if (pp_error < PP_OK) { |
500 PLUGIN_PRINTF(("PnaclCoordinator::DidCopyNexeToCachePartial failed (err=%" | 500 PLUGIN_PRINTF(("PnaclCoordinator::DidCopyNexeToCachePartial failed (err=%" |
501 NACL_PRId32")\n", pp_error)); | 501 NACL_PRId32 ")\n", pp_error)); |
502 NexeWasCopiedToCache(pp_error); | 502 NexeWasCopiedToCache(pp_error); |
503 return; | 503 return; |
504 } | 504 } |
505 | 505 |
506 // Check if we wrote as much as we read. | 506 // Check if we wrote as much as we read. |
507 nacl::DescWrapper* read_wrapper = temp_nexe_file_->read_wrapper(); | 507 nacl::DescWrapper* read_wrapper = temp_nexe_file_->read_wrapper(); |
508 if (pp_error != num_read_prev) { | 508 if (pp_error != num_read_prev) { |
509 PLUGIN_PRINTF(("PnaclCoordinator::DidCopyNexeToCachePartial partial " | 509 PLUGIN_PRINTF(("PnaclCoordinator::DidCopyNexeToCachePartial partial " |
510 "write (bytes_written=%"NACL_PRId32" vs " | 510 "write (bytes_written=%" NACL_PRId32 " vs " |
511 "read=%"NACL_PRId32")\n", pp_error, num_read_prev)); | 511 "read=%" NACL_PRId32 ")\n", pp_error, num_read_prev)); |
512 CHECK(pp_error < num_read_prev); | 512 CHECK(pp_error < num_read_prev); |
513 // Seek back to re-read the bytes that were not written. | 513 // Seek back to re-read the bytes that were not written. |
514 nacl_off64_t seek_result = | 514 nacl_off64_t seek_result = |
515 read_wrapper->Seek(pp_error - num_read_prev, SEEK_CUR); | 515 read_wrapper->Seek(pp_error - num_read_prev, SEEK_CUR); |
516 if (seek_result < 0) { | 516 if (seek_result < 0) { |
517 PLUGIN_PRINTF(("PnaclCoordinator::DidCopyNexeToCachePartial seek failed " | 517 PLUGIN_PRINTF(("PnaclCoordinator::DidCopyNexeToCachePartial seek failed " |
518 "(err=%"NACL_PRId64")\n", seek_result)); | 518 "(err=%" NACL_PRId64 ")\n", seek_result)); |
519 NexeWasCopiedToCache(PP_ERROR_FAILED); | 519 NexeWasCopiedToCache(PP_ERROR_FAILED); |
520 return; | 520 return; |
521 } | 521 } |
522 } | 522 } |
523 | 523 |
524 int64_t next_offset = cur_offset + pp_error; | 524 int64_t next_offset = cur_offset + pp_error; |
525 char buf[kCopyBufSize]; | 525 char buf[kCopyBufSize]; |
526 int32_t num_read = | 526 int32_t num_read = |
527 nacl::assert_cast<int32_t>(read_wrapper->Read(buf, sizeof buf)); | 527 nacl::assert_cast<int32_t>(read_wrapper->Read(buf, sizeof buf)); |
528 PLUGIN_PRINTF(("PnaclCoordinator::DidCopyNexeToCachePartial read (bytes=%" | 528 PLUGIN_PRINTF(("PnaclCoordinator::DidCopyNexeToCachePartial read (bytes=%" |
529 NACL_PRId32")\n", num_read)); | 529 NACL_PRId32 ")\n", num_read)); |
530 // Hit EOF or something. | 530 // Hit EOF or something. |
531 if (num_read == 0) { | 531 if (num_read == 0) { |
532 NexeWasCopiedToCache(PP_OK); | 532 NexeWasCopiedToCache(PP_OK); |
533 return; | 533 return; |
534 } | 534 } |
535 if (num_read < 0) { | 535 if (num_read < 0) { |
536 PLUGIN_PRINTF(("PnaclCoordinator::DidCopyNexeToCachePartial read failed " | 536 PLUGIN_PRINTF(("PnaclCoordinator::DidCopyNexeToCachePartial read failed " |
537 "(error=%"NACL_PRId32")\n", num_read)); | 537 "(error=%" NACL_PRId32 ")\n", num_read)); |
538 NexeWasCopiedToCache(PP_ERROR_FAILED); | 538 NexeWasCopiedToCache(PP_ERROR_FAILED); |
539 return; | 539 return; |
540 } | 540 } |
541 pp::CompletionCallback cb = callback_factory_.NewCallback( | 541 pp::CompletionCallback cb = callback_factory_.NewCallback( |
542 &PnaclCoordinator::DidCopyNexeToCachePartial, num_read, next_offset); | 542 &PnaclCoordinator::DidCopyNexeToCachePartial, num_read, next_offset); |
543 PLUGIN_PRINTF(("PnaclCoordinator::CopyNexeToCache Writing (" | 543 PLUGIN_PRINTF(("PnaclCoordinator::CopyNexeToCache Writing (" |
544 "bytes=%"NACL_PRId32", buf=%p, file_io=%p)\n", num_read, buf, | 544 "bytes=%" NACL_PRId32 ", buf=%p, file_io=%p)\n", num_read, buf, |
545 cached_nexe_file_->write_file_io())); | 545 cached_nexe_file_->write_file_io())); |
546 cached_nexe_file_->write_file_io()->Write(next_offset, buf, num_read, cb); | 546 cached_nexe_file_->write_file_io()->Write(next_offset, buf, num_read, cb); |
547 } | 547 } |
548 | 548 |
549 void PnaclCoordinator::NexeWasCopiedToCache(int32_t pp_error) { | 549 void PnaclCoordinator::NexeWasCopiedToCache(int32_t pp_error) { |
550 if (pp_error != PP_OK) { | 550 if (pp_error != PP_OK) { |
551 // Try to delete the partially written not-yet-committed cache file before | 551 // Try to delete the partially written not-yet-committed cache file before |
552 // returning. We pass the current pp_error along so that it can be reported | 552 // returning. We pass the current pp_error along so that it can be reported |
553 // before returning. | 553 // before returning. |
554 pp::CompletionCallback cb = callback_factory_.NewCallback( | 554 pp::CompletionCallback cb = callback_factory_.NewCallback( |
555 &PnaclCoordinator::CorruptCacheFileWasDeleted, pp_error); | 555 &PnaclCoordinator::CorruptCacheFileWasDeleted, pp_error); |
556 cached_nexe_file_->Delete(cb); | 556 cached_nexe_file_->Delete(cb); |
557 return; | 557 return; |
558 } | 558 } |
559 // Rename the cached_nexe_file_ file to the cache id, to finalize. | 559 // Rename the cached_nexe_file_ file to the cache id, to finalize. |
560 pp::CompletionCallback cb = | 560 pp::CompletionCallback cb = |
561 callback_factory_.NewCallback(&PnaclCoordinator::NexeFileWasRenamed); | 561 callback_factory_.NewCallback(&PnaclCoordinator::NexeFileWasRenamed); |
562 cached_nexe_file_->Rename(pnacl_options_.GetCacheKey(), cb); | 562 cached_nexe_file_->Rename(pnacl_options_.GetCacheKey(), cb); |
563 } | 563 } |
564 | 564 |
565 void PnaclCoordinator::CorruptCacheFileWasDeleted(int32_t delete_pp_error, | 565 void PnaclCoordinator::CorruptCacheFileWasDeleted(int32_t delete_pp_error, |
566 int32_t orig_pp_error) { | 566 int32_t orig_pp_error) { |
567 if (delete_pp_error != PP_OK) { | 567 if (delete_pp_error != PP_OK) { |
568 // The cache file was certainly already opened by the time we tried | 568 // The cache file was certainly already opened by the time we tried |
569 // to write to it, so it should certainly be deletable. | 569 // to write to it, so it should certainly be deletable. |
570 PLUGIN_PRINTF(("PnaclCoordinator::CorruptCacheFileWasDeleted " | 570 PLUGIN_PRINTF(("PnaclCoordinator::CorruptCacheFileWasDeleted " |
571 "delete failed with pp_error=%"NACL_PRId32"\n", | 571 "delete failed with pp_error=%" NACL_PRId32 "\n", |
572 delete_pp_error)); | 572 delete_pp_error)); |
573 // fall through and report the original error. | 573 // fall through and report the original error. |
574 } | 574 } |
575 // Report the original error that caused us to consider the | 575 // Report the original error that caused us to consider the |
576 // cache file corrupted. | 576 // cache file corrupted. |
577 if (orig_pp_error == PP_ERROR_NOQUOTA) { | 577 if (orig_pp_error == PP_ERROR_NOQUOTA) { |
578 ReportPpapiError(ERROR_PNACL_CACHE_FINALIZE_COPY_NOQUOTA, | 578 ReportPpapiError(ERROR_PNACL_CACHE_FINALIZE_COPY_NOQUOTA, |
579 orig_pp_error, | 579 orig_pp_error, |
580 "Failed to copy translated nexe to cache (no quota)."); | 580 "Failed to copy translated nexe to cache (no quota)."); |
581 return; | 581 return; |
582 } | 582 } |
583 if (orig_pp_error == PP_ERROR_NOSPACE) { | 583 if (orig_pp_error == PP_ERROR_NOSPACE) { |
584 ReportPpapiError(ERROR_PNACL_CACHE_FINALIZE_COPY_NOSPACE, | 584 ReportPpapiError(ERROR_PNACL_CACHE_FINALIZE_COPY_NOSPACE, |
585 orig_pp_error, | 585 orig_pp_error, |
586 "Failed to copy translated nexe to cache (no space)."); | 586 "Failed to copy translated nexe to cache (no space)."); |
587 return; | 587 return; |
588 } | 588 } |
589 ReportPpapiError(ERROR_PNACL_CACHE_FINALIZE_COPY_OTHER, | 589 ReportPpapiError(ERROR_PNACL_CACHE_FINALIZE_COPY_OTHER, |
590 orig_pp_error, | 590 orig_pp_error, |
591 "Failed to copy translated nexe to cache."); | 591 "Failed to copy translated nexe to cache."); |
592 return; | 592 return; |
593 } | 593 } |
594 | 594 |
595 void PnaclCoordinator::NexeFileWasRenamed(int32_t pp_error) { | 595 void PnaclCoordinator::NexeFileWasRenamed(int32_t pp_error) { |
596 PLUGIN_PRINTF(("PnaclCoordinator::NexeFileWasRenamed (pp_error=%" | 596 PLUGIN_PRINTF(("PnaclCoordinator::NexeFileWasRenamed (pp_error=%" |
597 NACL_PRId32")\n", pp_error)); | 597 NACL_PRId32 ")\n", pp_error)); |
598 if (pp_error != PP_OK) { | 598 if (pp_error != PP_OK) { |
599 if (pp_error == PP_ERROR_NOACCESS) { | 599 if (pp_error == PP_ERROR_NOACCESS) { |
600 ReportPpapiError(ERROR_PNACL_CACHE_FINALIZE_RENAME_NOACCESS, | 600 ReportPpapiError(ERROR_PNACL_CACHE_FINALIZE_RENAME_NOACCESS, |
601 pp_error, | 601 pp_error, |
602 "Failed to finalize cached translation (no access)."); | 602 "Failed to finalize cached translation (no access)."); |
603 return; | 603 return; |
604 } else if (pp_error != PP_ERROR_FILEEXISTS) { | 604 } else if (pp_error != PP_ERROR_FILEEXISTS) { |
605 ReportPpapiError(ERROR_PNACL_CACHE_FINALIZE_RENAME_OTHER, | 605 ReportPpapiError(ERROR_PNACL_CACHE_FINALIZE_RENAME_OTHER, |
606 pp_error, | 606 pp_error, |
607 "Failed to finalize cached translation."); | 607 "Failed to finalize cached translation."); |
(...skipping 20 matching lines...) Expand all Loading... |
628 total_time / 1000000.0); | 628 total_time / 1000000.0); |
629 | 629 |
630 // Open the cache file for reading. | 630 // Open the cache file for reading. |
631 pp::CompletionCallback cb = | 631 pp::CompletionCallback cb = |
632 callback_factory_.NewCallback(&PnaclCoordinator::NexeReadDidOpen); | 632 callback_factory_.NewCallback(&PnaclCoordinator::NexeReadDidOpen); |
633 cached_nexe_file_->OpenRead(cb); | 633 cached_nexe_file_->OpenRead(cb); |
634 } | 634 } |
635 | 635 |
636 void PnaclCoordinator::NexeReadDidOpen(int32_t pp_error) { | 636 void PnaclCoordinator::NexeReadDidOpen(int32_t pp_error) { |
637 PLUGIN_PRINTF(("PnaclCoordinator::NexeReadDidOpen (pp_error=%" | 637 PLUGIN_PRINTF(("PnaclCoordinator::NexeReadDidOpen (pp_error=%" |
638 NACL_PRId32")\n", pp_error)); | 638 NACL_PRId32 ")\n", pp_error)); |
639 if (pp_error != PP_OK) { | 639 if (pp_error != PP_OK) { |
640 if (pp_error == PP_ERROR_FILENOTFOUND) { | 640 if (pp_error == PP_ERROR_FILENOTFOUND) { |
641 ReportPpapiError(ERROR_PNACL_CACHE_FETCH_NOTFOUND, | 641 ReportPpapiError(ERROR_PNACL_CACHE_FETCH_NOTFOUND, |
642 pp_error, | 642 pp_error, |
643 "Failed to open translated nexe (not found)."); | 643 "Failed to open translated nexe (not found)."); |
644 return; | 644 return; |
645 } | 645 } |
646 if (pp_error == PP_ERROR_NOACCESS) { | 646 if (pp_error == PP_ERROR_NOACCESS) { |
647 ReportPpapiError(ERROR_PNACL_CACHE_FETCH_NOACCESS, | 647 ReportPpapiError(ERROR_PNACL_CACHE_FETCH_NOACCESS, |
648 pp_error, | 648 pp_error, |
(...skipping 10 matching lines...) Expand all Loading... |
659 if (cached_nexe_file_ != NULL) { | 659 if (cached_nexe_file_ != NULL) { |
660 translated_fd_.reset(cached_nexe_file_->release_read_wrapper()); | 660 translated_fd_.reset(cached_nexe_file_->release_read_wrapper()); |
661 } else { | 661 } else { |
662 translated_fd_.reset(temp_nexe_file_->release_read_wrapper()); | 662 translated_fd_.reset(temp_nexe_file_->release_read_wrapper()); |
663 } | 663 } |
664 translate_notify_callback_.Run(pp_error); | 664 translate_notify_callback_.Run(pp_error); |
665 } | 665 } |
666 | 666 |
667 void PnaclCoordinator::ResourceInfoWasRead(int32_t pp_error) { | 667 void PnaclCoordinator::ResourceInfoWasRead(int32_t pp_error) { |
668 PLUGIN_PRINTF(("PluginCoordinator::ResourceInfoWasRead (pp_error=%" | 668 PLUGIN_PRINTF(("PluginCoordinator::ResourceInfoWasRead (pp_error=%" |
669 NACL_PRId32")\n", pp_error)); | 669 NACL_PRId32 ")\n", pp_error)); |
670 // Second step of loading resources: call StartLoad. | 670 // Second step of loading resources: call StartLoad. |
671 pp::CompletionCallback resources_cb = | 671 pp::CompletionCallback resources_cb = |
672 callback_factory_.NewCallback(&PnaclCoordinator::ResourcesDidLoad); | 672 callback_factory_.NewCallback(&PnaclCoordinator::ResourcesDidLoad); |
673 resources_->StartLoad(resources_cb); | 673 resources_->StartLoad(resources_cb); |
674 } | 674 } |
675 | 675 |
676 void PnaclCoordinator::ResourcesDidLoad(int32_t pp_error) { | 676 void PnaclCoordinator::ResourcesDidLoad(int32_t pp_error) { |
677 PLUGIN_PRINTF(("PnaclCoordinator::ResourcesDidLoad (pp_error=%" | 677 PLUGIN_PRINTF(("PnaclCoordinator::ResourcesDidLoad (pp_error=%" |
678 NACL_PRId32")\n", pp_error)); | 678 NACL_PRId32 ")\n", pp_error)); |
679 if (pp_error != PP_OK) { | 679 if (pp_error != PP_OK) { |
680 // Finer-grained error code should have already been reported by | 680 // Finer-grained error code should have already been reported by |
681 // the PnaclResources class. | 681 // the PnaclResources class. |
682 return; | 682 return; |
683 } | 683 } |
684 | 684 |
685 if (!off_the_record_) { | 685 if (!off_the_record_) { |
686 if (use_new_cache_) { | 686 if (use_new_cache_) { |
687 OpenBitcodeStream(); | 687 OpenBitcodeStream(); |
688 } else { | 688 } else { |
(...skipping 21 matching lines...) Expand all Loading... |
710 } | 710 } |
711 } | 711 } |
712 } else { | 712 } else { |
713 // We don't have a cache, so do the non-cached codepath. | 713 // We don't have a cache, so do the non-cached codepath. |
714 OpenBitcodeStream(); | 714 OpenBitcodeStream(); |
715 } | 715 } |
716 } | 716 } |
717 | 717 |
718 void PnaclCoordinator::FileSystemDidOpen(int32_t pp_error) { | 718 void PnaclCoordinator::FileSystemDidOpen(int32_t pp_error) { |
719 PLUGIN_PRINTF(("PnaclCoordinator::FileSystemDidOpen (pp_error=%" | 719 PLUGIN_PRINTF(("PnaclCoordinator::FileSystemDidOpen (pp_error=%" |
720 NACL_PRId32")\n", pp_error)); | 720 NACL_PRId32 ")\n", pp_error)); |
721 if (pp_error != PP_OK) { | 721 if (pp_error != PP_OK) { |
722 if (pp_error == PP_ERROR_NOACCESS) { | 722 if (pp_error == PP_ERROR_NOACCESS) { |
723 ReportPpapiError( | 723 ReportPpapiError( |
724 ERROR_PNACL_CACHE_OPEN_NOACCESS, | 724 ERROR_PNACL_CACHE_OPEN_NOACCESS, |
725 pp_error, | 725 pp_error, |
726 "File system for PNaCl translation cache failed to open " | 726 "File system for PNaCl translation cache failed to open " |
727 "(no access)."); | 727 "(no access)."); |
728 return; | 728 return; |
729 } | 729 } |
730 if (pp_error == PP_ERROR_NOQUOTA) { | 730 if (pp_error == PP_ERROR_NOQUOTA) { |
(...skipping 18 matching lines...) Expand all Loading... |
749 } | 749 } |
750 dir_ref_.reset(new pp::FileRef(*file_system_, kPnaclTempDir)); | 750 dir_ref_.reset(new pp::FileRef(*file_system_, kPnaclTempDir)); |
751 // Attempt to create the directory. | 751 // Attempt to create the directory. |
752 pp::CompletionCallback cb = | 752 pp::CompletionCallback cb = |
753 callback_factory_.NewCallback(&PnaclCoordinator::DirectoryWasCreated); | 753 callback_factory_.NewCallback(&PnaclCoordinator::DirectoryWasCreated); |
754 dir_ref_->MakeDirectory(cb); | 754 dir_ref_->MakeDirectory(cb); |
755 } | 755 } |
756 | 756 |
757 void PnaclCoordinator::DirectoryWasCreated(int32_t pp_error) { | 757 void PnaclCoordinator::DirectoryWasCreated(int32_t pp_error) { |
758 PLUGIN_PRINTF(("PnaclCoordinator::DirectoryWasCreated (pp_error=%" | 758 PLUGIN_PRINTF(("PnaclCoordinator::DirectoryWasCreated (pp_error=%" |
759 NACL_PRId32")\n", pp_error)); | 759 NACL_PRId32 ")\n", pp_error)); |
760 if (pp_error != PP_ERROR_FILEEXISTS && pp_error != PP_OK) { | 760 if (pp_error != PP_ERROR_FILEEXISTS && pp_error != PP_OK) { |
761 // Directory did not exist and could not be created. | 761 // Directory did not exist and could not be created. |
762 if (pp_error == PP_ERROR_NOACCESS) { | 762 if (pp_error == PP_ERROR_NOACCESS) { |
763 ReportPpapiError( | 763 ReportPpapiError( |
764 ERROR_PNACL_CACHE_DIRECTORY_CREATE, | 764 ERROR_PNACL_CACHE_DIRECTORY_CREATE, |
765 pp_error, | 765 pp_error, |
766 "PNaCl translation cache directory creation/check failed " | 766 "PNaCl translation cache directory creation/check failed " |
767 "(no access)."); | 767 "(no access)."); |
768 return; | 768 return; |
769 } | 769 } |
(...skipping 101 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
871 cached_nexe_file_->OpenRead(cb); | 871 cached_nexe_file_->OpenRead(cb); |
872 } | 872 } |
873 } else { | 873 } else { |
874 // No cache case. | 874 // No cache case. |
875 CachedFileDidOpen(PP_ERROR_FAILED); | 875 CachedFileDidOpen(PP_ERROR_FAILED); |
876 } | 876 } |
877 } | 877 } |
878 | 878 |
879 void PnaclCoordinator::NexeFdDidOpen(int32_t pp_error) { | 879 void PnaclCoordinator::NexeFdDidOpen(int32_t pp_error) { |
880 PLUGIN_PRINTF(("PnaclCoordinator::NexeFdDidOpen (pp_error=%" | 880 PLUGIN_PRINTF(("PnaclCoordinator::NexeFdDidOpen (pp_error=%" |
881 NACL_PRId32", hit=%d, handle=%d)\n", pp_error, | 881 NACL_PRId32 ", hit=%d, handle=%d)\n", pp_error, |
882 is_cache_hit_ == PP_TRUE, | 882 is_cache_hit_ == PP_TRUE, |
883 nexe_handle_)); | 883 nexe_handle_)); |
884 if (pp_error < PP_OK) { | 884 if (pp_error < PP_OK) { |
885 ReportPpapiError(ERROR_PNACL_CREATE_TEMP, pp_error, | 885 ReportPpapiError(ERROR_PNACL_CREATE_TEMP, pp_error, |
886 nacl::string("GetNexeFd failed")); | 886 nacl::string("GetNexeFd failed")); |
887 return; | 887 return; |
888 } | 888 } |
889 temp_nexe_file_.reset(new TempFile(plugin_)); | 889 temp_nexe_file_.reset(new TempFile(plugin_)); |
890 if (!temp_nexe_file_->SetExistingFd(nexe_handle_)) { | 890 if (!temp_nexe_file_->SetExistingFd(nexe_handle_)) { |
891 ReportNonPpapiError( | 891 ReportNonPpapiError( |
(...skipping 24 matching lines...) Expand all Loading... |
916 // will begin handing data to the coordinator, which is safe any time after | 916 // will begin handing data to the coordinator, which is safe any time after |
917 // the translate_thread_ object has been initialized). | 917 // the translate_thread_ object has been initialized). |
918 pp::CompletionCallback finish_cb = callback_factory_.NewCallback( | 918 pp::CompletionCallback finish_cb = callback_factory_.NewCallback( |
919 &PnaclCoordinator::BitcodeStreamDidFinish); | 919 &PnaclCoordinator::BitcodeStreamDidFinish); |
920 streaming_downloader_->FinishStreaming(finish_cb); | 920 streaming_downloader_->FinishStreaming(finish_cb); |
921 } | 921 } |
922 } | 922 } |
923 | 923 |
924 void PnaclCoordinator::CachedFileDidOpen(int32_t pp_error) { | 924 void PnaclCoordinator::CachedFileDidOpen(int32_t pp_error) { |
925 PLUGIN_PRINTF(("PnaclCoordinator::CachedFileDidOpen (pp_error=%" | 925 PLUGIN_PRINTF(("PnaclCoordinator::CachedFileDidOpen (pp_error=%" |
926 NACL_PRId32")\n", pp_error)); | 926 NACL_PRId32 ")\n", pp_error)); |
927 if (pp_error == PP_OK) { | 927 if (pp_error == PP_OK) { |
928 // Cache hit -- no need to stream the rest of the file. | 928 // Cache hit -- no need to stream the rest of the file. |
929 streaming_downloader_.reset(NULL); | 929 streaming_downloader_.reset(NULL); |
930 HistogramEnumerateTranslationCache(true); | 930 HistogramEnumerateTranslationCache(true); |
931 NexeReadDidOpen(PP_OK); | 931 NexeReadDidOpen(PP_OK); |
932 return; | 932 return; |
933 } | 933 } |
934 // Otherwise, the cache file is missing so we must translate. | 934 // Otherwise, the cache file is missing so we must translate. |
935 HistogramEnumerateTranslationCache(false); | 935 HistogramEnumerateTranslationCache(false); |
936 | 936 |
937 // Continue streaming. | 937 // Continue streaming. |
938 pp::CompletionCallback cb = | 938 pp::CompletionCallback cb = |
939 callback_factory_.NewCallback(&PnaclCoordinator::BitcodeStreamDidFinish); | 939 callback_factory_.NewCallback(&PnaclCoordinator::BitcodeStreamDidFinish); |
940 streaming_downloader_->FinishStreaming(cb); | 940 streaming_downloader_->FinishStreaming(cb); |
941 } | 941 } |
942 | 942 |
943 void PnaclCoordinator::BitcodeStreamDidFinish(int32_t pp_error) { | 943 void PnaclCoordinator::BitcodeStreamDidFinish(int32_t pp_error) { |
944 PLUGIN_PRINTF(("PnaclCoordinator::BitcodeStreamDidFinish (pp_error=%" | 944 PLUGIN_PRINTF(("PnaclCoordinator::BitcodeStreamDidFinish (pp_error=%" |
945 NACL_PRId32")\n", pp_error)); | 945 NACL_PRId32 ")\n", pp_error)); |
946 if (pp_error != PP_OK) { | 946 if (pp_error != PP_OK) { |
947 // Defer reporting the error and cleanup until after the translation | 947 // Defer reporting the error and cleanup until after the translation |
948 // thread returns, because it may be accessing the coordinator's | 948 // thread returns, because it may be accessing the coordinator's |
949 // objects or writing to the files. | 949 // objects or writing to the files. |
950 translate_finish_error_ = pp_error; | 950 translate_finish_error_ = pp_error; |
951 if (pp_error == PP_ERROR_ABORTED) { | 951 if (pp_error == PP_ERROR_ABORTED) { |
952 error_info_.SetReport(ERROR_PNACL_PEXE_FETCH_ABORTED, | 952 error_info_.SetReport(ERROR_PNACL_PEXE_FETCH_ABORTED, |
953 "PnaclCoordinator: pexe load failed (aborted)."); | 953 "PnaclCoordinator: pexe load failed (aborted)."); |
954 } | 954 } |
955 if (pp_error == PP_ERROR_NOACCESS) { | 955 if (pp_error == PP_ERROR_NOACCESS) { |
956 error_info_.SetReport(ERROR_PNACL_PEXE_FETCH_NOACCESS, | 956 error_info_.SetReport(ERROR_PNACL_PEXE_FETCH_NOACCESS, |
957 "PnaclCoordinator: pexe load failed (no access)."); | 957 "PnaclCoordinator: pexe load failed (no access)."); |
958 } else { | 958 } else { |
959 nacl::stringstream ss; | 959 nacl::stringstream ss; |
960 ss << "PnaclCoordinator: pexe load failed (pp_error=" << pp_error << ")."; | 960 ss << "PnaclCoordinator: pexe load failed (pp_error=" << pp_error << ")."; |
961 error_info_.SetReport(ERROR_PNACL_PEXE_FETCH_OTHER, ss.str()); | 961 error_info_.SetReport(ERROR_PNACL_PEXE_FETCH_OTHER, ss.str()); |
962 } | 962 } |
963 translate_thread_->AbortSubprocesses(); | 963 translate_thread_->AbortSubprocesses(); |
964 } else { | 964 } else { |
965 // Compare download completion pct (100% now), to compile completion pct. | 965 // Compare download completion pct (100% now), to compile completion pct. |
966 HistogramRatio("NaCl.Perf.PNaClLoadTime.PctCompiledWhenFullyDownloaded", | 966 HistogramRatio("NaCl.Perf.PNaClLoadTime.PctCompiledWhenFullyDownloaded", |
967 pexe_bytes_compiled_, pexe_size_); | 967 pexe_bytes_compiled_, pexe_size_); |
968 } | 968 } |
969 } | 969 } |
970 | 970 |
971 void PnaclCoordinator::BitcodeStreamGotData(int32_t pp_error, | 971 void PnaclCoordinator::BitcodeStreamGotData(int32_t pp_error, |
972 FileStreamData data) { | 972 FileStreamData data) { |
973 PLUGIN_PRINTF(("PnaclCoordinator::BitcodeStreamGotData (pp_error=%" | 973 PLUGIN_PRINTF(("PnaclCoordinator::BitcodeStreamGotData (pp_error=%" |
974 NACL_PRId32", data=%p)\n", pp_error, data ? &(*data)[0] : 0)); | 974 NACL_PRId32 ", data=%p)\n", pp_error, data ? &(*data)[0] : 0)); |
975 DCHECK(translate_thread_.get()); | 975 DCHECK(translate_thread_.get()); |
976 | 976 |
977 translate_thread_->PutBytes(data, pp_error); | 977 translate_thread_->PutBytes(data, pp_error); |
978 // If pp_error > 0, then it represents the number of bytes received. | 978 // If pp_error > 0, then it represents the number of bytes received. |
979 if (data && pp_error > 0) { | 979 if (data && pp_error > 0) { |
980 pexe_size_ += pp_error; | 980 pexe_size_ += pp_error; |
981 } | 981 } |
982 } | 982 } |
983 | 983 |
984 StreamCallback PnaclCoordinator::GetCallback() { | 984 StreamCallback PnaclCoordinator::GetCallback() { |
(...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1022 } | 1022 } |
1023 | 1023 |
1024 void PnaclCoordinator::GetCurrentProgress(int64_t* bytes_loaded, | 1024 void PnaclCoordinator::GetCurrentProgress(int64_t* bytes_loaded, |
1025 int64_t* bytes_total) { | 1025 int64_t* bytes_total) { |
1026 *bytes_loaded = pexe_bytes_compiled_; | 1026 *bytes_loaded = pexe_bytes_compiled_; |
1027 *bytes_total = expected_pexe_size_; | 1027 *bytes_total = expected_pexe_size_; |
1028 } | 1028 } |
1029 | 1029 |
1030 void PnaclCoordinator::ObjectFileDidOpen(int32_t pp_error) { | 1030 void PnaclCoordinator::ObjectFileDidOpen(int32_t pp_error) { |
1031 PLUGIN_PRINTF(("PnaclCoordinator::ObjectFileDidOpen (pp_error=%" | 1031 PLUGIN_PRINTF(("PnaclCoordinator::ObjectFileDidOpen (pp_error=%" |
1032 NACL_PRId32")\n", pp_error)); | 1032 NACL_PRId32 ")\n", pp_error)); |
1033 if (pp_error != PP_OK) { | 1033 if (pp_error != PP_OK) { |
1034 ReportPpapiError(ERROR_PNACL_CREATE_TEMP, | 1034 ReportPpapiError(ERROR_PNACL_CREATE_TEMP, |
1035 pp_error, | 1035 pp_error, |
1036 "Failed to open scratch object file."); | 1036 "Failed to open scratch object file."); |
1037 return; | 1037 return; |
1038 } | 1038 } |
1039 // Open the nexe file for connecting ld and sel_ldr. | 1039 // Open the nexe file for connecting ld and sel_ldr. |
1040 // Start translation when done with this last step of setup! | 1040 // Start translation when done with this last step of setup! |
1041 if (!use_new_cache_) | 1041 if (!use_new_cache_) |
1042 // In the new cache case, the TempFile has already been created. | 1042 // In the new cache case, the TempFile has already been created. |
1043 temp_nexe_file_.reset(new TempFile(plugin_)); | 1043 temp_nexe_file_.reset(new TempFile(plugin_)); |
1044 | 1044 |
1045 pp::CompletionCallback cb = | 1045 pp::CompletionCallback cb = |
1046 callback_factory_.NewCallback(&PnaclCoordinator::RunTranslate); | 1046 callback_factory_.NewCallback(&PnaclCoordinator::RunTranslate); |
1047 temp_nexe_file_->Open(cb, true); | 1047 temp_nexe_file_->Open(cb, true); |
1048 } | 1048 } |
1049 | 1049 |
1050 void PnaclCoordinator::RunTranslate(int32_t pp_error) { | 1050 void PnaclCoordinator::RunTranslate(int32_t pp_error) { |
1051 PLUGIN_PRINTF(("PnaclCoordinator::RunTranslate (pp_error=%" | 1051 PLUGIN_PRINTF(("PnaclCoordinator::RunTranslate (pp_error=%" |
1052 NACL_PRId32")\n", pp_error)); | 1052 NACL_PRId32 ")\n", pp_error)); |
1053 // Invoke llc followed by ld off the main thread. This allows use of | 1053 // Invoke llc followed by ld off the main thread. This allows use of |
1054 // blocking RPCs that would otherwise block the JavaScript main thread. | 1054 // blocking RPCs that would otherwise block the JavaScript main thread. |
1055 pp::CompletionCallback report_translate_finished = | 1055 pp::CompletionCallback report_translate_finished = |
1056 callback_factory_.NewCallback(&PnaclCoordinator::TranslateFinished); | 1056 callback_factory_.NewCallback(&PnaclCoordinator::TranslateFinished); |
1057 | 1057 |
1058 CHECK(translate_thread_ != NULL); | 1058 CHECK(translate_thread_ != NULL); |
1059 translate_thread_->RunTranslate(report_translate_finished, | 1059 translate_thread_->RunTranslate(report_translate_finished, |
1060 manifest_.get(), | 1060 manifest_.get(), |
1061 obj_file_.get(), | 1061 obj_file_.get(), |
1062 temp_nexe_file_.get(), | 1062 temp_nexe_file_.get(), |
1063 &error_info_, | 1063 &error_info_, |
1064 resources_.get(), | 1064 resources_.get(), |
1065 &pnacl_options_, | 1065 &pnacl_options_, |
1066 this, | 1066 this, |
1067 plugin_); | 1067 plugin_); |
1068 } | 1068 } |
1069 | 1069 |
1070 } // namespace plugin | 1070 } // namespace plugin |
OLD | NEW |