FM / datafacade

/srv/osrm/osrm-backend/src/engine/datafacade/

/srv/osrm/osrm-backend/src/engine/datafacade

Name	Size	Mode	Actions
mmap_memory_allocator.cpp	2621	0644	edit dl rm
process_memory_allocator.cpp	1285	0644	edit dl rm
shared_memory_allocator.cpp	1340	0644	edit dl rm

Edit: /srv/osrm/osrm-backend/src/engine/datafacade/shared_memory_allocator.cpp (1340B)

#include "engine/datafacade/shared_memory_allocator.hpp"

#include "storage/serialization.hpp"

#include "util/log.hpp"

#include "boost/assert.hpp"

namespace osrm::engine::datafacade
{

SharedMemoryAllocator::SharedMemoryAllocator(
    const std::vector<storage::SharedRegionRegister::ShmKey> &shm_keys)
{
    std::vector<storage::SharedDataIndex::AllocatedRegion> regions;

for (const auto shm_key : shm_keys)
    {
        util::Log(logDEBUG) << "Loading new data for region " << (int)shm_key;
        BOOST_ASSERT(storage::SharedMemory::RegionExists(shm_key));
        auto mem = storage::makeSharedMemory(shm_key);

storage::io::BufferReader reader(reinterpret_cast<char *>(mem->Ptr()), mem->Size());
        std::unique_ptr<storage::BaseDataLayout> layout =
            std::make_unique<storage::ContiguousDataLayout>();
        storage::serialization::read(reader, *layout);
        auto layout_size = reader.GetPosition();

regions.push_back({reinterpret_cast<char *>(mem->Ptr()) + layout_size, std::move(layout)});
        memory_regions.push_back(std::move(mem));
    }

index = storage::SharedDataIndex{std::move(regions)};
}

SharedMemoryAllocator::~SharedMemoryAllocator() {}

const storage::SharedDataIndex &SharedMemoryAllocator::GetIndex() { return index; }

} // namespace osrm::engine::datafacade

#include "engine/datafacade/shared_memory_allocator.hpp" #include "storage/serialization.hpp" #include "util/log.hpp" #include "boost/assert.hpp" namespace osrm::engine::datafacade { SharedMemoryAllocator::SharedMemoryAllocator( const std::vector &shm_keys) { std::vector regions; for (const auto shm_key : shm_keys) { util::Log(logDEBUG) << "Loading new data for region " << (int)shm_key; BOOST_ASSERT(storage::SharedMemory::RegionExists(shm_key)); auto mem = storage::makeSharedMemory(shm_key); storage::io::BufferReader reader(reinterpret_cast(mem->Ptr()), mem->Size()); std::unique_ptr layout = std::make_unique(); storage::serialization::read(reader, *layout); auto layout_size = reader.GetPosition(); regions.push_back({reinterpret_cast(mem->Ptr()) + layout_size, std::move(layout)}); memory_regions.push_back(std::move(mem)); } index = storage::SharedDataIndex{std::move(regions)}; } SharedMemoryAllocator::~SharedMemoryAllocator() {} const storage::SharedDataIndex &SharedMemoryAllocator::GetIndex() { return index; } } // namespace osrm::engine::datafacade