1

ブースト インタープロセス ライブラリの仕組みを理解しようとしています。ベクターコンテナに整数値を保持する Equipment クラスがあります。

親の親プロセスで。MySegmentObjectセグメントでEquipment オブジェクトを作成し、このオブジェクトのコンストラクターでMySegmentVectorセグメントにベクターを作成しました。

子プロセスの使用; 作成したオブジェクトにアクセスしてベクターのサイズを取得したい。メソッドを使用してオブジェクトにアクセスできますが、アクセスしたオブジェクトからメソッドsegment->findを呼び出すと、getSize()クラッシュします!

おそらく、共有メモリの概念について sth がありません。

Visual Studio 2010 & boost 1.43.0 libでコードをテストしました

機器.h

#pragma once
#include <boost/interprocess/managed_shared_memory.hpp>
#include <boost/interprocess/containers/vector.hpp>
#include <boost/interprocess/allocators/allocator.hpp>

using namespace boost::interprocess;

typedef boost::interprocess::allocator<int, managed_shared_memory::segment_manager>     ShmemAllocator; 
typedef boost::container::vector<int, ShmemAllocator> EqVector;

class Equipments { 
public:     
    Equipments(void);   
    ~Equipments(void);  
    void addEquipment(int n);   
    int getSize();  
    int getElement(int n);

private:
    const ShmemAllocator *alloc_inst;
    <offset_ptr>EqVector eqVector;
    managed_shared_memory *segment;
};

機器.cpp

#include "StdAfx.h"
#include "Equipments.h"
#include <iostream>

Equipments::Equipments(void)
{   
    shared_memory_object::remove("mySegmentVector"); 
    segment = new managed_shared_memory(create_only, "mySegmentObjectVector", 65536);
    alloc_inst = new ShmemAllocator(segment->get_segment_manager());
    eqVector = segment->construct<EqVector>("myVector")(*alloc_inst);
}


Equipments::~Equipments(void)
{
}

void Equipments::addEquipment(int n)
{
    eqVector->push_back(n);
}

int Equipments::getSize()
{
    return eqVector->size();
}

int Equipments::getElement(int n)
{
    return eqVector->at(n);
}

メイン.cpp

#include "stdafx.h"
#include "Equipments.h"
#include <iostream>
#include <string>
#include <boost/interprocess/managed_shared_memory.hpp>
#include <boost/interprocess/containers/vector.hpp>
#include <boost/interprocess/allocators/allocator.hpp>

using namespace boost::interprocess;

int main(int argc, char *argv[]) 
{
    if (argc == 1) 
    {
        std::cout << "parent process" << std::endl;
        shared_memory_object::remove("mySegmentObject"); 
        managed_shared_memory segment(create_only, "mySegmentObject", 65536);
        Equipments *eqPtr = segment.construct<Equipments>("EQ")();

        eqPtr->addEquipment(19);
        eqPtr->addEquipment(12);

        //Launch child process
        std::string s(argv[0]); s += " child ";
        if(0 != std::system(s.c_str()))
            return 1;        //Launch child process
    }
    else 
    {
        std::cout << "child process" << std::endl;
        managed_shared_memory *segment = new managed_shared_memory(open_only, "mySegmentObject");
        std::pair<Equipments*, std::size_t> p = segment->find<Equipments>("EQ");

        if (p.first) 
        {
            std::cout << "EQ found" << std::endl;       
       std::cout << p.first->getSize() << std::endl;       
        }
        else 
        {
            std::cout << "EQ not found" << std::endl;
        }
    }
}
4

1 に答える 1

6

問題は、EqVectorを格納するために通常のポインターを使用していることです。共有メモリセグメントをマップすると、プロセスのアドレス空間の任意の場所にマップされる可能性があります。これは、eqVectorがメモリに格納される場所が、最初のプロセスの「メモリ空間」と2番目のプロセスの「メモリ空間」で異なることを意味します。共有メモリセグメントの先頭からのオフセットとしてアドレスを格納するboost::offset_ptrを使用する必要があります。http：//www.boost.org/doc/libs/1_35_0/doc/html/interprocess/offset_ptrを参照してください。 html

于 2010-10-27T17:14:53.777 に答える