Loading...
common/ProcessAtlas.cpp dyld-1042.1 dyld-1162
--- dyld/dyld-1042.1/common/ProcessAtlas.cpp
+++ dyld/dyld-1162/common/ProcessAtlas.cpp
@@ -24,6 +24,8 @@
 
 #include <TargetConditionals.h>
 
+#if !TARGET_OS_EXCLAVEKIT
+
 #include <atomic>
 #include <cstring>
 #include <Block.h>
@@ -39,8 +41,8 @@
 #include <sys/stat.h>
 #include <sys/fsgetpath.h>
 
+#include <mach/mach_time.h> // mach_absolute_time()
 #include <mach/mach_vm.h>
-#include <mach/mach_time.h> // mach_absolute_time()
 #include <mach-o/dyld_priv.h> // FIXME: We can remove this once we fully integrate into dyld4
 #include "dyld_cache_format.h"
 //FIXME: We should remove this header
@@ -131,6 +133,15 @@
         std::copy(&data[0], &data[byteSize], &bitmap[0]);
     });
     data = data.last(data.size()-byteSize);
+}
+
+Bitmap::Bitmap(Bitmap&& other) {
+    swap(other);
+}
+
+Bitmap& Bitmap::operator=(Bitmap&& other) {
+    swap(other);
+    return *this;
 }
 
 void Bitmap::setBit(size_t bit) {
@@ -579,11 +590,14 @@
 #if BUILDING_DYLD
 Image::Image(RuntimeState* state, Allocator& ephemeralAllocator, SharedPtr<Mapper>& mapper, const Loader* ldr)
     :   _ephemeralAllocator(ephemeralAllocator), _mapper(mapper), _rebasedAddress((void*)ldr->loadAddress(*state)) {
-        auto fileID = ldr->fileID(state->fileManager);
+        auto fileID = ldr->fileID(*state);
         if (fileID.inode() &&  fileID.device()) {
-            _file = state->fileManager.fileRecordForFileID(ldr->fileID(state->fileManager));
+            _file = state->fileManager.fileRecordForFileID(ldr->fileID(*state));
+            if ( _file.volume().empty() ) {
+                _file = state->fileManager.fileRecordForPath(ephemeralAllocator, ldr->path());
+            }
         } else {
-            _file = state->fileManager.fileRecordForPath(ldr->path());
+            _file = state->fileManager.fileRecordForPath(ephemeralAllocator, ldr->path());
         }
     }
 #endif
@@ -612,24 +626,32 @@
     using std::swap;
 
     if (this == &other) { return; }
-    std::swap(_uuid,                other._uuid);
-    std::swap(_ml,                  other._ml);
-    std::swap(_sharedCacheSlide,    other._sharedCacheSlide);
-    std::swap(_rebasedAddress,      other._rebasedAddress);
-    std::swap(_mapper,              other._mapper);
-    std::swap(_sharedCache,         other._sharedCache);
-    std::swap(_installname,         other._installname);
-    std::swap(_file,                other._file);
-    std::swap(_uuidLoaded,          other._uuidLoaded);
-    std::swap(_installnameLoaded,   other._installnameLoaded);
+    swap(_uuid,                 other._uuid);
+    swap(_ml,                   other._ml);
+    swap(_sharedCacheSlide,     other._sharedCacheSlide);
+    swap(_rebasedAddress,       other._rebasedAddress);
+    swap(_mapper,               other._mapper);
+    swap(_sharedCache,          other._sharedCache);
+    swap(_installname,          other._installname);
+    swap(_file,                 other._file);
+    swap(_uuidLoaded,           other._uuidLoaded);
+    swap(_installnameLoaded,    other._installnameLoaded);
+    swap(_mapperFailed,         other._mapperFailed);
 }
 
 const MachOLoaded* Image::ml() const {
-    void* slidML = (void*)rebasedAddress();
+    if (_mapperFailed) {
+        return nullptr;
+    }
     if (!_ml) {
+        void* slidML = (void*)rebasedAddress();
         // Note, using 4k here as we might be an arm64e process inspecting an x86_64 image, which uses 4k pages
+        if (!_mapper && !_mapperFailed) {
+            _mapper = Mapper::mapperForMachO(_transactionalAllocator, _file, _uuid, _rebasedAddress);
+        }
         if (!_mapper) {
-            _mapper = Mapper::mapperForMachO(_transactionalAllocator, _file, _uuid, _rebasedAddress);
+            _mapperFailed = true;
+            return nullptr;
         }
         _ml = _mapper->map<MachOLoaded>(slidML, 4096);
         size_t size = _ml->sizeofcmds;
@@ -651,7 +673,7 @@
     if (!_uuidLoaded) {
         uuid_t fileUUID;
         const MachOLoaded* mh = ml();
-        if (mh->hasMachOMagic()) {
+        if (mh && mh->hasMachOMagic()) {
             if (mh->getUuid(fileUUID))
                 _uuid = UUID(fileUUID);
         }
@@ -667,7 +689,9 @@
 
 const char* Image::installname() const {
     if (!_installnameLoaded) {
-        _installname = ml()->installName();
+        if (ml()) {
+            _installname = ml()->installName();
+        }
         _installnameLoaded = true;
     }
     return _installname;
@@ -690,10 +714,12 @@
 }
 
 uint32_t Image::pointerSize() {
+    if (!ml()) { return 0; }
     return ml()->pointerSize();
 }
 
 bool Image::forEachSegment(void (^block)(const char* segmentName, uint64_t vmAddr, uint64_t vmSize, int perm)) {
+    if (!ml()) { return false; }
     __block uint64_t slide = (uint64_t)_rebasedAddress - ml()->preferredLoadAddress();
     ml()->forEachSegment(^(const MachOLoaded::SegmentInfo &info, bool &stop) {
         uint64_t vmAddr = 0x0;
@@ -712,6 +738,7 @@
 }
 
 bool Image::forEachSection(void (^block)(const char* segmentName, const char* sectionName, uint64_t vmAddr, uint64_t vmSize)) {
+    if (!ml()) { return false; }
     __block uint64_t slide = (uint64_t)_rebasedAddress - ml()->preferredLoadAddress();
     ml()->forEachSection(^(const MachOLoaded::SectionInfo &info, bool malformedSectionRange, bool &stop) {
         uint64_t sectAddr = 0x0;
@@ -726,6 +753,7 @@
 }
 
 bool Image::contentForSegment(const char* segmentName, void (^contentReader)(const void* content, uint64_t vmAddr, uint64_t vmSize)) {
+    if (!ml()) { return false; }
     __block bool result = false;
     __block uint64_t slide = (uint64_t)_rebasedAddress - ml()->preferredLoadAddress();
     ml()->forEachSegment(^(const MachOLoaded::SegmentInfo &info, bool &stop) {
@@ -931,7 +959,7 @@
                     continue;
 
                 // FIXME: The memory managemnt here is awful, fix with allocators
-                auto cacheFile = fileManager.fileRecordForPath(cachePath);
+                auto cacheFile = fileManager.fileRecordForPath(_ephemeralAllocator, cachePath);
                 auto cache = Atlas::SharedCache::createForFileRecord(_ephemeralAllocator, std::move(cacheFile));
                 if (cache) {
                     cache.withUnsafe([&](auto cachePtr){
@@ -1052,7 +1080,7 @@
             return nullptr;
     }
     // TODO: Create Path extension helpers for FileRecord
-    auto localSymbolsCacheFile = _file.fileManager().fileRecordForPath(localSymbolsCachePath);
+    auto localSymbolsCacheFile = _file.fileManager().fileRecordForPath(_ephemeralAllocator, localSymbolsCachePath);
     auto [fileMapper, baseAddress] = Mapper::mapperForSharedCacheLocals(_ephemeralAllocator, localSymbolsCacheFile);
     if (!fileMapper) { return nullptr; }
     // Use placement new since operator new is not available
@@ -1243,7 +1271,7 @@
                     executablePath[len] = '\0';
                 }
                 SharedPtr<Mapper> mapper = nullptr;
-                auto file = _fileManager.fileRecordForPath(executablePath);
+                auto file = _fileManager.fileRecordForPath(_transactionalAllocator, executablePath);
                 uuid_t rawUUID;
                 mf->getUuid(rawUUID);
                 auto uuid = UUID(rawUUID);
@@ -1255,7 +1283,7 @@
                     executablePath[len] = '\0';
                 }
                 SharedPtr<Mapper> mapper = nullptr;
-                auto file = _fileManager.fileRecordForPath(executablePath);
+                auto file = _fileManager.fileRecordForPath(_transactionalAllocator, executablePath);
                 uuid_t rawUUID;
                 mf->getUuid(rawUUID);
                 auto uuid = UUID(rawUUID);
@@ -1577,7 +1605,7 @@
         if (!serializer.deserialize(data)) {
             // Deerialization failed, reset the snapshot and mark invalid
             _images.clear();
-            _bitmap             = Bitmap();
+            _bitmap             = nullptr;
             _sharedCache        = nullptr;
             _platform           = 0;
             _initialImageCount  = 0;
@@ -1600,7 +1628,7 @@
         if (processedCacheImages) { return; }
         processedCacheImages = true;
         for (auto i = 0; i < _sharedCache->imageCount(); ++i) {
-            if (!_bitmap.checkBit(i)) { continue; }
+            if (!_bitmap->checkBit(i)) { continue; }
             _sharedCache->withImageForIndex(i, ^(Image *image) {
                 block(image);
             });
@@ -1623,8 +1651,8 @@
         if (processedCacheImages) { return; }
         if (!_sharedCache) { return; }
         for (auto i = 0; i < _sharedCache->imageCount(); ++i) {
-            if (!_bitmap.checkBit(i)) { continue; }
-            if (other._sharedCache && other._bitmap.checkBit(i)) { continue; }
+            if (!_bitmap->checkBit(i)) { continue; }
+            if (other._sharedCache && other._bitmap->checkBit(i)) { continue; }
             _sharedCache->withImageForIndex(i, ^(Image *image) {
                 block(image);
             });
@@ -1666,7 +1694,7 @@
 void ProcessSnapshot::addImages(RuntimeState* state, const std::span<const Loader*>& loaders) {
     for (auto& ldr : loaders) {
         if (_sharedCache && ldr->dylibInDyldCache) {
-            _bitmap.setBit(ldr->ref.index);
+            _bitmap->setBit(ldr->ref.index);
         } else {
             _images.insert(_transactionalAllocator.makeUnique<Image>(state, _ephemeralAllocator, identityMapper(), ldr));
         }
@@ -1688,7 +1716,7 @@
 #if BUILDING_DYLD || BUILDING_UNIT_TESTS
 void ProcessSnapshot::addSharedCache(SharedCache&& sharedCache) {
     _sharedCache = _transactionalAllocator.makeUnique<SharedCache>(std::move(sharedCache));
-    _bitmap = Bitmap(_transactionalAllocator, _sharedCache->imageCount());
+    _bitmap = _transactionalAllocator.makeUnique<Bitmap>(_transactionalAllocator, _sharedCache->imageCount());
 }
 
 void ProcessSnapshot::addSharedCacheImage(const struct mach_header* mh) {
@@ -1701,7 +1729,7 @@
         return (other.loadAddress == ((uint64_t)mh-slide));
     });
     assert(i != images.end());
-    _bitmap.setBit(i-images.begin());
+    _bitmap->setBit(i-images.begin());
 }
 
 
@@ -1860,7 +1888,7 @@
     }
 }
 
-void ProcessSnapshot::Serializer::readMappedFileInfo(std::span<std::byte>& data, uint64_t& rebasedAddress, UUID& uuid, FileRecord& file) {
+bool ProcessSnapshot::Serializer::readMappedFileInfo(std::span<std::byte>& data, uint64_t& rebasedAddress, UUID& uuid, FileRecord& file) {
     uint64_t flags = readPVLEUInt64(data);
     rebasedAddress = readPVLEUInt64(data);
     if (flags & kMappedFileFlagsHasUUID) {
@@ -1870,12 +1898,17 @@
     if (flags & kMappedFileFlagsHasFileID) {
         uint64_t volumeIndex = readPVLEUInt64(data);
         uint64_t objectID = readPVLEUInt64(data);
+        if (volumeIndex >= _volumeUUIDs.size() )
+            return false;
         file = _fileManager.fileRecordForVolumeUUIDAndObjID(_volumeUUIDs[(size_t)volumeIndex], objectID);
     }
     if (flags & kMappedFileFlagsHasFilePath) {
         uint64_t pathOffset = readPVLEUInt64(data);
-        file = _fileManager.fileRecordForPath(&_stringTableBuffer[(size_t)pathOffset]);
-    }
+        if ( pathOffset >= _stringTableBuffer.size() )
+            return false;
+        file = _fileManager.fileRecordForPath(_ephemeralAllocator, &_stringTableBuffer[(size_t)pathOffset]);
+    }
+    return true;
 }
 
 Vector<std::byte> ProcessSnapshot::Serializer::serialize() {
@@ -1883,6 +1916,7 @@
     _genCount++;
     auto result = Vector<std::byte>(_ephemeralAllocator);
     // We need unique all the strings and UUIDs and place them in sorted tables
+    // FIXME: We should use vectors and sort them since it faster in pathological cases, but we need a non-allocating sort
     OrderedSet<const char*, lsl::ConstCharStarCompare>   stringSet(_ephemeralAllocator);
     OrderedSet<UUID>                                     volumeUUIDSet(_ephemeralAllocator);
     if (PAGE_SIZE == 16384) {
@@ -1905,7 +1939,7 @@
         if (file.persistent()) {
             volumeUUIDSet.insert(file.volume());
         } else if (auto filePath = file.getPath()) {
-            stringSet.insert(file.getPath());
+            stringSet.insert(filePath);
         } else {
             stringSet.insert("???");
         }
@@ -1948,7 +1982,7 @@
     if (_processFlags & kProcessFlagsHasSharedCache) {
         uint64_t address = _sharedCache->rebasedAddress()/((_processFlags & kProcessFlagsHas16kPages) ? 16384 : 4096);
         emitMappedFileInfo(address, _sharedCache->uuid(), _sharedCache->file(), result);
-        _bitmap.emit(result);
+        _bitmap->emit(result);
     }
 
     emitPVLEUInt64(_images.size(), result);
@@ -1978,17 +2012,17 @@
     _timestamp          = read<uint64_t>(i);
     _crc32c             = read<uint32_t>(i);
     if (_magic != kMagic) {
-        assert(0);
+        return false;
     }
     if (_version != 0) {
-        assert(0);
+        return false;
     }
     CRC32c checksumer;
     checksumer(std::span(&data[0], 32));
     checksumer((uint32_t)0); // Zero out the actual checksum
     checksumer(std::span(&data[36], data.size() - 36));
     if (_crc32c != checksumer) {
-        assert(0);
+        return false;
     }
     _processFlags           = readPVLEUInt64(i);
     _platform               = readPVLEUInt64(i);
@@ -2009,7 +2043,8 @@
         uint64_t rebasedAddress;
         UUID uuid;
         FileRecord file;
-        readMappedFileInfo(i, rebasedAddress, uuid, file);
+        if ( !readMappedFileInfo(i, rebasedAddress, uuid, file) )
+            return false;
         rebasedAddress = rebasedAddress * ((_processFlags & kProcessFlagsHas16kPages) ? 16384 : 4096);
         SharedPtr<Mapper> mapper = nullptr;
         if (_processSnapshot._useIdentityMapper) {
@@ -2027,7 +2062,7 @@
 
         _sharedCache = _transactionalAllocator.makeUnique<SharedCache>(_ephemeralAllocator, std::move(file), mapper,
                                                                        rebasedAddress, _processFlags & kProcessFlagsHasPrivateCache);
-        _bitmap = Bitmap(_transactionalAllocator, i);
+        _bitmap = _transactionalAllocator.makeUnique<Bitmap>(_transactionalAllocator, i);
     }
     auto imageCount = readPVLEUInt64(i);
     uint64_t lastAddress = 0;
@@ -2035,22 +2070,19 @@
         uint64_t rebasedAddress;
         UUID uuid;
         FileRecord file;
-        readMappedFileInfo(i, rebasedAddress, uuid, file);
+        if ( !readMappedFileInfo(i, rebasedAddress, uuid, file) )
+            return false;
         rebasedAddress = (rebasedAddress * ((_processFlags & kProcessFlagsHas16kPages) ? 16384 : 4096)) + lastAddress;
         lastAddress = rebasedAddress;
         SharedPtr<Mapper> mapper = nullptr;
         if (_processSnapshot._useIdentityMapper) {
             mapper = _processSnapshot.identityMapper();
-        } else {
+        }
 #if BUILDING_DYLD || BUILDING_UNIT_TESTS
+        else {
             mapper = _transactionalAllocator.makeShared<Mapper>(_transactionalAllocator);
-#else
-            mapper = Mapper::mapperForMachO(_transactionalAllocator, file, uuid, (const void*)rebasedAddress);
+        }
 #endif
-        }
-        if (!mapper) {
-            return false;
-        }
         auto image = Image(_ephemeralAllocator, std::move(file), mapper, (const struct mach_header*)rebasedAddress, uuid);
         _images.insert(_transactionalAllocator.makeUnique<Image>(std::move(image)));
     }
@@ -2059,3 +2091,4 @@
 
 };
 };
+#endif // !TARGET_OS_EXCLAVEKIT