Я читаю очередь сообщений, используя Boost.Serialization ( v1.46). Все работает нормально, пока очередь содержит только один элемент. Но когда я читаю очередь, содержащую более одного элемента, возникает следующее исключение:
terminate called after throwing an instance of 'boost::archive::archive_exception'
what(): invalid signature
archive_exception.hpp говорит invalid signature // first line of archive does not contain expected string"
Класс, который я сериализирую и десериализую, выглядит следующим образом:
#define MAX_SIZE 1000
class IpcMsg {
public:
IpcMsg(int logLevel = 0, std::string logMsg = "") :
logLevel(logLevel), logMsg(logMsg) {
}
;
int logLevel;
std::string logMsg;
private:
friend class boost::serialization::access;
template<class Archive>
void serialize(Archive & ar, const unsigned int version) {
ar & logLevel;
ar & logMsg;
}
};
сериализация:
try
{
message_queue mq
(
open_or_create,
"mq",
100,
MAX_SIZE
);
IpcMsg logMsg(1, "Test");
std::stringstream oss;
boost::archive::text_oarchive oa(oss);
oa << logMsg;
std::string serialized_string(oss.str());
mq.send(serialized_string.data(), serialized_string.size(), 0);
}
catch(interprocess_exception &ex)
{
std::cerr << ex.what() << std::endl;
}
десериализация:
...
IpcMsg logEntry;
std::stringstream iss;
std::string serialized_string;
serialized_string.resize(MAX_SIZE);
while(mq.try_receive(&serialized_string[0], MAX_SIZE, recvd_size, priority)){
iss << serialized_string;
boost::archive::text_iarchive ia(iss);
ia >> logEntry;
msgs.push_back(logEntry);
std::cout << logEntry.logLevel << std::endl;
std::cout << logEntry.logMsg << std::endl;
}
