Увеличьте межпроцессную проблему с общей памятью

Я использую использование межпроцессного Boost для доступа к общей памяти.
То, что я пытаюсь сделать, — это сохранить карту в общей памяти и получить доступ к ней из разных процессов. Ниже приведена часть кода, где я пытаюсь сделать то же самое —

SharedMemoryManager.h

#ifndef SHARED_MEMORY_MANAGER_H
#define SHARED_MEMORY_MANAGER_H

#include <boost/interprocess/managed_shared_memory.hpp>
#include <boost/interprocess/containers/string.hpp>
#include <boost/interprocess/allocators/allocator.hpp>
#include <boost/interprocess/sync/named_semaphore.hpp>
#include <boost/interprocess/containers/map.hpp>

enum RangeBound { START, END, SINGLE };

typedef struct {
std::string code;
RangeBound flag;
} ZipRangeInfo;

typedef std::string RangeKeyType;
typedef std::pair<const RangeKeyType, ZipRangeInfo> RangeValueType;

typedef boost::interprocess::allocator<RangeValueType, boost::interprocess::managed_shared_memory::segment_manager> RangeBasedShmemAllocator;

typedef boost::interprocess::map<RangeKeyType, ZipRangeInfo, std::less<RangeKeyType>, RangeBasedShmemAllocator> SharedRangeBasedMap;

class SharedMemoryManager {

private:
static boost::interprocess::managed_shared_memory *segment;
static RangeBasedShmemAllocator *alloc_range_map;
public:
static char* get_range_based_routing_code(char *dataItem, char *fileName);
static SharedRangeBasedMap* get_range_based_routing_table(char *fileName );
static void load_range_based_routing_table( const char *fileName );
};

#endif //SHARED_MEMORY_MANAGER_H

а также
SharedmemoryManager.cpp

#include "SharedMemoryManager.h"
const std::string shm_code_util("SharedMemoryUtil");

//Initializing shared memory of size 1 GB.
boost::interprocess::managed_shared_memory *SharedMemoryManager::segment =
new boost::interprocess::managed_shared_memory(
boost::interprocess::open_or_create, "CRS", 1024 * 1024 * 1024);
RangeBasedShmemAllocator *SharedMemoryManager::alloc_range_map =
new RangeBasedShmemAllocator(segment->get_segment_manager());

// Method definitions

char* SharedMemoryManager::get_range_based_routing_code(char *dataItem,
char *fileName) {

char* result = NULL;
// Postal Code Scrubbing Logic
if (dataItem == NULL)
return NULL;
try {
char *dataIt = (char *) calloc(strlen(dataItem) + 1, sizeof(char));
strcpy(dataIt, dataItem);

SharedRangeBasedMap *routing_table = get_range_based_routing_table(
fileName);
std::cout << "Hash Table Size :" << routing_table->size();
if (routing_table != NULL && routing_table->size() > 0) {
RangeKeyType key(dataItem);
SharedRangeBasedMap::const_iterator routing_entry =
routing_table->lower_bound(key);
std::cout << "Got iterator";
if (routing_entry == routing_table->end()) {
return NULL;
}
if (routing_entry->first == key
|| routing_entry->second.flag == END) {
result = (char *) routing_entry->second.code.c_str();
}
}
free(dataIt);

return result;
} catch (std::exception &e) {
throw;
}
}

SharedRangeBasedMap* SharedMemoryManager::get_range_based_routing_table(
char *fileName) {

boost::interprocess::named_semaphore sync_semaphore(
boost::interprocess::open_or_create, "LoadFilesSemaphore", 1);
sync_semaphore.wait();
try {
SharedRangeBasedMap *routing_table = segment->find_or_construct<
SharedRangeBasedMap>(fileName)(std::less<RangeKeyType>(),
*alloc_range_map);
if (routing_table->size() == 0) {
load_range_based_routing_table(fileName);
}
sync_semaphore.post();

return routing_table;
} catch (...) {
std::cout << "An exception was thrown; couldn't load post codes.";
sync_semaphore.post();
return NULL;
}
return NULL;
}

void SharedMemoryManager::load_range_based_routing_table(const char *fileName) {

SharedRangeBasedMap *range_based_map = NULL;
range_based_map = segment->find_or_construct<SharedRangeBasedMap>(
fileName)(std::less<RangeKeyType>(), *alloc_range_map);// Build the hash if empty
if (range_based_map != NULL && range_based_map->size() == 0) {
//logic to populate the map - tested to work correctly
}
}

Проблема, с которой я сталкиваюсь, заключается в том, что первый процесс, который вызывает get_range_based_routing_codeТаким образом, инициализируя общую память и заполняя карту, он может извлечь значение из карты, тогда как любой последующий вызов get_range_based_routing_code сталкивается с ошибкой сегментации.
Добавляя cout операторы, я смог сделать вывод, что приведенная ниже строка является той, которая вызывает ошибку (или это строка выполнения lsat) —

SharedRangeBasedMap::const_iterator routing_entry =
routing_table->lower_bound(key);

У меня проблемы с выяснением этого, и моя неопытность в C ++ не помогает. Есть указатели?

0

Решение

Вы также должны выделить тип ключа из области общей памяти.

Существует несколько примеров повышения IPC, которые определяют shared_string для этого. Вы можете повторно использовать это.


То же самое касается std::string внутри ZipRangeInfo тип. Да, это много работы и хлопотно. На практике вы можете заменить ZipRangeInfo::code некоторыми статически boost::array<char, ...> или же char[N]

2

Другие решения


По вопросам рекламы [email protected]