0

ブーストインタープロセスと ptree 構造を使用していくつかのテストを行っています。送信されたメッセージを読み取ろうとすると (または json で解析しようとすると)、セグメンテーション違反が発生します。

debian Linuxでboost1.49を使用しています。

後で使用するためにjsonでシリアル化しています.boostプロパティthreeの直接シリアル化に関する適切なドキュメントが見つからなかったためです。

これは私がテストに使用しているコードです（segfaultがどこにあるかを言う）：

recv.cc

#include <boost/property_tree/ptree.hpp>
#include <boost/property_tree/json_parser.hpp>
#include <boost/interprocess/ipc/message_queue.hpp>
#include <sstream>



struct test_data{
    std::string action;
    std::string name;
    int faceID;
    uint32_t Flags;
    uint32_t freshness;
};

test_data recvData()
{
    boost::interprocess::message_queue::remove("queue");
    boost::property_tree::ptree pt;
    test_data data;
    std::istringstream buffer;
    boost::interprocess::message_queue mq(boost::interprocess::open_or_create,"queue", 1, sizeof(buffer)
    boost::interprocess::message_queue::size_type recvd_size;
    unsigned int pri;
    mq.receive(&buffer,sizeof(buffer),recvd_size,pri);
    std::cout << buffer.str() << std::endl; //the segfault is there
    boost::property_tree::read_json(buffer,pt);
    data.action = pt.get<std::string>("action");
    data.name = pt.get<std::string>("name");
    data.faceID = pt.get<int>("face");
    data.Flags = pt.get<uint32_t>("flags");
    data.freshness = pt.get<uint32_t>("freshness");
    boost::interprocess::message_queue::remove("queue");
    return data;
}   

int main()
{
    test_data test;
    test = recvData();
    std::cout << test.action << test.name << test.faceID << test.Flags << test.freshness << std::endl;
}

送信者.cc

#include <boost/property_tree/ptree.hpp>
#include <boost/property_tree/json_parser.hpp>
#include <boost/interprocess/ipc/message_queue.hpp>
#include <sstream>


struct test_data{
    std::string action;
    std::string name;
    int faceID;
    uint32_t Flags;
    uint32_t freshness;
};


int sendData(test_data data)
{
    boost::property_tree::ptree pt;
    pt.put("action",data.action);
    pt.put("name",data.name);
    pt.put("face",data.faceID);
    pt.put("flags",data.Flags);
    pt.put("freshness",data.freshness);
    std::ostringstream buffer;
    boost::property_tree::write_json(buffer,pt,false);
    boost::interprocess::message_queue mq(boost::interprocess::open_only,"chiappen")
    std::cout << sizeof(buffer) << std::endl;
    mq.send(&buffer,sizeof(buffer),0);
    return 0;
}


int main ()
{
    test_data prova;
    prova.action = "registration";
    prova.name = "prefix";
    prova.Flags = 0;
    prova.freshness = 52;
    sendData(prova);
}
4

1 に答える 1

4

今は答えが少し遅いことはわかっていますが、とにかく..受信用のバッファとしてistringstreamを渡すことはできません。Boost メッセージ キューは raw バイトのみを処理し、std のようなオブジェクトは処理しません。

これを機能させるには、char 配列または以前に malloc で予約したバッファーを使用する必要があります。

元：

char buffer [1024];
mq.receive(buffer, sizeof(buffer), recvd_size, pri);

送信する場合も同じですが、生のバイトしか送信できないため、ostringstream は使用できません。

それが役に立てば幸い。

于 2013-09-25T04:21:26.953 に答える