0

我正在玩弄ZeroMQ和Cerealstd::vector在不同进程之间传递数据结构（主要是数字类型）。我已经成功地实现了我想要的，但是在执行结束时出现了分段错误，经过进一步检查后，valgrind我注意到内存正在泄漏/未释放。

server.cpp（接收方）：

#include <zmq.hpp>
#include <string>
#include <unistd.h>
#include <sstream>
#include <cereal/archives/binary.hpp> // serializer
#include <cereal/types/vector.hpp>    // to allow vector serialization
///////////////////////
int receiveMSG(zmq::socket_t& _ss, std::string& _dd){ 
    _dd.clear(); // empty string
    zmq::message_t msg; 
    int n = _ss.recv(&msg); 
    char * tmp;
    memcpy(tmp,msg.data(),msg.size()); 
    _dd = std::string (tmp,msg.size());
    return n;
};
///////////////////////
template <typename _t> 
void vectorDeserializer(std::vector<_t>& _output, std::string& _serializedVector){
    std::stringstream ss; 
    ss << _serializedVector;
    cereal::BinaryInputArchive iarchive(ss);
    iarchive(_output);
    ss.clear();
};
/////////////////////////////////////////////////////
int main () {
    zmq::context_t context (1);
    zmq::socket_t socket (context, ZMQ_REP);
    socket.bind ("tcp://*:4455");

    std::string ts = "dummy";
    std::vector<float> vec (10,5.5);

    receiveMSG(socket,ts);
    vectorDeserializer(vec,ts);

    for (int i = 0; i < vec.size(); ++i) printf("%f\t",vec[i]);
    printf("\n");

    return 0;
}

client.cpp（发送方）：

#include <zmq.hpp>
#include <string>
#include <vector>
#include <cereal/archives/binary.hpp> // serializer
#include <cereal/types/vector.hpp>    // to allow vector serialization
#include <sstream>
///////////////////////
int sendMSG(zmq::socket_t& _ss, std::string& _dd){
    zmq::message_t msg (_dd.size());
    return _ss.send(msg);
};
///////////////////////
template <typename _t> 
void vectorSerializer(std::vector<_t>& _input, std::string& _serializedVector){
    std::stringstream ss; // any stream can be used
    cereal::BinaryOutputArchive oarchive(ss); // Create an output archive
    oarchive(_input);
    _serializedVector = ss.str();
};
///////////////////////
int main ()  {
    zmq::context_t context (1);
    zmq::socket_t  socket (context, ZMQ_REQ);

    std::cout << "Connecting to server…" << std::endl;
    socket.connect ("tcp://localhost:4455");

    std::vector<float> tt (5,1.5);
    std::string ssss="dummy";
    vectorSerializer(tt,ssss);
    sendMSG(socket,ssss);
    return 0;
}

的输出valgrind在此 Pastebin 链接上。显然， zmq::socket_t由于Invalid read of size 4关闭套接字时，槽的析构函数会出现段错误。此外，调用时有很多Conditional jump or move depends on uninitialised value(s)报告。valgrindmemcpy

我的代码中到底缺少什么？还是图书馆内部代码的问题？

4

0 回答 0