부스트 shared_memory_object char와 다른 유형의 문제
-
18-09-2019 - |
문제
boost shared_memory_object 및 mapped_region에 문제가 있습니다. 메모리 객체에 객체 (구조) 세트를 쓰고 싶습니다. 구조에 숯이 포함되어 있으면 모든 것이 정상입니다. 구조물에 int를 추가하면 객체를 너무 많이 넣으면 (70, 블록의 한계보다 훨씬 적음) 쓸 때 분할 결함이 발생합니다.
지금까지 나는 단순한 숯이 공유 메모리에 기록되는 예를 보았지만 사용할 수있는 객체의 종류에 대해서는 아무것도 읽지 못했습니다. 궁금합니다 나 내 객체와 바이트 스트림 사이의 변환 또는 그러한 함수가 이미 존재하는지 여부를 전환해야합니다. 또는 내 코드에서 뭔가 잘못한 경우. 주석은 선은 분해 될 때 나에게 segfault를주는 줄입니다 ...
#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
해결책
pData += sizeof(Record);
그 줄은 문제입니다. 포인터 산술은 변경 사항이 기본 포인터 유형의 "단위",이 경우 레코드를 의미합니다. 따라서 다음 레코드로 증가하려면 pdata+= sizeof (레코드) 대신 pdata ++를 수행해야합니다. 64 바이트 (레코드의 크기 (레코드)가 8-8*8 = 64라고 가정합니다).
크기 검사에서 유사한 포인터 산술 오류가 있습니다.
pData0 + blockSize - pData < signed(sizeof(Record))
당신은 아마도 다음과 같은 것을 원할 것입니다.
blockSize/sizeof(Record)-(pData-pData0) <= 0
제휴하지 않습니다 StackOverflow