Усилить проблему shared_memory_object с типами, отличными от char - PullRequest
Новая
       47

Усилить проблему shared_memory_object с типами, отличными от char

2 голосов
/ 06 января 2010

У меня проблема с бустом shared_memory_object и mapped_region. Я хочу написать набор объектов (структур) в объекте памяти. Если структура содержит только символ, все в порядке; если я просто добавлю int к структуре, то, если я добавлю слишком много объектов (скажем, 70, намного меньше, чем предел блока), я получу ошибку сегментации при записи.

До сих пор я только что видел примеры, когда простые символы записываются в общую память, но я ничего не читал о типах объектов, которые можно использовать. Мне интересно, если I должен выполнить преобразование между моими объектами и байтовым потоком, или такая функция уже существует. Или если я просто делаю что-то не так в своем коде. Закомментированные строки - это те, которые дают мне ошибку при декомпозиции ... 

#include <boost/interprocess/shared_memory_object.hpp>
#include <boost/interprocess/mapped_region.hpp>
#include <boost/interprocess/containers/string.hpp>
#include <cstring>
#include <cstdlib>
#include <string>
#include <vector>
#include <iostream>
#include <unistd.h>

struct Record {
    char c;
    int i;
//  float f;
//  double d;
//  char cs[32];
//  boost::interprocess::string is;
//  std::vector<int> v;

    Record() {}
    Record(int _k) { Init(_k); }

    void Init(int _k = 0) {
        c = _k + 65;
        i = _k;
//      f = _k + _k/100.0;
//      d = _k + _k/1000.0;
//      is = "interprocess string";
//      for(int j = 0; j < _k; ++j) v.push_back(j);
    }
};

int main(int argc, char *argv[])
{
   using namespace boost::interprocess;
   using std::cerr;
   using std::endl;

   int nObjects = 0;
   size_t blockSize = 1024;

   static std::string sharedObjName("MySharedMemory");      // why static?

   const int writer = 1, reader = 2, error = -1;
   int operation = error;

   if(argc >= 2) {
      if(argv[1][0] == 'w') operation = writer;
      if(argv[1][0] == 'r') operation = reader;
   }
   if(argc == 1) operation = writer;

   if(operation == writer)      // Writer process
   {
      cerr << "Number of objects to write = ";
      std::cin >> nObjects;

      // Remove shared memory on construction and destruction
      struct shm_remove {
         shm_remove() { shared_memory_object::remove(sharedObjName.c_str()); }
         ~shm_remove(){ shared_memory_object::remove(sharedObjName.c_str()); }
      } remover;

      shared_memory_object shm(create_only, sharedObjName.c_str(), read_write);

      shm.truncate(blockSize);

      mapped_region region(shm, read_write);

      offset_t shmSize;
      shm.get_size(shmSize);

      // Produce and write data
      Record *pData0 = static_cast<Record*>(region.get_address());
      Record *pData  = pData0;

      for(int i = 0; i < nObjects; ++i) {
         if(pData0 + blockSize - pData < signed(sizeof(Record))) {
            cerr << "Error: memory block full!" << endl;
            break;
         }
         pData->Init(i);
         pData += sizeof(Record);
      }

      //Launch child process
      pid_t pId = fork();

      if(pId == 0)
      {
         std::string s(argv[0]); s += " r";

         if(std::system(s.c_str()) != 0) {
            cerr << "Error launching reader process." << endl;
            exit(1);
         }
         exit(0);
      }
      else if(pId > 0)
      {
         sleep(2);
         cerr << "Writer has finished!" << endl;
      }
      else  // pId < 0
         exit(-1);
   }
   else if(operation == reader)         // Reader process
   {
      shared_memory_object shm (open_only, sharedObjName.c_str(), read_only);

      mapped_region region(shm, read_only);

      Record *pData = static_cast<Record*>(region.get_address());

      for(int i = 0; i < nObjects; ++i)  {
         // Print pData...
         pData += sizeof(Record);
      }
   }
   else
      exit(1);

   return 0;
}

Спасибо за любую подсказку!

MacOS X 10.6.2 - gcc 4.2 - Повышение 1.41.0

1 Ответ

3 голосов
/ 08 января 2010 
pData += sizeof(Record);

Эта линия - проблема. Арифметика указателя означает, что изменения находятся в «единицах» базового типа указателя, в данном случае Record. Поэтому, если вы хотите перейти к следующей записи, вам следует использовать pData ++, а не pData + = sizeof (Record), которая увеличит указатель на 64 байтов (при условии, что sizeof (Record) составляет 8 - 8 * 8 = 64).

У вас похожая арифметическая ошибка указателя при проверке размера: 

pData0 + blockSize - pData < signed(sizeof(Record))

Вы, вероятно, хотите что-то вроде: 

blockSize/sizeof(Record)-(pData-pData0) <= 0
...