blob: ddfaaa7fc658aab7da376b5a256788da65576b8a (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
|
#include "message.h"
#include <stdexcept>
#include <cstring>
#include <iostream>
std::pair<uint8_t*, std::size_t> Message::serialize() {
//std::size_t s = payload.size();
//uint8_t* buf = new uint8_t[4 + s];
//*(uint16_t*)buf = (uint16_t)s;
//memcpy(buf + 4, payload.c_str(), payload.size());
//return std::pair<uint8_t*, std::size_t>(buf, 4 + s);
return std::pair<uint8_t*, std::size_t>(0, 0);
}
std::size_t Message::deserialize(uint8_t* data, std::size_t bytes) {
if(deserialize_size == 0 && bytes == 0) {
return 4;
}
if(deserialize_size == 0 && bytes == 4) {
uint16_t* header = (uint16_t*)data;
deserialize_size = (std::size_t)header[0];
payload_type = (Payload::Type)header[1];
return deserialize_size;
}
if(!deserialize_size) {
throw std::runtime_error("Deserialization header error.");
}
if(bytes != deserialize_size) {
throw std::runtime_error("Deserialization attempted with incomplete data.");
}
//payload = std::string((char*)data, bytes);
return 0;
}
Message::Message() : deserialize_size(0) {
}
Message::p Message::create() {
return Message::p(new Message);
}
Payload::Type Message::type() {
return payload_type;
}
|
