summaryrefslogtreecommitdiff
path: root/src/components/protocol_handler/test/incoming_data_handler_test.cc
diff options
context:
space:
mode:
Diffstat (limited to 'src/components/protocol_handler/test/incoming_data_handler_test.cc')
-rw-r--r--src/components/protocol_handler/test/incoming_data_handler_test.cc616
1 files changed, 423 insertions, 193 deletions
diff --git a/src/components/protocol_handler/test/incoming_data_handler_test.cc b/src/components/protocol_handler/test/incoming_data_handler_test.cc
index dd30620733..66f5aea712 100644
--- a/src/components/protocol_handler/test/incoming_data_handler_test.cc
+++ b/src/components/protocol_handler/test/incoming_data_handler_test.cc
@@ -65,10 +65,11 @@ class IncomingDataHandlerTest : public ::testing::Test {
delete[] some_data;
delete[] some_data2;
}
- void ProcessData(transport_manager::ConnectionUID uid, const uint8_t *const data,
- const uint32_t data_size ) {
- actual_frames = data_handler.ProcessData(RawMessage(uid, 0, data, data_size),
- &result_code, &malformed_occurs);
+ void ProcessData(transport_manager::ConnectionUID uid,
+ const uint8_t* const data,
+ const uint32_t data_size) {
+ actual_frames = data_handler.ProcessData(
+ RawMessage(uid, 0, data, data_size), &result_code, &malformed_occurs);
}
void AppendPacketToTMData(const ProtocolPacket& packet) {
@@ -116,35 +117,44 @@ TEST_F(IncomingDataHandlerTest, NullData) {
TEST_F(IncomingDataHandlerTest, DataForUnknownConnection) {
size_t malformed_count = 0;
- actual_frames = data_handler.ProcessData(RawMessage(uid_unknown, 0, NULL, 0),
- &result_code, &malformed_count);
+ actual_frames = data_handler.ProcessData(
+ RawMessage(uid_unknown, 0, NULL, 0), &result_code, &malformed_count);
EXPECT_EQ(RESULT_FAIL, result_code);
EXPECT_EQ(malformed_count, 0u);
EXPECT_TRUE(actual_frames.empty());
AppendPacketToTMData(ProtocolPacket());
- actual_frames = data_handler.ProcessData(RawMessage(uid_unknown, 0, tm_data.data(), tm_data.size()),
- &result_code, &malformed_count);
+ actual_frames = data_handler.ProcessData(
+ RawMessage(uid_unknown, 0, tm_data.data(), tm_data.size()),
+ &result_code,
+ &malformed_count);
EXPECT_EQ(RESULT_FAIL, result_code);
EXPECT_EQ(malformed_count, 0u);
EXPECT_TRUE(actual_frames.empty());
}
TEST_F(IncomingDataHandlerTest, Heartbeat_per_byte) {
- const ProtocolPacket hb_packet(uid1, PROTOCOL_VERSION_1, PROTECTION_OFF, FRAME_TYPE_CONTROL,
- kControl, FRAME_DATA_HEART_BEAT, some_session_id, 0u,
- protov1_message_id, NULL);
+ const ProtocolPacket hb_packet(uid1,
+ PROTOCOL_VERSION_1,
+ PROTECTION_OFF,
+ FRAME_TYPE_CONTROL,
+ kControl,
+ FRAME_DATA_HEART_BEAT,
+ some_session_id,
+ 0u,
+ protov1_message_id,
+ NULL);
const size_t hb_count = 100;
for (size_t i = 0; i < hb_count; ++i) {
AppendPacketToTMData(hb_packet);
// Send per 1 byte (except last byte)
for (size_t i = 0; i < tm_data.size() - 1; ++i) {
- ProcessData(uid1, &tm_data[i] , 1);
+ ProcessData(uid1, &tm_data[i], 1);
EXPECT_EQ(RESULT_OK, result_code);
EXPECT_EQ(malformed_occurs, 0u);
EXPECT_TRUE(actual_frames.empty());
}
- ProcessData(uid1, &*(tm_data.end()-1), 1);
+ ProcessData(uid1, &*(tm_data.end() - 1), 1);
EXPECT_EQ(RESULT_OK, result_code);
EXPECT_EQ(malformed_occurs, 0u);
EXPECT_EQ(1u, actual_frames.size());
@@ -154,9 +164,16 @@ TEST_F(IncomingDataHandlerTest, Heartbeat_per_byte) {
}
TEST_F(IncomingDataHandlerTest, Heartbeat_pack) {
- const ProtocolPacket hb_packet(uid1, PROTOCOL_VERSION_2, PROTECTION_OFF, FRAME_TYPE_CONTROL,
- kControl, FRAME_DATA_HEART_BEAT, some_session_id, 0u,
- some_message_id, NULL);
+ const ProtocolPacket hb_packet(uid1,
+ PROTOCOL_VERSION_2,
+ PROTECTION_OFF,
+ FRAME_TYPE_CONTROL,
+ kControl,
+ FRAME_DATA_HEART_BEAT,
+ some_session_id,
+ 0u,
+ some_message_id,
+ NULL);
const size_t hb_count = 100;
for (size_t i = 0u; i < hb_count; ++i) {
AppendPacketToTMData(hb_packet);
@@ -165,7 +182,9 @@ TEST_F(IncomingDataHandlerTest, Heartbeat_pack) {
EXPECT_EQ(RESULT_OK, result_code);
EXPECT_EQ(malformed_occurs, 0u);
EXPECT_EQ(hb_count, actual_frames.size());
- for (FrameList::iterator it = actual_frames.begin(); it != actual_frames.end(); ++it) {
+ for (FrameList::iterator it = actual_frames.begin();
+ it != actual_frames.end();
+ ++it) {
EXPECT_EQ(hb_packet, **it);
}
}
@@ -173,30 +192,52 @@ TEST_F(IncomingDataHandlerTest, Heartbeat_pack) {
TEST_F(IncomingDataHandlerTest, MixedPayloadData_TwoConnections) {
FrameList mobile_packets;
// single packet RPC
- mobile_packets.push_back(
- new ProtocolPacket(
- uid1, PROTOCOL_VERSION_1, PROTECTION_OFF, FRAME_TYPE_SINGLE,
- kRpc, FRAME_DATA_SINGLE, some_session_id, some_data_size,
- protov1_message_id, some_data));
+ mobile_packets.push_back(new ProtocolPacket(uid1,
+ PROTOCOL_VERSION_1,
+ PROTECTION_OFF,
+ FRAME_TYPE_SINGLE,
+ kRpc,
+ FRAME_DATA_SINGLE,
+ some_session_id,
+ some_data_size,
+ protov1_message_id,
+ some_data));
// consecutive packet Audio
- mobile_packets.push_back(
- new ProtocolPacket(
- uid1, PROTOCOL_VERSION_2, PROTECTION_ON, FRAME_TYPE_CONSECUTIVE,
- kAudio, FRAME_DATA_LAST_CONSECUTIVE, ++some_session_id, some_data2_size,
- some_message_id, some_data2));
+ mobile_packets.push_back(new ProtocolPacket(uid1,
+ PROTOCOL_VERSION_2,
+ PROTECTION_ON,
+ FRAME_TYPE_CONSECUTIVE,
+ kAudio,
+ FRAME_DATA_LAST_CONSECUTIVE,
+ ++some_session_id,
+ some_data2_size,
+ some_message_id,
+ some_data2));
// single packet Nav
- mobile_packets.push_back(
- new ProtocolPacket(
- uid1, PROTOCOL_VERSION_3, PROTECTION_ON, FRAME_TYPE_SINGLE,
- kMobileNav, FRAME_DATA_SINGLE, ++some_session_id, some_data_size,
- ++some_message_id, some_data));
+ mobile_packets.push_back(new ProtocolPacket(uid1,
+ PROTOCOL_VERSION_3,
+ PROTECTION_ON,
+ FRAME_TYPE_SINGLE,
+ kMobileNav,
+ FRAME_DATA_SINGLE,
+ ++some_session_id,
+ some_data_size,
+ ++some_message_id,
+ some_data));
// consecutive packet Bulk
- mobile_packets.push_back(
- new ProtocolPacket(
- uid1, PROTOCOL_VERSION_3, PROTECTION_ON, FRAME_TYPE_CONSECUTIVE,
- kBulk, FRAME_DATA_LAST_CONSECUTIVE, ++some_session_id, some_data2_size,
- ++some_message_id, some_data2));
- for (FrameList::iterator it = mobile_packets.begin(); it != mobile_packets.end(); ++it) {
+ mobile_packets.push_back(new ProtocolPacket(uid1,
+ PROTOCOL_VERSION_3,
+ PROTECTION_ON,
+ FRAME_TYPE_CONSECUTIVE,
+ kBulk,
+ FRAME_DATA_LAST_CONSECUTIVE,
+ ++some_session_id,
+ some_data2_size,
+ ++some_message_id,
+ some_data2));
+ for (FrameList::iterator it = mobile_packets.begin();
+ it != mobile_packets.end();
+ ++it) {
AppendPacketToTMData(**it);
}
ProcessData(uid1, &tm_data[0], tm_data.size());
@@ -204,29 +245,39 @@ TEST_F(IncomingDataHandlerTest, MixedPayloadData_TwoConnections) {
EXPECT_EQ(malformed_occurs, 0u);
EXPECT_EQ(mobile_packets.size(), actual_frames.size());
FrameList::iterator it_exp = mobile_packets.begin();
- for (FrameList::const_iterator it = actual_frames.begin(); it != actual_frames.end();
+ for (FrameList::const_iterator it = actual_frames.begin();
+ it != actual_frames.end();
++it, ++it_exp) {
// TODO(EZamakhov): investigate valgrind warning (unitialized value)
- EXPECT_EQ(**it, **it_exp)
- << "Element number " << std::distance(mobile_packets.begin(), it_exp);
+ EXPECT_EQ(**it, **it_exp) << "Element number "
+ << std::distance(mobile_packets.begin(), it_exp);
}
}
-// TODO(EZamakhov): add validator abstraction and replace next test with check only return frames
+// TODO(EZamakhov): add validator abstraction and replace next test with check
+// only return frames
// Protocol version shall be from 1 to 4
TEST_F(IncomingDataHandlerTest, MalformedPacket_Version) {
FrameList malformed_packets;
std::vector<uint8_t> malformed_versions;
malformed_versions.push_back(0);
- for (uint8_t version = PROTOCOL_VERSION_4 + 1; version <= PROTOCOL_VERSION_MAX; ++version) {
+ for (uint8_t version = PROTOCOL_VERSION_4 + 1;
+ version <= PROTOCOL_VERSION_MAX;
+ ++version) {
malformed_versions.push_back(version);
}
for (size_t i = 0; i < malformed_versions.size(); ++i) {
- malformed_packets.push_back(
- new ProtocolPacket(
- uid1, malformed_versions[i], PROTECTION_OFF, FRAME_TYPE_CONTROL, kControl,
- FRAME_DATA_HEART_BEAT, some_session_id, 0u, some_message_id, NULL));
+ malformed_packets.push_back(new ProtocolPacket(uid1,
+ malformed_versions[i],
+ PROTECTION_OFF,
+ FRAME_TYPE_CONTROL,
+ kControl,
+ FRAME_DATA_HEART_BEAT,
+ some_session_id,
+ 0u,
+ some_message_id,
+ NULL));
}
// We count malformed only first time when it occurs after correct message
@@ -237,7 +288,8 @@ TEST_F(IncomingDataHandlerTest, MalformedPacket_Version) {
EXPECT_EQ(0u, actual_frames.size());
++it;
- // All next data will be one large malformed message which we've already counted
+ // All next data will be one large malformed message which we've already
+ // counted
for (; it != malformed_packets.end(); ++it) {
ProcessPacket(**it);
EXPECT_EQ(RESULT_MALFORMED_OCCURS, result_code)
@@ -249,11 +301,13 @@ TEST_F(IncomingDataHandlerTest, MalformedPacket_Version) {
}
}
-// ServiceType shall be equal 0x0 (Control), 0x07 (RPC), 0x0A (PCM), 0x0B (Video), 0x0F (Bulk)
+// ServiceType shall be equal 0x0 (Control), 0x07 (RPC), 0x0A (PCM), 0x0B
+// (Video), 0x0F (Bulk)
TEST_F(IncomingDataHandlerTest, MalformedPacket_ServiceType) {
FrameList malformed_packets;
std::vector<uint8_t> malformed_serv_types;
- for (uint8_t service_type = kControl + 1; service_type < kRpc; ++service_type) {
+ for (uint8_t service_type = kControl + 1; service_type < kRpc;
+ ++service_type) {
malformed_serv_types.push_back(service_type);
}
malformed_serv_types.push_back(0x08);
@@ -262,11 +316,16 @@ TEST_F(IncomingDataHandlerTest, MalformedPacket_ServiceType) {
malformed_serv_types.push_back(0x0D);
malformed_serv_types.push_back(0x0E);
for (size_t i = 0; i < malformed_serv_types.size(); ++i) {
- malformed_packets.push_back(
- new ProtocolPacket(
- uid1, PROTOCOL_VERSION_3, PROTECTION_OFF, FRAME_TYPE_CONTROL,
- malformed_serv_types[i], FRAME_DATA_HEART_BEAT, some_session_id, 0u,
- some_message_id, NULL));
+ malformed_packets.push_back(new ProtocolPacket(uid1,
+ PROTOCOL_VERSION_3,
+ PROTECTION_OFF,
+ FRAME_TYPE_CONTROL,
+ malformed_serv_types[i],
+ FRAME_DATA_HEART_BEAT,
+ some_session_id,
+ 0u,
+ some_message_id,
+ NULL));
}
// We count malformed only first time when it occurs after correct message
@@ -277,7 +336,8 @@ TEST_F(IncomingDataHandlerTest, MalformedPacket_ServiceType) {
EXPECT_EQ(0u, actual_frames.size());
++it;
- // All next data will be one large malformed message which we've already counted
+ // All next data will be one large malformed message which we've already
+ // counted
for (; it != malformed_packets.end(); ++it) {
ProcessPacket(**it);
EXPECT_EQ(RESULT_MALFORMED_OCCURS, result_code)
@@ -289,19 +349,27 @@ TEST_F(IncomingDataHandlerTest, MalformedPacket_ServiceType) {
}
}
-// Frame type shall be 0x00 (Control), 0x01 (Single), 0x02 (First), 0x03 (Consecutive)
+// Frame type shall be 0x00 (Control), 0x01 (Single), 0x02 (First), 0x03
+// (Consecutive)
TEST_F(IncomingDataHandlerTest, MalformedPacket_FrameType) {
FrameList malformed_packets;
std::vector<uint8_t> malformed_frame_types;
for (uint8_t frame_type = FRAME_TYPE_CONSECUTIVE + 1;
- frame_type <= FRAME_TYPE_MAX_VALUE; ++frame_type) {
+ frame_type <= FRAME_TYPE_MAX_VALUE;
+ ++frame_type) {
malformed_frame_types.push_back(frame_type);
}
for (size_t i = 0; i < malformed_frame_types.size(); ++i) {
- malformed_packets.push_back(
- new ProtocolPacket(
- uid1, PROTOCOL_VERSION_3, PROTECTION_OFF, malformed_frame_types[i],
- kControl, FRAME_DATA_HEART_BEAT, some_session_id, 0u, some_message_id, NULL));
+ malformed_packets.push_back(new ProtocolPacket(uid1,
+ PROTOCOL_VERSION_3,
+ PROTECTION_OFF,
+ malformed_frame_types[i],
+ kControl,
+ FRAME_DATA_HEART_BEAT,
+ some_session_id,
+ 0u,
+ some_message_id,
+ NULL));
}
// We count malformed only first time when it occurs after correct message
@@ -312,7 +380,8 @@ TEST_F(IncomingDataHandlerTest, MalformedPacket_FrameType) {
EXPECT_EQ(0u, actual_frames.size());
++it;
- // All next data will be one large malformed message which we've already counted
+ // All next data will be one large malformed message which we've already
+ // counted
for (; it != malformed_packets.end(); ++it) {
ProcessPacket(**it);
EXPECT_EQ(RESULT_MALFORMED_OCCURS, result_code)
@@ -324,19 +393,27 @@ TEST_F(IncomingDataHandlerTest, MalformedPacket_FrameType) {
}
}
-// For Control frames Frame info value shall be from 0x00 to 0x06 or 0xFE(Data Ack), 0xFF(HB Ack)
+// For Control frames Frame info value shall be from 0x00 to 0x06 or 0xFE(Data
+// Ack), 0xFF(HB Ack)
TEST_F(IncomingDataHandlerTest, MalformedPacket_ControlFrame) {
FrameList malformed_packets;
std::vector<uint8_t> malformed_frame_data;
for (uint8_t frame_type = FRAME_DATA_END_SERVICE_NACK + 1;
- frame_type < FRAME_DATA_SERVICE_DATA_ACK; ++frame_type) {
+ frame_type < FRAME_DATA_SERVICE_DATA_ACK;
+ ++frame_type) {
malformed_frame_data.push_back(frame_type);
}
for (size_t i = 0; i < malformed_frame_data.size(); ++i) {
- malformed_packets.push_back(
- new ProtocolPacket(
- uid1, PROTOCOL_VERSION_3, PROTECTION_OFF, FRAME_TYPE_CONTROL, kControl,
- malformed_frame_data[i], some_session_id, 0u, some_message_id, NULL));
+ malformed_packets.push_back(new ProtocolPacket(uid1,
+ PROTOCOL_VERSION_3,
+ PROTECTION_OFF,
+ FRAME_TYPE_CONTROL,
+ kControl,
+ malformed_frame_data[i],
+ some_session_id,
+ 0u,
+ some_message_id,
+ NULL));
}
// We count malformed only first time when it occurs after correct message
@@ -347,7 +424,8 @@ TEST_F(IncomingDataHandlerTest, MalformedPacket_ControlFrame) {
EXPECT_EQ(0u, actual_frames.size());
++it;
- // All next data will be one large malformed message which we've already counted
+ // All next data will be one large malformed message which we've already
+ // counted
for (; it != malformed_packets.end(); ++it) {
ProcessPacket(**it);
EXPECT_EQ(RESULT_MALFORMED_OCCURS, result_code)
@@ -364,15 +442,22 @@ TEST_F(IncomingDataHandlerTest, MalformedPacket_SingleFrame) {
FrameList malformed_packets;
std::vector<uint8_t> malformed_frame_data;
for (uint8_t frame_type = FRAME_DATA_SINGLE + 1;
- frame_type < FRAME_DATA_MAX_VALUE; ++frame_type) {
+ frame_type < FRAME_DATA_MAX_VALUE;
+ ++frame_type) {
malformed_frame_data.push_back(frame_type);
}
malformed_frame_data.push_back(FRAME_DATA_MAX_VALUE);
for (size_t i = 0; i < malformed_frame_data.size(); ++i) {
- malformed_packets.push_back(
- new ProtocolPacket(
- uid1, PROTOCOL_VERSION_3, PROTECTION_OFF, FRAME_TYPE_SINGLE, kControl,
- malformed_frame_data[i], some_session_id, 0u, some_message_id, NULL));
+ malformed_packets.push_back(new ProtocolPacket(uid1,
+ PROTOCOL_VERSION_3,
+ PROTECTION_OFF,
+ FRAME_TYPE_SINGLE,
+ kControl,
+ malformed_frame_data[i],
+ some_session_id,
+ 0u,
+ some_message_id,
+ NULL));
}
// We count malformed only first time when it occurs after correct message
@@ -383,7 +468,8 @@ TEST_F(IncomingDataHandlerTest, MalformedPacket_SingleFrame) {
EXPECT_EQ(0u, actual_frames.size());
++it;
- // All next data will be one large malformed message which we've already counted
+ // All next data will be one large malformed message which we've already
+ // counted
for (; it != malformed_packets.end(); ++it) {
ProcessPacket(**it);
EXPECT_EQ(RESULT_MALFORMED_OCCURS, result_code)
@@ -400,15 +486,22 @@ TEST_F(IncomingDataHandlerTest, MalformedPacket_FirstFrame) {
FrameList malformed_packets;
std::vector<uint8_t> malformed_frame_data;
for (uint8_t frame_type = FRAME_DATA_FIRST + 1;
- frame_type < FRAME_DATA_MAX_VALUE; ++frame_type) {
+ frame_type < FRAME_DATA_MAX_VALUE;
+ ++frame_type) {
malformed_frame_data.push_back(frame_type);
}
malformed_frame_data.push_back(FRAME_DATA_MAX_VALUE);
for (size_t i = 0; i < malformed_frame_data.size(); ++i) {
- malformed_packets.push_back(
- new ProtocolPacket(
- uid1, PROTOCOL_VERSION_3, PROTECTION_OFF, FRAME_TYPE_SINGLE, kControl,
- malformed_frame_data[i], some_session_id, 0u, some_message_id, NULL));
+ malformed_packets.push_back(new ProtocolPacket(uid1,
+ PROTOCOL_VERSION_3,
+ PROTECTION_OFF,
+ FRAME_TYPE_SINGLE,
+ kControl,
+ malformed_frame_data[i],
+ some_session_id,
+ 0u,
+ some_message_id,
+ NULL));
}
// We count malformed only first time when it occurs after correct message
@@ -419,7 +512,8 @@ TEST_F(IncomingDataHandlerTest, MalformedPacket_FirstFrame) {
EXPECT_EQ(0u, actual_frames.size());
++it;
- // All next data will be one large malformed message which we've already counted
+ // All next data will be one large malformed message which we've already
+ // counted
for (; it != malformed_packets.end(); ++it) {
ProcessPacket(**it);
EXPECT_EQ(RESULT_MALFORMED_OCCURS, result_code)
@@ -435,71 +529,106 @@ TEST_F(IncomingDataHandlerTest, MalformedPacket_FirstFrame) {
TEST_F(IncomingDataHandlerTest, MalformedPacket_AdditionalByte) {
FrameList mobile_packets;
// single packet RPC
- mobile_packets.push_back(
- new ProtocolPacket(
- uid1, PROTOCOL_VERSION_1, PROTECTION_OFF, FRAME_TYPE_SINGLE,
- kRpc, FRAME_DATA_SINGLE, some_session_id, some_data_size,
- protov1_message_id, some_data));
+ mobile_packets.push_back(new ProtocolPacket(uid1,
+ PROTOCOL_VERSION_1,
+ PROTECTION_OFF,
+ FRAME_TYPE_SINGLE,
+ kRpc,
+ FRAME_DATA_SINGLE,
+ some_session_id,
+ some_data_size,
+ protov1_message_id,
+ some_data));
AppendPacketToTMData(*mobile_packets.back());
// Add malformed byte
tm_data.insert(tm_data.end(), 1, 0x1);
// consecutive packet Audio
- mobile_packets.push_back(
- new ProtocolPacket(
- uid1, PROTOCOL_VERSION_2, PROTECTION_ON, FRAME_TYPE_CONSECUTIVE,
- kAudio, FRAME_DATA_LAST_CONSECUTIVE, ++some_session_id, some_data2_size,
- some_message_id, some_data2));
+ mobile_packets.push_back(new ProtocolPacket(uid1,
+ PROTOCOL_VERSION_2,
+ PROTECTION_ON,
+ FRAME_TYPE_CONSECUTIVE,
+ kAudio,
+ FRAME_DATA_LAST_CONSECUTIVE,
+ ++some_session_id,
+ some_data2_size,
+ some_message_id,
+ some_data2));
AppendPacketToTMData(*mobile_packets.back());
// Add malformed bytes
tm_data.insert(tm_data.end(), 2, 0x2);
// single packet Nav
- mobile_packets.push_back(
- new ProtocolPacket(
- uid1, PROTOCOL_VERSION_3, PROTECTION_ON, FRAME_TYPE_SINGLE,
- kMobileNav, FRAME_DATA_SINGLE, ++some_session_id, some_data_size,
- ++some_message_id, some_data));
+ mobile_packets.push_back(new ProtocolPacket(uid1,
+ PROTOCOL_VERSION_3,
+ PROTECTION_ON,
+ FRAME_TYPE_SINGLE,
+ kMobileNav,
+ FRAME_DATA_SINGLE,
+ ++some_session_id,
+ some_data_size,
+ ++some_message_id,
+ some_data));
AppendPacketToTMData(*mobile_packets.back());
// Add malformed bytes
tm_data.insert(tm_data.end(), 3, 0x3);
// consecutive packet Bulk
- mobile_packets.push_back(
- new ProtocolPacket(
- uid1, PROTOCOL_VERSION_3, PROTECTION_ON, FRAME_TYPE_CONSECUTIVE,
- kBulk, FRAME_DATA_LAST_CONSECUTIVE, ++some_session_id, some_data2_size,
- ++some_message_id, some_data2));
+ mobile_packets.push_back(new ProtocolPacket(uid1,
+ PROTOCOL_VERSION_3,
+ PROTECTION_ON,
+ FRAME_TYPE_CONSECUTIVE,
+ kBulk,
+ FRAME_DATA_LAST_CONSECUTIVE,
+ ++some_session_id,
+ some_data2_size,
+ ++some_message_id,
+ some_data2));
AppendPacketToTMData(*mobile_packets.back());
// Add malformed bytes
tm_data.insert(tm_data.end(), 4, 0x4);
// single packet RPC
- mobile_packets.push_back(
- new ProtocolPacket(
- uid1, PROTOCOL_VERSION_1, PROTECTION_OFF, FRAME_TYPE_CONTROL,
- kRpc, FRAME_DATA_HEART_BEAT, some_session_id, some_data_size,
- protov1_message_id, some_data));
+ mobile_packets.push_back(new ProtocolPacket(uid1,
+ PROTOCOL_VERSION_1,
+ PROTECTION_OFF,
+ FRAME_TYPE_CONTROL,
+ kRpc,
+ FRAME_DATA_HEART_BEAT,
+ some_session_id,
+ some_data_size,
+ protov1_message_id,
+ some_data));
AppendPacketToTMData(*mobile_packets.back());
// Add malformed bytes
tm_data.insert(tm_data.end(), 5, 0x5);
// single packet Audio
- mobile_packets.push_back(
- new ProtocolPacket(
- uid1, PROTOCOL_VERSION_1, PROTECTION_OFF, FRAME_TYPE_CONTROL,
- kAudio, FRAME_DATA_HEART_BEAT, some_session_id, some_data_size,
- protov1_message_id, some_data));
+ mobile_packets.push_back(new ProtocolPacket(uid1,
+ PROTOCOL_VERSION_1,
+ PROTECTION_OFF,
+ FRAME_TYPE_CONTROL,
+ kAudio,
+ FRAME_DATA_HEART_BEAT,
+ some_session_id,
+ some_data_size,
+ protov1_message_id,
+ some_data));
AppendPacketToTMData(*mobile_packets.back());
// Add malformed bytes
tm_data.insert(tm_data.end(), 6, 0x6);
// single packet RPC
- mobile_packets.push_back(
- new ProtocolPacket(
- uid1, PROTOCOL_VERSION_1, PROTECTION_OFF, FRAME_TYPE_SINGLE,
- kRpc, FRAME_DATA_SINGLE, some_session_id, some_data_size,
- protov1_message_id, some_data));
+ mobile_packets.push_back(new ProtocolPacket(uid1,
+ PROTOCOL_VERSION_1,
+ PROTECTION_OFF,
+ FRAME_TYPE_SINGLE,
+ kRpc,
+ FRAME_DATA_SINGLE,
+ some_session_id,
+ some_data_size,
+ protov1_message_id,
+ some_data));
AppendPacketToTMData(*mobile_packets.back());
ProcessData(uid1, &tm_data[0], tm_data.size());
@@ -509,11 +638,12 @@ TEST_F(IncomingDataHandlerTest, MalformedPacket_AdditionalByte) {
EXPECT_EQ(malformed_occurs, 6u);
FrameList::iterator it_exp = mobile_packets.begin();
- for (FrameList::const_iterator it = actual_frames.begin(); it != actual_frames.end();
+ for (FrameList::const_iterator it = actual_frames.begin();
+ it != actual_frames.end();
++it, ++it_exp) {
// TODO(EZamakhov): investigate valgrind warning (unitialized value)
- EXPECT_EQ(**it, **it_exp)
- << "Element number " << std::distance(mobile_packets.begin(), it_exp);
+ EXPECT_EQ(**it, **it_exp) << "Element number "
+ << std::distance(mobile_packets.begin(), it_exp);
}
}
@@ -521,51 +651,83 @@ TEST_F(IncomingDataHandlerTest, MalformedPacket_AdditionalByte) {
TEST_F(IncomingDataHandlerTest, MalformedPacket_Mix) {
FrameList mobile_packets;
// single packet RPC
- mobile_packets.push_back(
- new ProtocolPacket(
- uid1, PROTOCOL_VERSION_1, PROTECTION_OFF, FRAME_TYPE_SINGLE,
- kRpc, FRAME_DATA_SINGLE, some_session_id, some_data_size,
- protov1_message_id, some_data));
+ mobile_packets.push_back(new ProtocolPacket(uid1,
+ PROTOCOL_VERSION_1,
+ PROTECTION_OFF,
+ FRAME_TYPE_SINGLE,
+ kRpc,
+ FRAME_DATA_SINGLE,
+ some_session_id,
+ some_data_size,
+ protov1_message_id,
+ some_data));
AppendPacketToTMData(*mobile_packets.back());
// consecutive packet Audio
- mobile_packets.push_back(
- new ProtocolPacket(
- uid1, PROTOCOL_VERSION_2, PROTECTION_ON, FRAME_TYPE_CONSECUTIVE,
- kAudio, FRAME_DATA_LAST_CONSECUTIVE, ++some_session_id, some_data2_size,
- some_message_id, some_data2));
+ mobile_packets.push_back(new ProtocolPacket(uid1,
+ PROTOCOL_VERSION_2,
+ PROTECTION_ON,
+ FRAME_TYPE_CONSECUTIVE,
+ kAudio,
+ FRAME_DATA_LAST_CONSECUTIVE,
+ ++some_session_id,
+ some_data2_size,
+ some_message_id,
+ some_data2));
AppendPacketToTMData(*mobile_packets.back());
// Malformed packet 1
const uint8_t malformed_version = PROTOCOL_VERSION_MAX;
- const ProtocolPacket malformed_packet1(
- uid1, malformed_version, PROTECTION_ON, FRAME_TYPE_SINGLE,
- kMobileNav, FRAME_DATA_SINGLE, ++some_session_id, some_data_size,
- ++some_message_id, some_data);
+ const ProtocolPacket malformed_packet1(uid1,
+ malformed_version,
+ PROTECTION_ON,
+ FRAME_TYPE_SINGLE,
+ kMobileNav,
+ FRAME_DATA_SINGLE,
+ ++some_session_id,
+ some_data_size,
+ ++some_message_id,
+ some_data);
AppendPacketToTMData(malformed_packet1);
// consecutive packet Bulk
- mobile_packets.push_back(
- new ProtocolPacket(
- uid1, PROTOCOL_VERSION_3, PROTECTION_ON, FRAME_TYPE_CONSECUTIVE,
- kBulk, FRAME_DATA_LAST_CONSECUTIVE, ++some_session_id, some_data2_size,
- ++some_message_id, some_data2));
+ mobile_packets.push_back(new ProtocolPacket(uid1,
+ PROTOCOL_VERSION_3,
+ PROTECTION_ON,
+ FRAME_TYPE_CONSECUTIVE,
+ kBulk,
+ FRAME_DATA_LAST_CONSECUTIVE,
+ ++some_session_id,
+ some_data2_size,
+ ++some_message_id,
+ some_data2));
AppendPacketToTMData(*mobile_packets.back());
// Malformed packet 2
const uint8_t malformed_type = FRAME_TYPE_MAX_VALUE;
- ProtocolPacket malformed_packet2(
- uid1, PROTOCOL_VERSION_3, PROTECTION_OFF, malformed_type,
- kRpc, FRAME_DATA_HEART_BEAT, some_session_id, some_data_size,
- protov1_message_id, some_data);
+ ProtocolPacket malformed_packet2(uid1,
+ PROTOCOL_VERSION_3,
+ PROTECTION_OFF,
+ malformed_type,
+ kRpc,
+ FRAME_DATA_HEART_BEAT,
+ some_session_id,
+ some_data_size,
+ protov1_message_id,
+ some_data);
AppendPacketToTMData(malformed_packet2);
// Audio packet
- mobile_packets.push_back(
- new ProtocolPacket(
- uid1, PROTOCOL_VERSION_3, PROTECTION_OFF, FRAME_TYPE_CONTROL,
- kAudio, FRAME_DATA_HEART_BEAT, some_session_id, some_data_size,
- protov1_message_id, some_data));
+ mobile_packets.push_back(new ProtocolPacket(uid1,
+ PROTOCOL_VERSION_3,
+ PROTECTION_OFF,
+ FRAME_TYPE_CONTROL,
+ kAudio,
+ FRAME_DATA_HEART_BEAT,
+ some_session_id,
+ some_data_size,
+ protov1_message_id,
+ some_data));
AppendPacketToTMData(*mobile_packets.back());
ProcessData(uid1, &tm_data[0], tm_data.size());
@@ -573,21 +735,29 @@ TEST_F(IncomingDataHandlerTest, MalformedPacket_Mix) {
EXPECT_EQ(malformed_occurs, 2u);
EXPECT_EQ(mobile_packets.size(), actual_frames.size());
FrameList::iterator it_exp = mobile_packets.begin();
- for (FrameList::const_iterator it = actual_frames.begin(); it != actual_frames.end();
+ for (FrameList::const_iterator it = actual_frames.begin();
+ it != actual_frames.end();
++it, ++it_exp) {
// TODO(EZamakhov): investigate valgrind warning (unitialized value)
- EXPECT_EQ(**it, **it_exp)
- << "Element number " << std::distance(mobile_packets.begin(), it_exp);
+ EXPECT_EQ(**it, **it_exp) << "Element number "
+ << std::distance(mobile_packets.begin(), it_exp);
}
}
-TEST_F(IncomingDataHandlerTest, OnePortionOfData_CorrectAndMalformed_OneMalformedCounted) {
+TEST_F(IncomingDataHandlerTest,
+ OnePortionOfData_CorrectAndMalformed_OneMalformedCounted) {
// Arrange
- ProtocolPacket correct_hb_packet_(uid1, PROTOCOL_VERSION_3, PROTECTION_OFF, FRAME_TYPE_CONTROL,
- kControl, FRAME_DATA_HEART_BEAT, some_session_id, 0u,
+ ProtocolPacket correct_hb_packet_(uid1,
+ PROTOCOL_VERSION_3,
+ PROTECTION_OFF,
+ FRAME_TYPE_CONTROL,
+ kControl,
+ FRAME_DATA_HEART_BEAT,
+ some_session_id,
+ 0u,
some_message_id);
AppendPacketToTMData(correct_hb_packet_);
- tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
+ tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
// Act
ProcessData(uid1, &tm_data[0], tm_data.size());
@@ -598,12 +768,19 @@ TEST_F(IncomingDataHandlerTest, OnePortionOfData_CorrectAndMalformed_OneMalforme
EXPECT_EQ(1u, actual_frames.size());
}
-TEST_F(IncomingDataHandlerTest, FirstPortionOfData_MalformedAndCorrect_OneMalformedCounted) {
+TEST_F(IncomingDataHandlerTest,
+ FirstPortionOfData_MalformedAndCorrect_OneMalformedCounted) {
// Arrange
- ProtocolPacket correct_hb_packet_(uid1, PROTOCOL_VERSION_3, PROTECTION_OFF, FRAME_TYPE_CONTROL,
- kControl, FRAME_DATA_HEART_BEAT, some_session_id, 0u,
+ ProtocolPacket correct_hb_packet_(uid1,
+ PROTOCOL_VERSION_3,
+ PROTECTION_OFF,
+ FRAME_TYPE_CONTROL,
+ kControl,
+ FRAME_DATA_HEART_BEAT,
+ some_session_id,
+ 0u,
some_message_id);
- tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
+ tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
AppendPacketToTMData(correct_hb_packet_);
// Act
@@ -615,13 +792,20 @@ TEST_F(IncomingDataHandlerTest, FirstPortionOfData_MalformedAndCorrect_OneMalfor
EXPECT_EQ(1u, actual_frames.size());
}
-TEST_F(IncomingDataHandlerTest, OnePortionOfData_CorrectMalformedCorrect_OneMalformedCounted) {
+TEST_F(IncomingDataHandlerTest,
+ OnePortionOfData_CorrectMalformedCorrect_OneMalformedCounted) {
// Arrange
- ProtocolPacket correct_hb_packet_(uid1, PROTOCOL_VERSION_3, PROTECTION_OFF, FRAME_TYPE_CONTROL,
- kControl, FRAME_DATA_HEART_BEAT, some_session_id, 0u,
+ ProtocolPacket correct_hb_packet_(uid1,
+ PROTOCOL_VERSION_3,
+ PROTECTION_OFF,
+ FRAME_TYPE_CONTROL,
+ kControl,
+ FRAME_DATA_HEART_BEAT,
+ some_session_id,
+ 0u,
some_message_id);
AppendPacketToTMData(correct_hb_packet_);
- tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
+ tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
AppendPacketToTMData(correct_hb_packet_);
// Act
@@ -633,15 +817,22 @@ TEST_F(IncomingDataHandlerTest, OnePortionOfData_CorrectMalformedCorrect_OneMalf
EXPECT_EQ(2u, actual_frames.size());
}
-TEST_F(IncomingDataHandlerTest, OnePortionOfData_CorrectMalformedCorrectMalformed_TwoMalformedCounted) {
+TEST_F(IncomingDataHandlerTest,
+ OnePortionOfData_CorrectMalformedCorrectMalformed_TwoMalformedCounted) {
// Arrange
- ProtocolPacket correct_hb_packet_(uid1, PROTOCOL_VERSION_3, PROTECTION_OFF, FRAME_TYPE_CONTROL,
- kControl, FRAME_DATA_HEART_BEAT, some_session_id, 0u,
+ ProtocolPacket correct_hb_packet_(uid1,
+ PROTOCOL_VERSION_3,
+ PROTECTION_OFF,
+ FRAME_TYPE_CONTROL,
+ kControl,
+ FRAME_DATA_HEART_BEAT,
+ some_session_id,
+ 0u,
some_message_id);
AppendPacketToTMData(correct_hb_packet_);
- tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
+ tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
AppendPacketToTMData(correct_hb_packet_);
- tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
+ tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
// Act
ProcessData(uid1, &tm_data[0], tm_data.size());
@@ -652,14 +843,21 @@ TEST_F(IncomingDataHandlerTest, OnePortionOfData_CorrectMalformedCorrectMalforme
EXPECT_EQ(2u, actual_frames.size());
}
-TEST_F(IncomingDataHandlerTest, OnePortionOfData_MalformedCorrectMalformedCorrect_TwoMalformedCounted) {
+TEST_F(IncomingDataHandlerTest,
+ OnePortionOfData_MalformedCorrectMalformedCorrect_TwoMalformedCounted) {
// Arrange
- ProtocolPacket correct_hb_packet_(uid1, PROTOCOL_VERSION_3, PROTECTION_OFF, FRAME_TYPE_CONTROL,
- kControl, FRAME_DATA_HEART_BEAT, some_session_id, 0u,
+ ProtocolPacket correct_hb_packet_(uid1,
+ PROTOCOL_VERSION_3,
+ PROTECTION_OFF,
+ FRAME_TYPE_CONTROL,
+ kControl,
+ FRAME_DATA_HEART_BEAT,
+ some_session_id,
+ 0u,
some_message_id);
- tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
+ tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
AppendPacketToTMData(correct_hb_packet_);
- tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
+ tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
AppendPacketToTMData(correct_hb_packet_);
// Act
@@ -671,13 +869,21 @@ TEST_F(IncomingDataHandlerTest, OnePortionOfData_MalformedCorrectMalformedCorrec
EXPECT_EQ(2u, actual_frames.size());
}
-TEST_F(IncomingDataHandlerTest, TwoPortionsOfData_CorrectMalformedANDCorrectMalformed_TwoMalformedCounted) {
+TEST_F(
+ IncomingDataHandlerTest,
+ TwoPortionsOfData_CorrectMalformedANDCorrectMalformed_TwoMalformedCounted) {
// Arrange
- ProtocolPacket correct_hb_packet_(uid1, PROTOCOL_VERSION_3, PROTECTION_OFF, FRAME_TYPE_CONTROL,
- kControl, FRAME_DATA_HEART_BEAT, some_session_id, 0u,
+ ProtocolPacket correct_hb_packet_(uid1,
+ PROTOCOL_VERSION_3,
+ PROTECTION_OFF,
+ FRAME_TYPE_CONTROL,
+ kControl,
+ FRAME_DATA_HEART_BEAT,
+ some_session_id,
+ 0u,
some_message_id);
AppendPacketToTMData(correct_hb_packet_);
- tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
+ tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
// Act
ProcessData(uid1, &tm_data[0], tm_data.size());
@@ -690,7 +896,7 @@ TEST_F(IncomingDataHandlerTest, TwoPortionsOfData_CorrectMalformedANDCorrectMalf
// Arrange
tm_data.clear();
AppendPacketToTMData(correct_hb_packet_);
- tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
+ tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
// Act
ProcessData(uid1, &tm_data[0], tm_data.size());
@@ -701,13 +907,21 @@ TEST_F(IncomingDataHandlerTest, TwoPortionsOfData_CorrectMalformedANDCorrectMalf
EXPECT_EQ(1u, actual_frames.size());
}
-TEST_F(IncomingDataHandlerTest, TwoPortionsOfData_CorrectMalformedANDMalformedCorrect_OneMalformedCounted) {
+TEST_F(
+ IncomingDataHandlerTest,
+ TwoPortionsOfData_CorrectMalformedANDMalformedCorrect_OneMalformedCounted) {
// Arrange
- ProtocolPacket correct_hb_packet_(uid1, PROTOCOL_VERSION_3, PROTECTION_OFF, FRAME_TYPE_CONTROL,
- kControl, FRAME_DATA_HEART_BEAT, some_session_id, 0u,
+ ProtocolPacket correct_hb_packet_(uid1,
+ PROTOCOL_VERSION_3,
+ PROTECTION_OFF,
+ FRAME_TYPE_CONTROL,
+ kControl,
+ FRAME_DATA_HEART_BEAT,
+ some_session_id,
+ 0u,
some_message_id);
AppendPacketToTMData(correct_hb_packet_);
- tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
+ tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
// Act
ProcessData(uid1, &tm_data[0], tm_data.size());
@@ -719,7 +933,7 @@ TEST_F(IncomingDataHandlerTest, TwoPortionsOfData_CorrectMalformedANDMalformedCo
// Arrange
tm_data.clear();
- tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
+ tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
AppendPacketToTMData(correct_hb_packet_);
// Act
@@ -731,12 +945,20 @@ TEST_F(IncomingDataHandlerTest, TwoPortionsOfData_CorrectMalformedANDMalformedCo
EXPECT_EQ(1u, actual_frames.size());
}
-TEST_F(IncomingDataHandlerTest, TwoPortionsOfData_MalformedCorrectANDMalformedCorrect_TwoMalformedCounted) {
+TEST_F(
+ IncomingDataHandlerTest,
+ TwoPortionsOfData_MalformedCorrectANDMalformedCorrect_TwoMalformedCounted) {
// Arrange
- ProtocolPacket correct_hb_packet_(uid1, PROTOCOL_VERSION_3, PROTECTION_OFF, FRAME_TYPE_CONTROL,
- kControl, FRAME_DATA_HEART_BEAT, some_session_id, 0u,
+ ProtocolPacket correct_hb_packet_(uid1,
+ PROTOCOL_VERSION_3,
+ PROTECTION_OFF,
+ FRAME_TYPE_CONTROL,
+ kControl,
+ FRAME_DATA_HEART_BEAT,
+ some_session_id,
+ 0u,
some_message_id);
- tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
+ tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
AppendPacketToTMData(correct_hb_packet_);
// Act
@@ -749,7 +971,7 @@ TEST_F(IncomingDataHandlerTest, TwoPortionsOfData_MalformedCorrectANDMalformedCo
// Arrange
tm_data.clear();
- tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
+ tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
AppendPacketToTMData(correct_hb_packet_);
// Act
@@ -761,12 +983,20 @@ TEST_F(IncomingDataHandlerTest, TwoPortionsOfData_MalformedCorrectANDMalformedCo
EXPECT_EQ(1u, actual_frames.size());
}
-TEST_F(IncomingDataHandlerTest, TwoPortionsOfData_MalformedCorrectANDCorrectMalformed_TwoMalformedCounted) {
+TEST_F(
+ IncomingDataHandlerTest,
+ TwoPortionsOfData_MalformedCorrectANDCorrectMalformed_TwoMalformedCounted) {
// Arrange
- ProtocolPacket correct_hb_packet_(uid1, PROTOCOL_VERSION_3, PROTECTION_OFF, FRAME_TYPE_CONTROL,
- kControl, FRAME_DATA_HEART_BEAT, some_session_id, 0u,
+ ProtocolPacket correct_hb_packet_(uid1,
+ PROTOCOL_VERSION_3,
+ PROTECTION_OFF,
+ FRAME_TYPE_CONTROL,
+ kControl,
+ FRAME_DATA_HEART_BEAT,
+ some_session_id,
+ 0u,
some_message_id);
- tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
+ tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
AppendPacketToTMData(correct_hb_packet_);
// Act
@@ -780,7 +1010,7 @@ TEST_F(IncomingDataHandlerTest, TwoPortionsOfData_MalformedCorrectANDCorrectMalf
// Arrange
tm_data.clear();
AppendPacketToTMData(correct_hb_packet_);
- tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
+ tm_data.insert(tm_data.end(), 12, 0xFF); // 12 bytes of malformed data
// Act
ProcessData(uid1, &tm_data[0], tm_data.size());
View Lorry Controller Status