Home
last modified time | relevance | path

Searched refs:reply (Results 1 - 25 of 35) sorted by relevance

12

/test/xts/acts/communication/dsoftbus/rpc/entry/src/ohosTest/js/test/
H A DRpcClientJsunit.test.js162 onRemoteRequest(code, data, reply, option) {
168 let result = reply.writeString("onRemoteRequest invoking");
173 let result = reply.writeString(tmp1);
177 return super.onRemoteRequest(code, data, reply, option);
184 onRemoteMessageRequest(code, data, reply, option) {
192 let result = reply.writeByteArray(tmp1);
199 let result = reply.writeIntArray(tmp1);
206 let result = reply.writeFloatArray(tmp1);
213 let result = reply.writeShort(tmp1);
220 let result = reply
[all...]
/test/xts/device_attest_lite/framework/small/src/service/
H A Dattest_framework_feature.c46 static int32_t Invoke(IServerProxy *iProxy, int funcId, void *origin, IpcIo *req, IpcIo *reply);
90 static int32_t WriteAttestResultInfo(IpcIo *reply, AttestResultInfo *attestResultInfo) in WriteAttestResultInfo() argument
92 if (reply == NULL) { in WriteAttestResultInfo()
93 HILOGE("[WriteAttestResultInfo] reply is null!"); in WriteAttestResultInfo()
97 if (!WriteInt32(reply, DEVATTEST_SUCCESS)) { in WriteAttestResultInfo()
102 if (!WriteInt32(reply, attestResultInfo->authResult) || in WriteAttestResultInfo()
103 !WriteInt32(reply, attestResultInfo->softwareResult)) { in WriteAttestResultInfo()
109 if (!WriteInt32Vector(reply, attestResultInfo->softwareResultDetail, size)) { in WriteAttestResultInfo()
114 if (!WriteInt32(reply, attestResultInfo->ticketLength) || in WriteAttestResultInfo()
115 !WriteString(reply, attestResultInf in WriteAttestResultInfo()
122 FeatureQueryAttest(IpcIo *reply) FeatureQueryAttest() argument
149 Invoke(IServerProxy *iProxy, int funcId, void *origin, IpcIo *req, IpcIo *reply) Invoke() argument
[all...]
/test/xts/device_attest_lite/framework/small/src/client/
H A Dattest_framework_client_proxy.c44 static int32_t ReadAttestResultTicket(IpcIo *reply, AttestResultInfo **attestStatus) in ReadAttestResultTicket() argument
46 if ((attestStatus == NULL) || (*attestStatus == NULL) || (reply == NULL)) { in ReadAttestResultTicket()
52 char *ticket = (char *)ReadString(reply, &len); in ReadAttestResultTicket()
77 static int32_t ReadAttestResultInfo(IpcIo *reply, AttestResultInfo **attestStatus) in ReadAttestResultInfo() argument
79 if ((attestStatus == NULL) || (*attestStatus == NULL) || (reply == NULL)) { in ReadAttestResultInfo()
85 if (!ReadInt32(reply, (int32_t *)&attestResult->authResult) || in ReadAttestResultInfo()
86 !ReadInt32(reply, (int32_t *)&attestResult->softwareResult)) { in ReadAttestResultInfo()
92 int32_t *softwareResultDetail = ReadInt32Vector(reply, &len); in ReadAttestResultInfo()
103 if (!ReadInt32(reply, (int32_t *)&attestResult->ticketLength)) { in ReadAttestResultInfo()
108 return ReadAttestResultTicket(reply, attestStatu in ReadAttestResultInfo()
111 AttestClientQueryStatusCb(void *owner, int code, IpcIo *reply) AttestClientQueryStatusCb() argument
154 ServiceRspMsg reply = {0}; QueryStatus() local
[all...]
/test/xts/acts/ability/ability_runtime/capichildprocess/entry/src/main/cpp/
H A DIpcStub.cpp41 int IpcStub::OnRemoteRequest(uint32_t code, const OHIPCParcel *data, OHIPCParcel *reply, void *userData) in OnRemoteRequest() argument
55 ret = thiz->HandleRequestExitChildProcess(data, reply); in OnRemoteRequest()
59 ret = thiz->HandleAdd(data, reply); in OnRemoteRequest()
63 ret = thiz->HandleStartNativeChildProcess(data, reply); in OnRemoteRequest()
103 int IpcStub::HandleRequestExitChildProcess(const OHIPCParcel *data, OHIPCParcel *reply) in HandleRequestExitChildProcess() argument
106 return OH_IPCParcel_WriteInt32(reply, ret); in HandleRequestExitChildProcess()
109 int32_t IpcStub::HandleAdd(const OHIPCParcel *data, OHIPCParcel *reply) in HandleAdd() argument
119 if (OH_IPCParcel_WriteInt32(reply, result) != OH_IPC_SUCCESS) { in HandleAdd()
126 int IpcStub::HandleStartNativeChildProcess(const OHIPCParcel *data, OHIPCParcel *reply) in HandleStartNativeChildProcess() argument
129 return OH_IPCParcel_WriteInt32(reply, re in HandleStartNativeChildProcess()
[all...]
H A DIpcProxy.cpp39 StdUniPtrIpcParcel reply(OH_IPCParcel_Create(), OH_IPCParcel_Destroy); in RequestExitChildProcess()
40 if (data == nullptr || reply == nullptr) { in RequestExitChildProcess()
52 int ret = OH_IPCRemoteProxy_SendRequest(ipcProxy_, IPC_ID_REQUEST_EXIT_PROCESS, data.get(), reply.get(), &ipcOpt); in RequestExitChildProcess()
68 StdUniPtrIpcParcel reply(OH_IPCParcel_Create(), OH_IPCParcel_Destroy); in Add()
69 if (data == nullptr || reply == nullptr) { in Add()
83 int ret = OH_IPCRemoteProxy_SendRequest(ipcProxy_, IPC_ID_ADD, data.get(), reply.get(), &ipcOpt); in Add()
88 OH_IPCParcel_ReadInt32(reply.get(), &result); in Add()
100 StdUniPtrIpcParcel reply(OH_IPCParcel_Create(), OH_IPCParcel_Destroy); in StartNativeChildProcess()
101 if (data == nullptr || reply == nullptr) { in StartNativeChildProcess()
114 ipcProxy_, IPC_ID_START_NATIVE_CHILD_PROCESS, data.get(), reply in StartNativeChildProcess()
[all...]
H A DIpcStub.h36 static int OnRemoteRequest(uint32_t code, const OHIPCParcel *data, OHIPCParcel *reply, void *userData);
41 int HandleRequestExitChildProcess(const OHIPCParcel *data, OHIPCParcel *reply);
42 int HandleAdd(const OHIPCParcel *data, OHIPCParcel *reply);
43 int HandleStartNativeChildProcess(const OHIPCParcel *data, OHIPCParcel *reply);
/test/xts/hats/hdf/manager/managerServiceTest/
H A Dservice_manager_hdi_test.cpp107 uint32_t code, OHOS::MessageParcel &data, OHOS::MessageParcel &reply, OHOS::MessageOption &option) override
149 OHOS::MessageParcel reply; in HWTEST_F() local
155 int status = sampleService->SendRequest(SAMPLE_SERVICE_PING, data, reply, option); in HWTEST_F()
175 OHOS::MessageParcel reply; in HWTEST_F() local
183 int status = sampleService->SendRequest(SAMPLE_SERVICE_CALLBACK, data, reply, option); in HWTEST_F()
203 OHOS::MessageParcel reply; in HWTEST_F() local
210 int status = sampleService->SendRequest(SAMPLE_SERVICE_SUM, data, reply, option); in HWTEST_F()
212 int32_t result = reply.ReadInt32(); in HWTEST_F()
232 OHOS::MessageParcel reply; in HWTEST_F() local
245 int status = sampleService->SendRequest(SAMPLE_BUFFER_TRANS, data, reply, optio in HWTEST_F()
281 OHOS::MessageParcel reply; HWTEST_F() local
449 OHOS::MessageParcel reply; TestSampleService() local
586 OHOS::MessageParcel reply; HWTEST_F() local
627 OHOS::MessageParcel reply; HWTEST_F() local
670 OHOS::MessageParcel reply; HWTEST_F() local
921 OHOS::MessageParcel reply; HWTEST_F() local
976 OHOS::MessageParcel reply; HWTEST_F() local
1011 MessageParcel reply; HWTEST_F() local
1038 MessageParcel reply; HWTEST_F() local
1062 MessageParcel reply; HWTEST_F() local
1089 MessageParcel reply; HWTEST_F() local
1116 MessageParcel reply; HWTEST_F() local
1146 MessageParcel reply; HWTEST_F() local
1179 MessageParcel reply; HWTEST_F() local
1201 MessageParcel reply; HWTEST_F() local
[all...]
/test/testfwk/arkxtest/uitest/connection/
H A Dipc_transactor.cpp77 int ApiCaller::OnRemoteRequest(uint32_t code, Message data, Message reply, MessageOption &option) in OnRemoteRequest() argument
97 auto ret = reply.WriteString(result.resultValue_.dump()) && reply.WriteUint32(result.exception_.code_) && in OnRemoteRequest()
98 reply.WriteString(result.exception_.message_); in OnRemoteRequest()
101 reply.WriteBool(SetBackCaller(data.ReadRemoteObject())); in OnRemoteRequest()
104 return IPCObjectStub::OnRemoteRequest(code, data, reply, option); in OnRemoteRequest()
140 MessageParcel reply; in Call() local
154 if (!ret || Remote()->SendRequest(TRANS_ID_CALL, data, reply, option) != 0) { in Call()
158 result.resultValue_ = json::parse(reply.ReadString(), nullptr, false); in Call()
160 result.exception_.code_ = static_cast<ErrCode>(reply in Call()
169 MessageParcel reply; SetBackCaller() local
344 Transact(const ApiCallInfo &call, ApiReplyInfo &reply) Transact() argument
[all...]
H A Dipc_transactor.h35 // call api specified in call and receive result in reply
47 OHOS::MessageParcel &reply, OHOS::MessageOption &option) override;
82 void Transact(const ApiCallInfo &call, ApiReplyInfo &reply);
/test/xts/hats/hdf/manager/managerBenchmarkTest/
H A Dhdf_manager_benchmark_test.cpp88 uint32_t code, OHOS::MessageParcel &data, OHOS::MessageParcel &reply, OHOS::MessageOption &option) override
116 OHOS::MessageParcel reply; in BENCHMARK_F() local
124 status = sampleService->SendRequest(SAMPLE_SERVICE_PING, data, reply, option); in BENCHMARK_F()
148 OHOS::MessageParcel reply; in BENCHMARK_F() local
157 status = sampleService->SendRequest(SAMPLE_SERVICE_CALLBACK, data, reply, option); in BENCHMARK_F()
191 OHOS::MessageParcel reply; in BENCHMARK_F() local
199 int status = sampleService->SendRequest(SAMPLE_REGISTER_DEVICE, data, reply, option); in BENCHMARK_F()
206 reply.FlushBuffer(); in BENCHMARK_F()
212 status = sampleService2->SendRequest(SAMPLE_SERVICE_SUM, data, reply, option); in BENCHMARK_F()
214 int32_t result = reply in BENCHMARK_F()
266 OHOS::MessageParcel reply; BENCHMARK_F() local
346 OHOS::MessageParcel reply; BENCHMARK_F() local
389 OHOS::MessageParcel reply; BENCHMARK_F() local
[all...]
/test/xts/device_attest/services/devattest_ability/src/
H A Ddevattest_service_stub.cpp35 MessageParcel& data, MessageParcel& reply, MessageOption& option) in OnRemoteRequest()
47 return (this->*requestFunc)(data, reply); in OnRemoteRequest()
51 return IPCObjectStub::OnRemoteRequest(code, data, reply, option); in OnRemoteRequest()
54 int DevAttestServiceStub::GetAttestStatusInner(MessageParcel& data, MessageParcel& reply) in GetAttestStatusInner() argument
59 if (!reply.WriteInt32(DEVATTEST_ERR_JS_IS_NOT_SYSTEM_APP)) { in GetAttestStatusInner()
68 if (!reply.WriteInt32(ret)) { in GetAttestStatusInner()
74 if (!attestResultInfoPtr->Marshalling(reply)) { in GetAttestStatusInner()
34 OnRemoteRequest(uint32_t code, MessageParcel& data, MessageParcel& reply, MessageOption& option) OnRemoteRequest() argument
/test/xts/acts/communication/dsoftbus/rpc_request/entry/src/ohosTest/js/test/
H A DActsRpcRequestJsTest.test.js94 onRemoteRequest(code, data, reply, option) {
122 onRemoteRequest(code, data, reply, option) {
128 let result = reply.writeString("onRemoteRequest invoking");
132 return super.onRemoteRequest(code, data, reply, option);
139 async onRemoteMessageRequest(code, data, reply, option) {
144 reply.writeString("async onRemoteMessageRequest invoking");
148 reply.writeString("async onRemoteMessageRequest invoking");
153 reply.writeAshmem(tmp1);
156 return super.onRemoteMessageRequest(code, data, reply, option);
182 var reply
[all...]
/test/xts/hats/hdf/manager/managerHdiTest/
H A Dservice_manager_hdi_c_test.cpp110 struct HdfSBuf *reply = HdfSbufTypedObtain(SBUF_IPC); in HWTEST_F() local
112 ASSERT_TRUE(reply != nullptr); in HWTEST_F()
119 int status = sampleService->dispatcher->Dispatch(sampleService, SAMPLE_SERVICE_PING, data, reply); in HWTEST_F()
123 HdfSbufRecycle(reply); in HWTEST_F()
129 struct HdfRemoteService *service, int code, struct HdfSBuf *data, struct HdfSBuf *reply) in ServiceManagerTestCallbackDispatch()
160 struct HdfSBuf *reply = HdfSbufTypedObtain(SBUF_IPC); in HWTEST_F() local
162 ASSERT_TRUE(reply != nullptr); in HWTEST_F()
169 int status = sampleService->dispatcher->Dispatch(sampleService, SAMPLE_SERVICE_CALLBACK, data, reply); in HWTEST_F()
174 HdfSbufRecycle(reply); in HWTEST_F()
195 struct HdfSBuf *reply in HWTEST_F() local
128 ServiceManagerTestCallbackDispatch( struct HdfRemoteService *service, int code, struct HdfSBuf *data, struct HdfSBuf *reply) ServiceManagerTestCallbackDispatch() argument
234 struct HdfSBuf *reply = HdfSbufTypedObtain(SBUF_IPC); HWTEST_F() local
277 struct HdfSBuf *reply = HdfSbufTypedObtain(SBUF_IPC); HWTEST_F() local
332 struct HdfSBuf *reply = HdfSbufTypedObtain(SBUF_IPC); HWTEST_F() local
522 struct HdfSBuf *reply = HdfSbufTypedObtain(SBUF_IPC); HWTEST_F() local
[all...]
/test/testfwk/arkxtest/uitest/test/
H A Dfrontend_api_handler_test.cpp80 auto reply = ApiReplyInfo(); in TEST_F() local
81 FrontendApiServer::Get().Call(call, reply); in TEST_F()
82 ASSERT_EQ(ERR_INTERNAL, reply.exception_.code_); in TEST_F()
83 ASSERT_TRUE(reply.exception_.message_.find("No handler found") != string::npos); in TEST_F()
99 auto reply = ApiReplyInfo(); in TEST_F() local
100 server.Call(call, reply); in TEST_F()
101 ASSERT_EQ(NO_ERROR, reply.exception_.code_); in TEST_F()
105 server.Call(call, reply); in TEST_F()
106 ASSERT_EQ(ERR_INTERNAL, reply.exception_.code_) << "The handler should be unavailable after been removed"; in TEST_F()
119 auto reply in TEST_F() local
137 auto reply = ApiReplyInfo(); TEST_F() local
152 auto reply = ApiReplyInfo(); TEST_F() local
174 auto reply = ApiReplyInfo(); TEST_F() local
[all...]
/test/xts/device_attest/interfaces/innerkits/native_cpp/src/
H A Ddevattest_service_proxy.cpp27 MessageParcel reply; in GetAttestStatus() local
40 int ret = remote->SendRequest(GET_AUTH_RESULT, data, reply, option); in GetAttestStatus()
46 if (!reply.ReadInt32(authRet)) { in GetAttestStatus()
55 sptr<AttestResultInfo> attestResultInfoPtr = AttestResultInfo::Unmarshalling(reply); in GetAttestStatus()
/test/xts/device_attest/services/devattest_ability/include/
H A Ddevattest_service_stub.h29 int OnRemoteRequest(uint32_t code, MessageParcel& data, MessageParcel& reply, MessageOption& option) override;
36 int GetAttestStatusInner(MessageParcel& data, MessageParcel& reply);
37 using RequestFuncType = int (DevAttestServiceStub::*)(MessageParcel& data, MessageParcel& reply);
/test/testfwk/arkxtest/uitest/napi/
H A Duitest_napi.cpp202 /**Evaluate and convert transaction reply to object. Return the exception raised during the
204 static napi_value UnmarshalReply(napi_env env, const TransactionContext &ctx, const ApiReplyInfo &reply) in UnmarshalReply() argument
211 const auto &message = reply.exception_.message_; in UnmarshalReply()
212 ErrCode code = reply.exception_.code_; in UnmarshalReply()
215 } else if (reply.exception_.code_ != NO_ERROR) { in UnmarshalReply()
219 LOG_I("Start to Unmarshal return value: %{public}s", reply.resultValue_.dump().c_str()); in UnmarshalReply()
220 const auto resultType = reply.resultValue_.type(); in UnmarshalReply()
225 NAPI_CALL(env, napi_create_array_with_length(env, reply.resultValue_.size(), &result)); in UnmarshalReply()
226 for (size_t idx = 0; idx < reply.resultValue_.size(); idx++) { in UnmarshalReply()
228 NAPI_CALL(env, UnmarshalObject(env, reply in UnmarshalReply()
242 auto reply = ApiReplyInfo(); TransactSync() local
[all...]
/test/testfwk/arkxtest/uitest/cj/
H A Duitest_ffi.cpp118 auto reply = ApiReplyInfo(); in CJTransact() local
119 g_apiTransactClient.Transact(callInfo, reply); in CJTransact()
120 LOG_I("return value: %{public}s", reply.resultValue_.dump().c_str()); in CJTransact()
133 return reply; in CJTransact()
/test/xts/acts/distributed_schedule_lite/system_ability_manager_posix/src/
H A DLiteIPCFeatureTest.cpp88 static int32 Invoke(IServerProxy *iProxy, int funcId, void *origin, IpcIo *req, IpcIo *reply);
129 static int32 Invoke(IServerProxy *iProxy, int funcId, void *origin, IpcIo *req, IpcIo *reply) in Invoke() argument
132 pthread_self(), iProxy, funcId, origin, req, reply); in Invoke()
133 WriteBool(reply, TRUE); in Invoke()
H A DLiteIPCServiceTest.cpp76 static int32 Invoke(IServerProxy *iProxy, int funcId, void *origin, IpcIo *req, IpcIo *reply) in Invoke() argument
79 pthread_self(), iProxy, funcId, origin, req, reply); in Invoke()
94 WriteString(reply, "Yes, you did!"); in Invoke()
/test/xts/device_attest/interfaces/innerkits/native_cpp/test/unittest/src/
H A Ddevattest_client_proxy_test.cpp94 int SendRequest(uint32_t code, MessageParcel &data, MessageParcel &reply, MessageOption &option) override
97 reply.WriteInt32(DEVATTEST_FAIL);
108 reply.WriteInt32(ActionReturnResult(ATTEST_TYPE_REPLY_RESULT, ATTEST_GET_OPTION, DEVATTEST_INIT));
109 attestResultInfo.Marshalling(reply);
201 * @tc.desc: Test IPC interface returned success, but reply returned failure.
/test/testfwk/arkxtest/uitest/addon/
H A Dextension_executor.cpp150 auto reply = ApiReplyInfo(); in CallThroughMessage() local
151 server.Call(call, reply); in CallThroughMessage()
152 const auto errCode = reply.exception_.code_; in CallThroughMessage()
154 CALL_THROUGH_CHECK(errCode == ErrCode::NO_ERROR, reply.exception_.message_.c_str(), errCode, isFatalErr, ptr); in CallThroughMessage()
156 result["result"] = move(reply.resultValue_); in CallThroughMessage()
/test/xts/device_attest/test/fuzztest/devattestservicestub_fuzzer/
H A Ddevattestservicestub_fuzzer.cpp68 MessageParcel reply; in OnRemoteRequest() local
71 (void)devattestservicestub->OnRemoteRequest(code, datas, reply, option); in OnRemoteRequest()
/test/testfwk/xdevice/plugins/ohos/src/ohos/environment/
H A Ddmlib.py921 reply = HdcHelper.read(sock, DATA_UNIT_LENGTH)
922 if HdcHelper.is_okay(reply):
987 def is_okay(reply):
989 Checks to see if the first four bytes in "reply" are OKAY.
991 return reply[0:4] == ID_OKAY
994 def reply_to_string(reply):
996 Converts an HDC reply to a string.
999 return str(reply, encoding=DEFAULT_ENCODING)
1038 reply = HdcHelper.read(connection, 48)
1039 struct.unpack(">I12s32s", reply)
[all...]
/test/xts/device_attest/test/performancetest/src/
H A Ddevattestservice_performance_test.cpp92 MessageParcel reply; in HWTEST_F() local
110 DevAttestInterface::GET_AUTH_RESULT, datas, reply, option); in HWTEST_F()

Completed in 16 milliseconds

12