Home
last modified time | relevance | path

Searched refs:outMsg (Results 1 - 13 of 13) sorted by relevance

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Ddistributeddb_communicator_common.cpp188 Message *outMsg = new (nothrow) Message(REGED_TINY_MSG_ID); in BuildRegedTinyMessage() local
189 if (outMsg == nullptr) { in BuildRegedTinyMessage()
195 int errCode = outMsg->SetExternalObject(obj); in BuildRegedTinyMessage()
199 delete outMsg; in BuildRegedTinyMessage()
200 outMsg = nullptr; in BuildRegedTinyMessage()
203 outMsg->SetMessageType(TYPE_REQUEST); in BuildRegedTinyMessage()
204 outMsg->SetSessionId(FIXED_SESSIONID); in BuildRegedTinyMessage()
205 outMsg->SetSequenceId(FIXED_SEQUENCEID); in BuildRegedTinyMessage()
207 return outMsg; in BuildRegedTinyMessage()
217 Message *outMsg in BuildRegedHugeMessage() local
251 Message *outMsg = new (nothrow) Message(REGED_GIANT_MSG_ID); BuildRegedGiantMessage() local
287 Message *outMsg = new (nothrow) Message(REGED_OVERSIZE_MSG_ID); BuildRegedOverSizeMessage() local
315 Message *outMsg = new (nothrow) Message(UNREGED_TINY_MSG_ID); BuildUnRegedTinyMessage() local
[all...]
/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/proxy_channel/
H A Dtrans_proxy_message_test.cpp463 ProxyMessage msg, outMsg; in HWTEST_F() local
481 int32_t ret = TransProxyParseMessage(buf, len, &outMsg); in HWTEST_F()
484 ret = TransProxyParseMessage(buf, len, &outMsg); in HWTEST_F()
498 ProxyMessage msg, outMsg; in HWTEST_F() local
530 int32_t ret = TransProxyParseMessage(buf, len, &outMsg); in HWTEST_F()
533 ret = TransProxyParseMessage(buf, len, &outMsg); in HWTEST_F()
536 ret = TransProxyParseMessage(buf, len, &outMsg); in HWTEST_F()
541 ret = TransProxyParseMessage(buf, len, &outMsg); in HWTEST_F()
545 ret = TransProxyParseMessage(buf, len, &outMsg); in HWTEST_F()
547 ret = TransProxyParseMessage(buf, len, &outMsg); in HWTEST_F()
[all...]
H A Dsoftbus_proxychannel_message_test.cpp515 ProxyMessage msg, outMsg; in HWTEST_F() local
527 int32_t ret = TransProxyParseMessage(buf, len, &outMsg, &authHandle); in HWTEST_F()
530 ret = TransProxyParseMessage(buf, len, &outMsg, &authHandle); in HWTEST_F()
544 ProxyMessage msg, outMsg; in HWTEST_F() local
563 int32_t ret = TransProxyParseMessage(buf, len, &outMsg, &authHandle); in HWTEST_F()
566 ret = TransProxyParseMessage(buf, len, &outMsg, &authHandle); in HWTEST_F()
569 ret = TransProxyParseMessage(buf, len, &outMsg, &authHandle); in HWTEST_F()
574 ret = TransProxyParseMessage(buf, len, &outMsg, &authHandle); in HWTEST_F()
578 ret = TransProxyParseMessage(buf, len, &outMsg, &authHandle); in HWTEST_F()
580 ret = TransProxyParseMessage(buf, len, &outMsg, in HWTEST_F()
[all...]
/foundation/ai/intelligent_voice_framework/utils/
H A Dstate_manager.h36 void *outMsg = nullptr; member
40 : msgId(id), inMsg(in), inMsgLen(inLen), outMsg(out) {}; in StateMsg()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dvirtual_communicator.cpp216 int VirtualCommunicator::TranslateMsg(const Message *inMsg, Message *&outMsg) in TranslateMsg() argument
225 outMsg = ProtocolProto::ToMessage(buffer, errCode); in TranslateMsg()
H A Dvirtual_communicator.h90 static int TranslateMsg(const Message *inMsg, Message *&outMsg);
H A Ddistributeddb_single_ver_p2p_subscribe_sync_test.cpp300 Message outMsg; in HWTEST_F() local
301 outMsg.SetMessageId(CONTROL_SYNC_MESSAGE); in HWTEST_F()
302 outMsg.SetMessageType(TYPE_REQUEST); in HWTEST_F()
303 ASSERT_EQ(SingleVerSerializeManager::DeSerialization(buffer, len, &outMsg), E_OK); in HWTEST_F()
306 * @tc.steps: step5. checkout the outMsg. in HWTEST_F()
307 * @tc.expected: step5. outMsg equal the the in msg in HWTEST_F()
309 auto outPacket = outMsg.GetObject<SubscribeRequest>(); in HWTEST_F()
354 Message outMsg; in HWTEST_F() local
355 outMsg.SetMessageId(CONTROL_SYNC_MESSAGE); in HWTEST_F()
356 outMsg in HWTEST_F()
[all...]
H A Ddistributeddb_single_ver_p2p_query_sync_test.cpp656 Message outMsg(QUERY_SYNC_MESSAGE); in HWTEST_F()
657 outMsg.SetMessageType(TYPE_REQUEST); in HWTEST_F()
658 ASSERT_EQ(SingleVerSerializeManager::DeSerialization(buffer.data(), buffer.size(), &outMsg), E_OK); in HWTEST_F()
661 * @tc.steps: step5. checkout the outMsg. in HWTEST_F()
662 * @tc.expected: step5. outMsg equal the the in msg in HWTEST_F()
664 auto outPacket = outMsg.GetObject<DataRequestPacket>(); in HWTEST_F()
752 Message outMsg; in HWTEST_F() local
753 outMsg.SetMessageId(QUERY_SYNC_MESSAGE); in HWTEST_F()
754 outMsg.SetMessageType(TYPE_RESPONSE); in HWTEST_F()
755 errCode = SingleVerSerializeManager::DeSerialization(buffer, len, &outMsg); in HWTEST_F()
[all...]
/foundation/communication/ipc/ipc/native/c/ipc/src/liteos_a/include/
H A Dlite_ipc.h72 IpcMsg *outMsg; /**< data to send to target */ member
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Dprotocol_proto.cpp161 Message *outMsg = new (std::nothrow) Message(); in ToMessage() local
162 if (outMsg == nullptr) { in ToMessage()
166 int errCode = DeSerializeMessage(inBuff, outMsg, onlyMsgHeader); in ToMessage()
170 delete outMsg; in ToMessage()
171 outMsg = nullptr; in ToMessage()
176 return outMsg; in ToMessage()
/foundation/ai/intelligent_voice_framework/services/intell_voice_engine/server/wakeup/
H A Dwakeup_engine_impl.cpp365 StringParam *value = reinterpret_cast<StringParam *>(msg.outMsg); in HandleGetParam()
548 CapturerData *capturerData = reinterpret_cast<CapturerData *>(msg.outMsg); in HandleRead()
588 CapturerData *capturerData = reinterpret_cast<CapturerData *>(msg.outMsg); in HandleGetWakeupPcm()
/foundation/communication/ipc/ipc/native/c/ipc/src/liteos_a/
H A Dipc_invoker.c217 .outMsg = &out, in SendReply()
254 .outMsg = &out, in SendFailedReply()
584 .outMsg = &msg, in IpcSendRequest()
/foundation/ai/intelligent_voice_framework/services/intell_voice_engine/server/wakeup/headset/
H A Dheadset_wakeup_engine_impl.cpp358 CapturerData *capturerData = reinterpret_cast<CapturerData *>(msg.outMsg); in HandleRead()

Completed in 13 milliseconds