123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183 |
- #ifndef _FASTDDS_RTPS_SERIALIZEDPAYLOAD_H_
- #define _FASTDDS_RTPS_SERIALIZEDPAYLOAD_H_
- #include <fastrtps/fastrtps_dll.h>
- #include <fastdds/rtps/common/Types.h>
- #include <cstring>
- #include <new>
- #include <stdexcept>
- #include <stdint.h>
- #include <stdlib.h>
- namespace eprosima {
- namespace fastrtps {
- namespace rtps {
- #define CDR_BE 0x0000
- #define CDR_LE 0x0001
- #define PL_CDR_BE 0x0002
- #define PL_CDR_LE 0x0003
- struct RTPS_DllAPI SerializedPayload_t
- {
-
- uint16_t encapsulation;
-
- uint32_t length;
-
- octet* data;
-
- uint32_t max_size;
-
- uint32_t pos;
-
- SerializedPayload_t()
- : encapsulation(CDR_BE)
- , length(0)
- , data(nullptr)
- , max_size(0)
- , pos(0)
- {
- }
-
- SerializedPayload_t(
- uint32_t len)
- : SerializedPayload_t()
- {
- this->reserve(len);
- }
- ~SerializedPayload_t()
- {
- this->empty();
- }
- bool operator == (
- const SerializedPayload_t& other) const
- {
- return ((encapsulation == other.encapsulation) &&
- (length == other.length) &&
- (0 == memcmp(data, other.data, length)));
- }
-
- bool copy(
- const SerializedPayload_t* serData,
- bool with_limit = true)
- {
- length = serData->length;
- if (serData->length > max_size)
- {
- if (with_limit)
- {
- return false;
- }
- else
- {
- this->reserve(serData->length);
- }
- }
- encapsulation = serData->encapsulation;
- memcpy(data, serData->data, length);
- return true;
- }
-
- bool reserve_fragmented(
- SerializedPayload_t* serData)
- {
- length = serData->length;
- max_size = serData->length;
- encapsulation = serData->encapsulation;
- data = (octet*)calloc(length, sizeof(octet));
- return true;
- }
-
- void empty()
- {
- length = 0;
- encapsulation = CDR_BE;
- max_size = 0;
- if (data != nullptr)
- {
- free(data);
- }
- data = nullptr;
- }
- void reserve(
- uint32_t new_size)
- {
- if (new_size <= this->max_size)
- {
- return;
- }
- if (data == nullptr)
- {
- data = (octet*)calloc(new_size, sizeof(octet));
- if (!data)
- {
- throw std::bad_alloc();
- }
- }
- else
- {
- void* old_data = data;
- data = (octet*)realloc(data, new_size);
- if (!data)
- {
- free(old_data);
- throw std::bad_alloc();
- }
- }
- max_size = new_size;
- }
- };
- }
- }
- }
- #endif
|