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 "vm/snapshot.h" | 5 #include "vm/snapshot.h" |
6 | 6 |
7 #include "platform/assert.h" | 7 #include "platform/assert.h" |
8 #include "vm/bootstrap.h" | 8 #include "vm/bootstrap.h" |
9 #include "vm/class_finalizer.h" | 9 #include "vm/class_finalizer.h" |
10 #include "vm/dart.h" | 10 #include "vm/dart.h" |
(...skipping 555 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
566 index -= max_vm_isolate_object_id_; | 566 index -= max_vm_isolate_object_id_; |
567 if (index < backward_references_->length()) { | 567 if (index < backward_references_->length()) { |
568 return (*backward_references_)[index].reference(); | 568 return (*backward_references_)[index].reference(); |
569 } | 569 } |
570 return NULL; | 570 return NULL; |
571 } | 571 } |
572 | 572 |
573 | 573 |
574 class HeapLocker : public StackResource { | 574 class HeapLocker : public StackResource { |
575 public: | 575 public: |
576 HeapLocker(Isolate* isolate, PageSpace* page_space) | 576 HeapLocker(Thread* thread, PageSpace* page_space) |
577 : StackResource(isolate), page_space_(page_space) { | 577 : StackResource(thread), page_space_(page_space) { |
578 page_space_->AcquireDataLock(); | 578 page_space_->AcquireDataLock(); |
579 } | 579 } |
580 ~HeapLocker() { | 580 ~HeapLocker() { |
581 page_space_->ReleaseDataLock(); | 581 page_space_->ReleaseDataLock(); |
582 } | 582 } |
583 | 583 |
584 private: | 584 private: |
585 PageSpace* page_space_; | 585 PageSpace* page_space_; |
586 }; | 586 }; |
587 | 587 |
588 | 588 |
589 RawApiError* SnapshotReader::ReadFullSnapshot() { | 589 RawApiError* SnapshotReader::ReadFullSnapshot() { |
590 ASSERT(kind_ == Snapshot::kFull); | 590 ASSERT(kind_ == Snapshot::kFull); |
591 Isolate* isolate = Isolate::Current(); | 591 Thread* thread = Thread::Current(); |
| 592 Isolate* isolate = thread->isolate(); |
592 ASSERT(isolate != NULL); | 593 ASSERT(isolate != NULL); |
593 ObjectStore* object_store = isolate->object_store(); | 594 ObjectStore* object_store = isolate->object_store(); |
594 ASSERT(object_store != NULL); | 595 ASSERT(object_store != NULL); |
595 | 596 |
596 // First read the version string, and check that it matches. | 597 // First read the version string, and check that it matches. |
597 RawApiError* error = VerifyVersion(); | 598 RawApiError* error = VerifyVersion(); |
598 if (error != ApiError::null()) { | 599 if (error != ApiError::null()) { |
599 return error; | 600 return error; |
600 } | 601 } |
601 | 602 |
602 // The version string matches. Read the rest of the snapshot. | 603 // The version string matches. Read the rest of the snapshot. |
603 | 604 |
604 // TODO(asiva): Add a check here to ensure we have the right heap | 605 // TODO(asiva): Add a check here to ensure we have the right heap |
605 // size for the full snapshot being read. | 606 // size for the full snapshot being read. |
606 { | 607 { |
607 NoSafepointScope no_safepoint; | 608 NoSafepointScope no_safepoint; |
608 HeapLocker hl(isolate, old_space()); | 609 HeapLocker hl(thread, old_space()); |
609 | 610 |
610 // Read in all the objects stored in the object store. | 611 // Read in all the objects stored in the object store. |
611 RawObject** toobj = snapshot_code() ? object_store->to() | 612 RawObject** toobj = snapshot_code() ? object_store->to() |
612 : object_store->to_snapshot(); | 613 : object_store->to_snapshot(); |
613 intptr_t num_flds = (toobj - object_store->from()); | 614 intptr_t num_flds = (toobj - object_store->from()); |
614 for (intptr_t i = 0; i <= num_flds; i++) { | 615 for (intptr_t i = 0; i <= num_flds; i++) { |
615 *(object_store->from() + i) = ReadObjectImpl(kAsInlinedObject); | 616 *(object_store->from() + i) = ReadObjectImpl(kAsInlinedObject); |
616 } | 617 } |
617 for (intptr_t i = 0; i < backward_references_->length(); i++) { | 618 for (intptr_t i = 0; i < backward_references_->length(); i++) { |
618 if (!(*backward_references_)[i].is_deserialized()) { | 619 if (!(*backward_references_)[i].is_deserialized()) { |
(...skipping 846 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1465 Object::vm_isolate_snapshot_object_table().SetAt( | 1466 Object::vm_isolate_snapshot_object_table().SetAt( |
1466 i, *(backrefs->At(i).reference())); | 1467 i, *(backrefs->At(i).reference())); |
1467 } | 1468 } |
1468 ResetBackwardReferenceTable(); | 1469 ResetBackwardReferenceTable(); |
1469 Dart::set_instructions_snapshot_buffer(instructions_buffer_); | 1470 Dart::set_instructions_snapshot_buffer(instructions_buffer_); |
1470 } | 1471 } |
1471 | 1472 |
1472 | 1473 |
1473 RawApiError* VmIsolateSnapshotReader::ReadVmIsolateSnapshot() { | 1474 RawApiError* VmIsolateSnapshotReader::ReadVmIsolateSnapshot() { |
1474 ASSERT(kind() == Snapshot::kFull); | 1475 ASSERT(kind() == Snapshot::kFull); |
1475 Isolate* isolate = Isolate::Current(); | 1476 Thread* thread = Thread::Current(); |
| 1477 Isolate* isolate = thread->isolate(); |
1476 ASSERT(isolate != NULL); | 1478 ASSERT(isolate != NULL); |
1477 ASSERT(isolate == Dart::vm_isolate()); | 1479 ASSERT(isolate == Dart::vm_isolate()); |
1478 ObjectStore* object_store = isolate->object_store(); | 1480 ObjectStore* object_store = isolate->object_store(); |
1479 ASSERT(object_store != NULL); | 1481 ASSERT(object_store != NULL); |
1480 | 1482 |
1481 // First read the version string, and check that it matches. | 1483 // First read the version string, and check that it matches. |
1482 RawApiError* error = VerifyVersion(); | 1484 RawApiError* error = VerifyVersion(); |
1483 if (error != ApiError::null()) { | 1485 if (error != ApiError::null()) { |
1484 return error; | 1486 return error; |
1485 } | 1487 } |
1486 | 1488 |
1487 // The version string matches. Read the rest of the snapshot. | 1489 // The version string matches. Read the rest of the snapshot. |
1488 | 1490 |
1489 { | 1491 { |
1490 NoSafepointScope no_safepoint; | 1492 NoSafepointScope no_safepoint; |
1491 HeapLocker hl(isolate, old_space()); | 1493 HeapLocker hl(thread, old_space()); |
1492 | 1494 |
1493 // Read in the symbol table. | 1495 // Read in the symbol table. |
1494 object_store->symbol_table_ = reinterpret_cast<RawArray*>(ReadObject()); | 1496 object_store->symbol_table_ = reinterpret_cast<RawArray*>(ReadObject()); |
1495 | 1497 |
1496 Symbols::InitOnceFromSnapshot(isolate); | 1498 Symbols::InitOnceFromSnapshot(isolate); |
1497 | 1499 |
1498 // Read in all the script objects and the accompanying token streams | 1500 // Read in all the script objects and the accompanying token streams |
1499 // for bootstrap libraries so that they are in the VM isolate's read | 1501 // for bootstrap libraries so that they are in the VM isolate's read |
1500 // only memory. | 1502 // only memory. |
1501 *(ArrayHandle()) ^= ReadObject(); | 1503 *(ArrayHandle()) ^= ReadObject(); |
(...skipping 1051 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2553 if (setjmp(*jump.Set()) == 0) { | 2555 if (setjmp(*jump.Set()) == 0) { |
2554 NoSafepointScope no_safepoint; | 2556 NoSafepointScope no_safepoint; |
2555 WriteObject(obj.raw()); | 2557 WriteObject(obj.raw()); |
2556 } else { | 2558 } else { |
2557 ThrowException(exception_type(), exception_msg()); | 2559 ThrowException(exception_type(), exception_msg()); |
2558 } | 2560 } |
2559 } | 2561 } |
2560 | 2562 |
2561 | 2563 |
2562 } // namespace dart | 2564 } // namespace dart |
OLD | NEW |