Ошибка сегментации и утечка памяти при передаче сериализованных данных в сокет

Я играю с ZeroMQ и Cereal, чтобы передать структуры данных (в основном std::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) сообщает valgrind при звонке memcpy,

Что именно мне не хватает в моем коде? Или проблема во внутреннем коде библиотек?

0 ответов

Другие вопросы по тегам