Home
last modified time | relevance | path

Searched refs:SetMessageType (Results 1 – 25 of 26) sorted by relevance

12

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_ability_sync_test.cpp135 msg1.SetMessageType(TYPE_REQUEST);
152 msg2.SetMessageType(TYPE_REQUEST);
186 msg1.SetMessageType(TYPE_REQUEST);
203 msg2.SetMessageType(TYPE_REQUEST);
237 msg1.SetMessageType(TYPE_REQUEST);
254 msg2.SetMessageType(TYPE_REQUEST);
294 msg1.SetMessageType(TYPE_REQUEST);
311 msg2.SetMessageType(TYPE_REQUEST);
352 msg1.SetMessageType(TYPE_RESPONSE);
369 msg2.SetMessageType(TYPE_RESPONSE);
[all …]
H A Ddistributeddb_multi_ver_p2p_sync_test.cpp646 oriMsgA.SetMessageType(TYPE_REQUEST);
649 oriMsgB.SetMessageType(TYPE_RESPONSE);
675 outMsgA.SetMessageType(TYPE_REQUEST);
812 oriMsgA.SetMessageType(TYPE_REQUEST);
815 oriMsgB.SetMessageType(TYPE_REQUEST);
841 outMsgA.SetMessageType(TYPE_REQUEST);
854 outMsgB.SetMessageType(TYPE_REQUEST);
1011 oriMsgA.SetMessageType(TYPE_REQUEST);
1014 oriMsgB.SetMessageType(TYPE_REQUEST);
1040 outMsgA.SetMessageType(TYPE_REQUEST);
[all …]
H A Ddistributeddb_time_sync_test.cpp341 msg->SetMessageType(TYPE_REQUEST);
358 msg->SetMessageType(TYPE_REQUEST);
369 msg->SetMessageType(TYPE_RESPONSE);
409 msg->SetMessageType(TYPE_RESPONSE);
426 msg->SetMessageType(TYPE_RESPONSE);
437 msg->SetMessageType(TYPE_REQUEST);
H A Ddistributeddb_anti_dos_sync_test.cpp187 message->SetMessageType(TYPE_REQUEST);
239 message->SetMessageType(TYPE_REQUEST);
304 message->SetMessageType(TYPE_REQUEST);
H A Ddistributeddb_single_ver_p2p_query_sync_test.cpp644 msg.SetMessageType(TYPE_REQUEST);
657 outMsg.SetMessageType(TYPE_REQUEST);
694 msg.SetMessageType(TYPE_INVALID);
737 msg.SetMessageType(TYPE_RESPONSE);
754 outMsg.SetMessageType(TYPE_RESPONSE);
H A Ddistributeddb_single_ver_p2p_subscribe_sync_test.cpp286 msg.SetMessageType(TYPE_REQUEST);
302 outMsg.SetMessageType(TYPE_REQUEST);
339 msg.SetMessageType(TYPE_RESPONSE);
356 outMsg.SetMessageType(TYPE_RESPONSE);
H A Ddistributeddb_mock_sync_module_test.cpp147 message->SetMessageType(TYPE_REQUEST); in BuildRemoteQueryMsg()
504 message->SetMessageType(TYPE_RESPONSE);
689 msg.SetMessageType(TYPE_NOTIFY);
754 message->SetMessageType(TYPE_NOTIFY);
811 message->SetMessageType(TYPE_NOTIFY);
H A Ddistributeddb_single_ver_p2p_sync_check_test.cpp787 inMsg->SetMessageType(TYPE_INVALID); in RegOnDispatchWithOffline()
800 inMsg->SetMessageType(TYPE_INVALID); in RegOnDispatchWithInvalidMsg()
1302 inMsg->SetMessageType(TYPE_INVALID); in RegOnDispatchWithInvalidMsgAndCnt()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Ddistributeddb_communicator_common.cpp203 outMsg->SetMessageType(TYPE_REQUEST); in BuildRegedTinyMessage()
231 outMsg->SetMessageType(TYPE_RESPONSE); in BuildRegedHugeMessage()
273 outMsg->SetMessageType(TYPE_NOTIFY); in BuildRegedGiantMessage()
301 outMsg->SetMessageType(TYPE_NOTIFY); in BuildRegedOverSizeMessage()
329 outMsg->SetMessageType(TYPE_NOTIFY); in BuildUnRegedTinyMessage()
/ohos5.0/foundation/communication/dsoftbus/tests/core/connection/wifi_direct_cpp/data/
H A Dnegotiate_message_test.cpp63 msg.SetMessageType(NegotiateMessageType::CMD_CONN_V2_REQ_1);
181 msg1.SetMessageType(NegotiateMessageType::CMD_CONN_V2_REQ_1);
362 msg.SetMessageType(LegacyCommandType::CMD_DISCONNECT_V1_REQ);
363 msg.SetMessageType(NegotiateMessageType::CMD_V3_REQ);
401 msg.SetMessageType(NegotiateMessageType::CMD_INVALID);
/ohos5.0/foundation/communication/dsoftbus/core/connection/wifi_direct_cpp/data/
H A Dnegotiate_message.h147 void SetMessageType(NegotiateMessageType value);
148 void SetMessageType(LegacyCommandType value);
H A Dnegotiate_message.cpp144 SetMessageType(type); in NegotiateMessage()
149 SetMessageType(type); in NegotiateMessage()
336 void NegotiateMessage::SetMessageType(NegotiateMessageType value) in SetMessageType() function in OHOS::SoftBus::NegotiateMessage
341 void NegotiateMessage::SetMessageType(LegacyCommandType value) in SetMessageType() function in OHOS::SoftBus::NegotiateMessage
/ohos5.0/foundation/communication/dsoftbus/tests/core/connection/fuzztest/softbusnegotiatemessage_fuzzer/
H A Dsoftbusnegotiatemessage_fuzzer.cpp60 msg1.SetMessageType(GetData<SoftBus::NegotiateMessageType>()); in SoftBusNegotiateMessageUnmarshallingFuzzTest()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
H A Dvalue_slice_sync.cpp328 message->SetMessageType(TYPE_REQUEST); in SendFinishedRequest()
564 message->SetMessageType(TYPE_REQUEST); in SendRequestPacket()
608 ackMessage->SetMessageType(TYPE_RESPONSE); in SendAckPacket()
H A Dmulti_ver_data_sync.cpp336 message->SetMessageType(TYPE_REQUEST); in SendFinishedRequest()
604 message->SetMessageType(TYPE_REQUEST); in SendRequestPacket()
661 ackMessage->SetMessageType(TYPE_RESPONSE); in SendAckPacket()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/
H A Dmessage.h111 int SetMessageType(uint16_t inMsgType) in SetMessageType() function
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Dcommunicator.cpp250 oriMsg->SetMessageType(TYPE_RESPONSE); in TriggerUnknownMessageFeedback()
H A Dcommunicator_aggregator.cpp841 oriMsg->SetMessageType(TYPE_RESPONSE); in TriggerCommunicatorNotFoundFeedback()
H A Dprotocol_proto.cpp680 inMsg->SetMessageType(messageHdr.messageType); in DeSerializeMessage()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dcommit_history_sync.cpp633 message->SetMessageType(TYPE_REQUEST); in SendRequestPacket()
683 ackMessage->SetMessageType(TYPE_RESPONSE); in SendAckPacket()
H A Dability_sync.cpp392 message->SetMessageType(TYPE_REQUEST); in SyncStart()
1197 …(!isAckNotify) ? ackMessage->SetMessageType(TYPE_RESPONSE) : ackMessage->SetMessageType(TYPE_NOTIF… in SendAck()
H A Dtime_sync.cpp245 message->SetMessageType(TYPE_REQUEST); in SyncStart()
432 ackMessage->SetMessageType(TYPE_RESPONSE); in RequestRecv()
H A Dremote_executor.cpp484 message->SetMessageType(TYPE_REQUEST); in RequestStart()
604 message->SetMessageType(TYPE_RESPONSE); in ResponseStart()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync_utils.cpp380 message.SetMessageType(inMsgType); in SetMessageHeadInfo()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
H A Ddistributeddb_tools_unit_test.cpp1069 message->SetMessageType(messageInfo.messageType_); in BuildMessage()

12