Home
last modified time | relevance | path

Searched refs:messageInfo (Results 1 - 16 of 16) sorted by relevance

/foundation/communication/ipc/ipc/native/src/mock/include/
H A Ddbinder_base_invoker_object.h336 std::shared_ptr<ThreadMessageInfo> messageInfo) in HandleReply()
344 if (messageInfo == nullptr) { in HandleReply()
350 if (messageInfo->flags & MessageOption::TF_STATUS_CODE) { in HandleReply()
351 int32_t err = static_cast<int32_t>(messageInfo->offsetsSize); in HandleReply()
354 if (messageInfo->buffer == nullptr) { in HandleReply()
371 reply->ParseFrom(reinterpret_cast<uintptr_t>(messageInfo->buffer), messageInfo->bufferSize); in HandleReply()
373 if (messageInfo->offsetsSize > 0) { in HandleReply()
375 reinterpret_cast<binder_uintptr_t>(reinterpret_cast<char *>(messageInfo->buffer) + messageInfo in HandleReply()
335 HandleReply(uint64_t seqNumber, MessageParcel *reply, std::shared_ptr<ThreadMessageInfo> messageInfo) HandleReply() argument
404 std::shared_ptr<ThreadMessageInfo> messageInfo = MakeThreadMessageInfo(handle); WaitForReply() local
476 std::shared_ptr<ThreadMessageInfo> messageInfo = std::make_shared<struct ThreadMessageInfo>(); MakeThreadMessageInfo() local
[all...]
H A Ddbinder_base_invoker_process.h129 std::shared_ptr<ThreadMessageInfo> messageInfo = current->QueryThreadBySeqNumber(tr->seqNumber); in ProcessReply() local
131 while (messageInfo == nullptr) { in ProcessReply()
137 return; // messageInfo is null, no thread need to wakeup in ProcessReply()
140 messageInfo = current->QueryThreadBySeqNumber(tr->seqNumber); in ProcessReply()
144 messageInfo->buffer = new (std::nothrow) unsigned char[tr->sizeOfSelf - sizeof(dbinder_transaction_data)]; in ProcessReply()
145 if (messageInfo->buffer == nullptr) { in ProcessReply()
154 int memcpyResult = memcpy_s(messageInfo->buffer, tr->sizeOfSelf - sizeof(dbinder_transaction_data), tr->buffer, in ProcessReply()
160 delete[](unsigned char *) messageInfo->buffer; in ProcessReply()
161 messageInfo->buffer = nullptr; in ProcessReply()
167 messageInfo in ProcessReply()
[all...]
H A Ddbinder_base_invoker_define.h110 int HandleReply(uint64_t seqNumber, MessageParcel *reply, std::shared_ptr<ThreadMessageInfo> messageInfo);
/foundation/communication/ipc/ipc/native/c/rpc/src/
H A Ddbinder_invoker.c248 ThreadMessageInfo *messageInfo = (ThreadMessageInfo *)malloc(sizeof(ThreadMessageInfo)); in MakeThreadMessageInfo() local
249 if (messageInfo == NULL) { in MakeThreadMessageInfo()
250 RPC_LOG_ERROR("messageInfo malloc failed"); in MakeThreadMessageInfo()
254 messageInfo->threadId = pthread_self(); in MakeThreadMessageInfo()
255 messageInfo->seqNumber = seqNumber; in MakeThreadMessageInfo()
256 messageInfo->buffer = NULL; in MakeThreadMessageInfo()
257 messageInfo->offsets = 0; in MakeThreadMessageInfo()
258 messageInfo->sessionId = handle; in MakeThreadMessageInfo()
259 return messageInfo; in MakeThreadMessageInfo()
269 ThreadMessageInfo *messageInfo in HandleReply() local
298 ThreadMessageInfo *messageInfo = MakeThreadMessageInfo(seqNumber, handle); WaitForReply() local
410 ThreadMessageInfo *messageInfo = QueryThreadBySeqNumber(tr->seqNumber); ProcessReply() local
[all...]
H A Drpc_process_skeleton.c350 static int32_t AddThreadBySeqNumber(ThreadMessageInfo *messageInfo) in AddThreadBySeqNumber() argument
353 UtilsListAdd(&g_seqNumberToThread.list, &messageInfo->list); in AddThreadBySeqNumber()
358 int32_t AddSendThreadInWait(uint64_t seqNumber, ThreadMessageInfo *messageInfo, uint32_t userWaitTime) in AddSendThreadInWait() argument
360 if (AddThreadBySeqNumber(messageInfo) != ERR_NONE) { in AddSendThreadInWait()
365 SocketThreadLockInfo *threadLockInfo = QueryThreadLockInfo(messageInfo->threadId); in AddSendThreadInWait()
375 threadLockInfo->threadId = messageInfo->threadId; in AddSendThreadInWait()
407 void EraseThreadBySeqNumber(ThreadMessageInfo *messageInfo) in EraseThreadBySeqNumber() argument
410 UtilsListDelete(&messageInfo->list); in EraseThreadBySeqNumber()
431 ThreadMessageInfo *messageInfo = QueryThreadBySeqNumber(seqNumber); in WakeUpThreadBySeqNumber() local
432 if (messageInfo in WakeUpThreadBySeqNumber()
[all...]
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/test/unittest/src/
H A Dapp_pipe_mgr_test.cpp262 MessageInfo messageInfo = { MessageType::DEFAULT }; in HWTEST_F() local
265 auto ret = appPipeMgr.SendData(pipeInfo, deviceId, dataInfo, size, messageInfo); in HWTEST_F()
271 ret = appPipeMgr.SendData(pipeInfo1, deviceId1, dataInfo, size, messageInfo); in HWTEST_F()
277 ret = appPipeMgr.SendData(pipeInfo1, deviceId2, dataInfo1, size, messageInfo); in HWTEST_F()
283 ret = appPipeMgr.SendData(pipeInfo1, deviceId2, dataInfo2, size, messageInfo); in HWTEST_F()
288 ret = appPipeMgr.SendData(pipeInfo1, deviceId2, dataInfo3, size, messageInfo); in HWTEST_F()
305 MessageInfo messageInfo = { MessageType::DEFAULT }; in HWTEST_F() local
307 auto ret = appPipeMgr->SendData(pipeInfo, deviceId, dataInfo, size, messageInfo); in HWTEST_F()
324 MessageInfo messageInfo = { MessageType::DEFAULT }; in HWTEST_F() local
328 ret = appPipeMgr.SendData(pipeInfo, deviceId, dataInfo, size, messageInfo); in HWTEST_F()
[all...]
H A Dcommunicator_test.cpp496 MessageInfo messageInfo = {MessageType::DEFAULT}; in HWTEST_F() local
498 auto ret = softBusAdapter.SendData(pipeInfo, deviceId, dataInfo, size, messageInfo); in HWTEST_F()
/foundation/communication/ipc/ipc/native/test/unittest/common/
H A Dipc_process_skeleton_unittest.cpp606 std::shared_ptr<ThreadMessageInfo> messageInfo = in HWTEST_F() local
608 skeleton->AddThreadBySeqNumber(seqNumber, messageInfo); in HWTEST_F()
634 auto messageInfo = std::make_shared<ThreadMessageInfo>(); in HWTEST_F() local
635 messageInfo->socketId = handler; in HWTEST_F()
636 skeleton->AddThreadBySeqNumber(seqNumber, messageInfo); in HWTEST_F()
677 auto messageInfo = std::make_shared<ThreadMessageInfo>(); in HWTEST_F() local
678 messageInfo->socketId = 0; in HWTEST_F()
679 skeleton->AddThreadBySeqNumber(seqNumber, messageInfo); in HWTEST_F()
700 auto messageInfo = std::make_shared<ThreadMessageInfo>(); in HWTEST_F() local
701 messageInfo in HWTEST_F()
734 auto messageInfo = std::make_shared<ThreadMessageInfo>(); HWTEST_F() local
759 auto messageInfo = std::make_shared<ThreadMessageInfo>(); HWTEST_F() local
784 auto messageInfo = std::make_shared<ThreadMessageInfo>(); HWTEST_F() local
816 auto messageInfo = std::make_shared<ThreadMessageInfo>(); HWTEST_F() local
845 auto messageInfo = std::make_shared<ThreadMessageInfo>(); HWTEST_F() local
[all...]
/foundation/communication/ipc/ipc/native/test/fuzztest/core/ipcprocessskeleton_fuzzer/
H A Dipcprocessskeleton_fuzzer.cpp500 std::shared_ptr<ThreadMessageInfo> messageInfo = std::make_shared<ThreadMessageInfo>(); in EraseThreadBySeqNumberTest() local
501 current->AddThreadBySeqNumber(seqNumber, messageInfo); in EraseThreadBySeqNumberTest()
531 std::shared_ptr<ThreadMessageInfo> messageInfo = std::make_shared<ThreadMessageInfo>(); in AddSendThreadInWaitTest001() local
532 current->AddSendThreadInWait(seqNumber, messageInfo, 1); in AddSendThreadInWaitTest001()
542 std::shared_ptr<ThreadMessageInfo> messageInfo = std::make_shared<ThreadMessageInfo>(); in AddSendThreadInWaitTest002() local
543 if (messageInfo == nullptr) { in AddSendThreadInWaitTest002()
548 if (!GenerateUint64(seqNumber) || !GenerateBool(messageInfo->ready) || !GenerateInt32(handle)) { in AddSendThreadInWaitTest002()
551 messageInfo->socketId = handle; in AddSendThreadInWaitTest002()
552 current->AddSendThreadInWait(seqNumber, messageInfo, 1); in AddSendThreadInWaitTest002()
604 std::shared_ptr<ThreadMessageInfo> messageInfo in WakeUpThreadBySeqNumberTest003() local
[all...]
/foundation/communication/ipc/ipc/native/c/rpc/include/
H A Drpc_process_skeleton.h128 int32_t AddSendThreadInWait(uint64_t seqNumber, ThreadMessageInfo *messageInfo, uint32_t userWaitTime);
129 void EraseThreadBySeqNumber(ThreadMessageInfo *messageInfo);
/foundation/communication/ipc/ipc/native/src/core/source/
H A Dipc_process_skeleton.cpp885 bool IPCProcessSkeleton::AddThreadBySeqNumber(uint64_t seqNumber, std::shared_ptr<ThreadMessageInfo> messageInfo) in AddThreadBySeqNumber() argument
891 seqNumberToThread_.insert(std::pair<uint64_t, std::shared_ptr<ThreadMessageInfo>>(seqNumber, messageInfo)); in AddThreadBySeqNumber()
899 std::shared_ptr<ThreadMessageInfo> messageInfo; in WakeUpThreadBySeqNumber() local
901 messageInfo = QueryThreadBySeqNumber(seqNumber); in WakeUpThreadBySeqNumber()
902 if (messageInfo == nullptr) { in WakeUpThreadBySeqNumber()
903 ZLOGE(LOG_LABEL, "error! messageInfo is nullptr"); in WakeUpThreadBySeqNumber()
906 if (handle != messageInfo->socketId) { in WakeUpThreadBySeqNumber()
908 handle, messageInfo->socketId); in WakeUpThreadBySeqNumber()
912 std::unique_lock<std::mutex> lock_unique(messageInfo->mutex); in WakeUpThreadBySeqNumber()
913 messageInfo in WakeUpThreadBySeqNumber()
917 AddSendThreadInWait(uint64_t seqNumber, std::shared_ptr<ThreadMessageInfo> messageInfo, int userWaitTime) AddSendThreadInWait() argument
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
H A Ddistributeddb_tools_unit_test.cpp1089 int DistributedDBToolsUnitTest::BuildMessage(const DataSyncMessageInfo &messageInfo, in BuildMessage() argument
1096 message = new (std::nothrow) Message(messageInfo.messageId_); in BuildMessage()
1102 packet->SetBasicInfo(messageInfo.sendCode_, messageInfo.version_, messageInfo.mode_); in BuildMessage()
1103 packet->SetWaterMark(messageInfo.localMark_, messageInfo.peerMark_, messageInfo.deleteMark_); in BuildMessage()
1104 std::vector<uint64_t> reserved {messageInfo.packetId_}; in BuildMessage()
1106 message->SetMessageType(messageInfo in BuildMessage()
[all...]
H A Ddistributeddb_tools_unit_test.h227 static int BuildMessage(const DataSyncMessageInfo &messageInfo, DistributedDB::Message *&message);
/foundation/communication/netmanager_base/frameworks/js/napi/common/
H A Dnapi_common.cpp58 napi_value messageInfo = nullptr; in CreateCodeMessage() local
60 NAPI_CALL(env, napi_create_string_utf8(env, msg.c_str(), msg.length(), &messageInfo)); in CreateCodeMessage()
63 NAPI_CALL(env, napi_create_error(env, codeInfo, messageInfo, &messageCodeInfo)); in CreateCodeMessage()
/foundation/communication/ipc/ipc/native/src/core/include/
H A Dipc_process_skeleton.h142 bool AddThreadBySeqNumber(uint64_t seqNumber, std::shared_ptr<ThreadMessageInfo> messageInfo);
144 bool AddSendThreadInWait(uint64_t seqNumber, std::shared_ptr<ThreadMessageInfo> messageInfo, int userWaitTime);
/foundation/ability/form_fwk/frameworks/js/napi/form_host/
H A Djs_form_host.cpp501 bool ParseParameter(napi_env env, napi_value *argv, int32_t &formErrorCode, std::string &messageInfo) in ParseParameter() argument
517 messageInfo = GetStringFromNapi(env, message); in ParseParameter()
1791 std::string messageInfo = ""; in OnSetPublishFormResult() local
1793 if (!ParseParameter(env, argv, formErrorCode, messageInfo)) { in OnSetPublishFormResult()
1802 publishFormResult.message = messageInfo; in OnSetPublishFormResult()

Completed in 19 milliseconds