Newer
Older
#include <string>
#include <typeinfo>
#include "GeoNetworkingCodec.hh"
#include "loggers.hh"
int GeoNetworkingCodec::encode (const LibItsGeoNetworking__TypesAndValues::GeoNetworkingPdu& msg, OCTETSTRING& data)
{
loggers::loggers::log_msg("GeoNetworkingCodec::encode: ", (const Base_Type&)msg);
TTCN_Buffer encoding_buffer;
encode_(msg, encoding_buffer);
data = OCTETSTRING(encoding_buffer.get_len(), encoding_buffer.get_data());
return 0;
}
int GeoNetworkingCodec::decode (const OCTETSTRING& data, LibItsGeoNetworking__TypesAndValues::GeoNetworkingPdu& msg)
{
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
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
loggers::loggers::log("GeoNetworkingCodec::decode");
return 0;
}
int GeoNetworkingCodec::encode_ (const Base_Type& type, TTCN_Buffer& encoding_buffer)
{
loggers::loggers::log(">>> GeoNetworkingCodec::encode_: processing %s", type.get_descriptor()->name);
loggers::loggers::log_msg("GeoNetworkingCodec::encode_: ", type);
if (dynamic_cast<const Record_Type *>(&type) != NULL) {
const Record_Type& r = (const Record_Type &)type;
loggers::loggers::log("GeoNetworkingCodec::encode_: processing Record_Type %s", r.get_descriptor()->name);
for(int i = 0; i < r.get_count(); i++) {
loggers::loggers::log("GeoNetworkingCodec::encode_: processing %s - %d (1 ==> use dynamic_cast<const OPTIONAL<...>)", r.fld_name(i), r.get_at(i)->is_optional());
if (encode_(*r.get_at(i), encoding_buffer) == -1) {
return -1;
}
} // End of 'for' statement
} else if (std::string(type.get_descriptor()->name).compare("@LibItsGeoNetworking_TypesAndValues.ExtendedHeader") == 0) {
const OPTIONAL<LibItsGeoNetworking__TypesAndValues::ExtendedHeader> &v = dynamic_cast<const OPTIONAL<LibItsGeoNetworking__TypesAndValues::ExtendedHeader> &>(type);
const LibItsGeoNetworking__TypesAndValues::ExtendedHeader& u = static_cast<const LibItsGeoNetworking__TypesAndValues::ExtendedHeader &>(*v.get_opt_value());
int result = -1;
switch (u.get_selection()) {
case LibItsGeoNetworking__TypesAndValues::ExtendedHeader::UNBOUND_VALUE:
TTCN_error("Invalid selection in unbound union");
break;
case LibItsGeoNetworking__TypesAndValues::ExtendedHeader::ALT_geoUnicastHeader:
loggers::loggers::log("GeoNetworkingCodec::encode_: processing type %s", u.geoUnicastHeader().get_descriptor()->name);
result = encode_(u.geoUnicastHeader(), encoding_buffer);
break;
case LibItsGeoNetworking__TypesAndValues::ExtendedHeader::ALT_tsbHeader:
loggers::loggers::log("GeoNetworkingCodec::encode_: processing type %s", u.tsbHeader().get_descriptor()->name);
result = encode_(u.tsbHeader(), encoding_buffer);
break;
case LibItsGeoNetworking__TypesAndValues::ExtendedHeader::ALT_shbHeader:
loggers::loggers::log("GeoNetworkingCodec::encode_: processing type %s", u.shbHeader().get_descriptor()->name);
result = encode_(u.shbHeader(), encoding_buffer);
break;
case LibItsGeoNetworking__TypesAndValues::ExtendedHeader::ALT_geoBroadcastHeader:
loggers::loggers::log("GeoNetworkingCodec::encode_: processing type %s", u.geoBroadcastHeader().get_descriptor()->name);
result = encode_(u.geoBroadcastHeader(), encoding_buffer);
break;
case LibItsGeoNetworking__TypesAndValues::ExtendedHeader::ALT_geoAnycastHeader:
loggers::loggers::log("GeoNetworkingCodec::encode_: processing type %s", u.geoAnycastHeader().get_descriptor()->name);
result = encode_(u.geoAnycastHeader(), encoding_buffer);
break;
case LibItsGeoNetworking__TypesAndValues::ExtendedHeader::ALT_beaconHeader:
loggers::loggers::log("GeoNetworkingCodec::encode_: processing type %s", u.beaconHeader().get_descriptor()->name);
result = encode_(u.beaconHeader(), encoding_buffer);
break;
case LibItsGeoNetworking__TypesAndValues::ExtendedHeader::ALT_anyHeader:
loggers::loggers::log("GeoNetworkingCodec::encode_: processing type %s", u.anyHeader().get_descriptor()->name);
result = encode_(u.anyHeader(), encoding_buffer);
break;
case LibItsGeoNetworking__TypesAndValues::ExtendedHeader::ALT_lsRequestHeader:
loggers::loggers::log("GeoNetworkingCodec::encode_: processing type %s", u.lsRequestHeader().get_descriptor()->name);
result = encode_(u.lsRequestHeader(), encoding_buffer);
break;
case LibItsGeoNetworking__TypesAndValues::ExtendedHeader::ALT_lsReplyHeader:
loggers::loggers::log("GeoNetworkingCodec::encode_: processing type %s", u.lsReplyHeader().get_descriptor()->name);
result = encode_(u.lsReplyHeader(), encoding_buffer);
break;
default: TTCN_error("Invalid selection in union is_bound");
} // End of 'switch' statement
if (result == -1) {
return -1;
}
} else {
loggers::loggers::log("GeoNetworkingCodec::encode_ (else): processing type %s", type.get_descriptor()->name);
type.encode(*type.get_descriptor(), encoding_buffer, TTCN_EncDec::CT_RAW);
}
loggers::loggers::log_to_hexa("GeoNetworkingCodec::encode_: encoding_buffer=", encoding_buffer);