| /foundation/communication/ipc/services/dbinder/c/src/ |
| H A D | dbinder_service.c | 357 RPC_LOG_ERROR("InvokerRemoteDBinder wait for reply timeout"); in InvokerRemoteDBinder()
548 IpcIo reply; in OnRemoteInvokerDataBusMessage() local
550 ret = InvokerListenThread(proxy, localDeviceId, remoteDeviceID, pid, uid, &reply, &ptr); in OnRemoteInvokerDataBusMessage()
558 if (!ReadUint64(&reply, &stubIndex)) { in OnRemoteInvokerDataBusMessage()
564 char *serverSessionName = (char *)ReadString(&reply, &sessionLen); in OnRemoteInvokerDataBusMessage()
567 RPC_LOG_ERROR("INVOKE_LISTEN_THREAD reply stubIndex or sessionName invalid"); in OnRemoteInvokerDataBusMessage()
|
| /kernel/linux/linux-5.10/net/ceph/ |
| H A D | auth_x.c | 734 struct ceph_x_authorize_reply *reply = p + ceph_x_encrypt_offset(); in ceph_x_verify_authorizer_reply() local
740 if (ret < sizeof(*reply)) { in ceph_x_verify_authorizer_reply()
745 if (au->nonce + 1 != le64_to_cpu(reply->nonce_plus_one)) in ceph_x_verify_authorizer_reply()
750 au->nonce, le64_to_cpu(reply->nonce_plus_one), ret); in ceph_x_verify_authorizer_reply()
|
| /foundation/ability/ability_lite/services/abilitymgr_lite/src/ |
| H A D | ability_mgr_feature.cpp | 88 int32 AbilityMgrFeature::Invoke(IServerProxy *iProxy, int funcId, void *origin, IpcIo *req, IpcIo *reply) in Invoke() argument
134 IpcIo reply; in OnRequestCallback() local
140 int32_t transRet = SendRequest(svc_, START_ABILITY_CALLBACK, &io, &reply, option, NULL); in OnRequestCallback()
|
| /foundation/resourceschedule/resource_schedule_service/ressched/interfaces/innerkits/ressched_client/src/ |
| H A D | res_sched_client.cpp | 74 nlohmann::json& reply)
in ReportSyncEvent()
96 reply = std::move(result.second);
in ReportSyncEvent()
102 return proxy->ReportSyncEvent(resType, value, payload, reply);
in ReportSyncEvent()
73 ReportSyncEvent(const uint32_t resType, const int64_t value, const nlohmann::json& payload, nlohmann::json& reply) ReportSyncEvent() argument
|
| /kernel/linux/linux-5.10/sound/soc/sof/ |
| H A D | debug.c | 247 struct sof_ipc_reply reply; in sof_debug_ipc_flood_test() local
268 &reply, sizeof(reply)); in sof_debug_ipc_flood_test()
|
| /kernel/linux/linux-5.10/sound/soc/sof/intel/ |
| H A D | hda-dsp.c | 357 struct sof_ipc_reply reply; in hda_dsp_send_pm_gate_ipc() local
368 &pm_gate, sizeof(pm_gate), &reply, in hda_dsp_send_pm_gate_ipc()
369 sizeof(reply)); in hda_dsp_send_pm_gate_ipc()
|
| /kernel/linux/linux-5.10/drivers/xen/xenbus/ |
| H A D | xenbus_dev_frontend.c | 70 * still waiting a reply.
95 * reply_mutex protects the reply being built up to return to
297 /* success: pass reply list onto watcher */ in watch_fired()
420 unsigned int msg_type, const char *reply) in xenbus_command_reply()
430 msg.hdr.len = strlen(reply) + 1; in xenbus_command_reply()
433 memcpy(&msg.body, reply, msg.hdr.len); in xenbus_command_reply()
543 /* Success. Synthesize a reply to say all is OK. */ in xenbus_write_watch()
419 xenbus_command_reply(struct xenbus_file_priv *u, unsigned int msg_type, const char *reply) xenbus_command_reply() argument
|
| /kernel/linux/linux-5.10/drivers/message/fusion/ |
| H A D | mptbase.h | 278 * In particular, do NOT reply on offset [2]
326 MPIDefaultReply_t reply; member
451 u8 reply[MPT_DEFAULT_FRAME_SIZE]; /* reply frame data */ member
637 int reply_depth; /* Num Allocated reply frames */
797 typedef int (*MPT_CALLBACK)(MPT_ADAPTER *ioc, MPT_FRAME_HDR *req, MPT_FRAME_HDR *reply);
|
| /kernel/linux/linux-6.6/drivers/message/fusion/ |
| H A D | mptbase.h | 278 * In particular, do NOT reply on offset [2]
326 MPIDefaultReply_t reply; member
451 u8 reply[MPT_DEFAULT_FRAME_SIZE]; /* reply frame data */ member
637 int reply_depth; /* Num Allocated reply frames */
796 typedef int (*MPT_CALLBACK)(MPT_ADAPTER *ioc, MPT_FRAME_HDR *req, MPT_FRAME_HDR *reply);
|
| /kernel/linux/linux-6.6/drivers/xen/xenbus/ |
| H A D | xenbus_dev_frontend.c | 70 * still waiting a reply.
95 * reply_mutex protects the reply being built up to return to
297 /* success: pass reply list onto watcher */ in watch_fired()
420 unsigned int msg_type, const char *reply) in xenbus_command_reply()
430 msg.hdr.len = strlen(reply) + 1; in xenbus_command_reply()
433 memcpy(&msg.body, reply, msg.hdr.len); in xenbus_command_reply()
543 /* Success. Synthesize a reply to say all is OK. */ in xenbus_write_watch()
419 xenbus_command_reply(struct xenbus_file_priv *u, unsigned int msg_type, const char *reply) xenbus_command_reply() argument
|
| /kernel/linux/linux-6.6/net/vmw_vsock/ |
| H A D | virtio_transport.c | 106 bool reply; in virtio_transport_send_pkt_work() local
113 reply = virtio_vsock_skb_reply(skb); in virtio_transport_send_pkt_work()
131 if (reply) { in virtio_transport_send_pkt_work()
|
| /foundation/bundlemanager/bundle_framework/services/bundlemgr/test/unittest/bms_bundle_free_install_test/ |
| H A D | bms_bundle_free_install_test.cpp | 1497 MessageParcel reply; in HWTEST_F() local
1499 callbackStub.OnRemoteRequest(code, data, reply, option); in HWTEST_F()
1578 MessageParcel reply; in HWTEST_F() local
1580 auto result = callbackStub.OnRemoteRequest(code, data, reply, option); in HWTEST_F()
1597 MessageParcel reply; in HWTEST_F() local
1600 auto result = callbackStub.OnRemoteRequest(code, data, reply, option); in HWTEST_F()
1617 MessageParcel reply; in HWTEST_F() local
1621 auto result = callbackStub.OnRemoteRequest(code, data, reply, option); in HWTEST_F()
|
| /foundation/multimedia/audio_framework/frameworks/native/audiopolicy/test/unittest/policy_test/src/ |
| H A D | audio_policy_unit_test.cpp | 604 MessageParcel reply; in HWTEST() local
606 int ret = capturerStub->OnRemoteRequest(code, data, reply, option); in HWTEST()
629 MessageParcel reply; in HWTEST() local
631 int ret = rendererStub->OnRemoteRequest(code, data, reply, option); in HWTEST()
655 MessageParcel reply; in HWTEST() local
657 int ret = ringermodeStub->OnRemoteRequest(code, data, reply, option); in HWTEST()
683 MessageParcel reply; in HWTEST() local
685 int ret = audioPolicyClientStubImpl->OnRemoteRequest(code, data, reply, option); in HWTEST()
|
| /foundation/communication/ipc/services/dbinder/dbinder_service/src/ |
| H A D | dbinder_service.cpp | 473 /* pend to wait reply */ in InvokerRemoteDBinder()
725 bool DBinderService::CheckInvokeListenThreadIllegal(IPCObjectProxy *proxy, MessageParcel &data, MessageParcel &reply) in CheckInvokeListenThreadIllegal() argument
727 int err = proxy->InvokeListenThread(data, reply); in CheckInvokeListenThreadIllegal()
782 MessageParcel reply; in OnRemoteInvokerDataBusMessage() local
791 if (CheckInvokeListenThreadIllegal(proxy, data, reply)) { in OnRemoteInvokerDataBusMessage()
797 uint64_t stubIndex = reply.ReadUint64(); in OnRemoteInvokerDataBusMessage()
798 std::string serverSessionName = reply.ReadString(); in OnRemoteInvokerDataBusMessage()
799 std::string deviceId = reply.ReadString(); in OnRemoteInvokerDataBusMessage()
800 uint32_t selfTokenId = reply.ReadUint32(); in OnRemoteInvokerDataBusMessage()
|
| /kernel/linux/linux-5.10/drivers/scsi/mpt3sas/ |
| H A D | mpt3sas_transport.c | 221 * @reply: reply message frame(lower 32bit addr)
231 u32 reply) in mpt3sas_transport_done()
235 mpi_reply = mpt3sas_base_get_reply_virt_addr(ioc, reply); in mpt3sas_transport_done()
242 memcpy(ioc->transport_cmds.reply, mpi_reply, in mpt3sas_transport_done()
259 /* report manufacture reply structure */
387 mpi_reply = ioc->transport_cmds.reply; in _transport_expander_report_manufacture()
390 ioc_info(ioc, "report_manufacture - reply data transfer size(%d)\n", in _transport_expander_report_manufacture()
416 ioc_info(ioc, "report_manufacture - no reply\n")); in _transport_expander_report_manufacture()
1046 /* report phy error log reply structur
230 mpt3sas_transport_done(struct MPT3SAS_ADAPTER *ioc, u16 smid, u8 msix_index, u32 reply) mpt3sas_transport_done() argument
[all...] |
| /kernel/linux/linux-6.6/drivers/scsi/mpt3sas/ |
| H A D | mpt3sas_transport.c | 283 * @reply: reply message frame(lower 32bit addr)
293 u32 reply) in mpt3sas_transport_done()
297 mpi_reply = mpt3sas_base_get_reply_virt_addr(ioc, reply); in mpt3sas_transport_done()
304 memcpy(ioc->transport_cmds.reply, mpi_reply, in mpt3sas_transport_done()
321 /* report manufacture reply structure */
450 mpi_reply = ioc->transport_cmds.reply; in _transport_expander_report_manufacture()
453 ioc_info(ioc, "report_manufacture - reply data transfer size(%d)\n", in _transport_expander_report_manufacture()
479 ioc_info(ioc, "report_manufacture - no reply\n")); in _transport_expander_report_manufacture()
1245 /* report phy error log reply structur
292 mpt3sas_transport_done(struct MPT3SAS_ADAPTER *ioc, u16 smid, u8 msix_index, u32 reply) mpt3sas_transport_done() argument
[all...] |
| /kernel/linux/linux-5.10/drivers/net/fddi/skfp/ |
| H A D | pmf.c | 280 SMbuf *reply ; in smt_pmf_received_pack() local
295 reply = smt_build_pmf_response(smc,sm, in smt_pmf_received_pack()
297 if (reply) { in smt_pmf_received_pack()
298 sm = smtod(reply,struct smt_header *) ; in smt_pmf_received_pack()
302 smt_send_frame(smc,reply,FC_SMT_INFO,local) ; in smt_pmf_received_pack()
|
| /kernel/linux/linux-5.10/drivers/usb/gadget/udc/ |
| H A D | s3c-hsudc.c | 542 __le16 reply; in s3c_hsudc_process_req_status() local
547 reply = cpu_to_le16(0); in s3c_hsudc_process_req_status()
551 reply = cpu_to_le16(0); in s3c_hsudc_process_req_status()
557 reply = cpu_to_le16(hsep->stopped ? 1 : 0); in s3c_hsudc_process_req_status()
563 hsreq.req.buf = &reply; in s3c_hsudc_process_req_status()
|
| /kernel/linux/linux-5.10/net/mac80211/ |
| H A D | mesh_hwmp.c | 569 bool reply = false; in hwmp_preq_frame_process() local
588 reply = true; in hwmp_preq_frame_process()
607 reply = true; in hwmp_preq_frame_process()
627 reply = true; in hwmp_preq_frame_process()
637 if (reply) { in hwmp_preq_frame_process()
|
| /kernel/linux/linux-5.10/drivers/gpu/drm/ |
| H A D | drm_dp_helper.c | 242 native_reply = msg.reply & DP_AUX_NATIVE_REPLY_MASK; in drm_dp_dpcd_access()
1180 * In case of i2c defer or short i2c ack reply to a write, in drm_dp_i2c_msg_write_status_update()
1199 * Calculate the duration of the AUX request/reply in usec. Gives the
1278 * reply field.
1317 switch (msg->reply & DP_AUX_NATIVE_REPLY_MASK) { in drm_dp_i2c_do_msg()
1321 * need to check for the I2C ACK reply. in drm_dp_i2c_do_msg()
1345 DRM_ERROR("%s: invalid native reply %#04x\n", in drm_dp_i2c_do_msg()
1346 aux->name, msg->reply); in drm_dp_i2c_do_msg()
1350 switch (msg->reply & DP_AUX_I2C_REPLY_MASK) { in drm_dp_i2c_do_msg()
1381 DRM_ERROR("%s: invalid I2C reply in drm_dp_i2c_do_msg()
[all...] |
| /kernel/linux/linux-6.6/drivers/net/fddi/skfp/ |
| H A D | pmf.c | 276 SMbuf *reply ; in smt_pmf_received_pack() local
291 reply = smt_build_pmf_response(smc,sm, in smt_pmf_received_pack()
293 if (reply) { in smt_pmf_received_pack()
294 sm = smtod(reply,struct smt_header *) ; in smt_pmf_received_pack()
298 smt_send_frame(smc,reply,FC_SMT_INFO,local) ; in smt_pmf_received_pack()
|
| /kernel/linux/linux-6.6/net/mac80211/ |
| H A D | mesh_hwmp.c | 583 bool reply = false; in hwmp_preq_frame_process() local
602 reply = true; in hwmp_preq_frame_process()
621 reply = true; in hwmp_preq_frame_process()
641 reply = true; in hwmp_preq_frame_process()
651 if (reply) { in hwmp_preq_frame_process()
|
| /third_party/pulseaudio/src/modules/dbus/ |
| H A D | iface-stream.c | 514 DBusMessage *reply = NULL; in handle_get_all() local
572 pa_assert_se((reply = dbus_message_new_method_return(msg))); in handle_get_all()
574 dbus_message_iter_init_append(reply, &msg_iter); in handle_get_all()
604 pa_assert_se(dbus_connection_send(conn, reply, NULL)); in handle_get_all()
605 dbus_message_unref(reply); in handle_get_all()
|
| /foundation/ability/form_fwk/test/unittest/fms_form_mgr_proxy_test/ |
| H A D | fms_form_mgr_proxy_test.cpp | 56 int SendRequestReplace(uint32_t code, MessageParcel &data, MessageParcel &reply, MessageOption &option, in SendRequestReplace() argument
60 reply.WriteInt32(error); in SendRequestReplace()
65 int SendRequestReplaceFormData(uint32_t code, MessageParcel &data, MessageParcel &reply, MessageOption &option, in SendRequestReplaceFormData() argument
69 reply.WriteInt32(error); in SendRequestReplaceFormData()
73 reply.WriteParcelable(¶ms); in SendRequestReplaceFormData()
77 int SendRequestReplaceFormInfo(uint32_t code, MessageParcel &data, MessageParcel &reply, MessageOption &option, in SendRequestReplaceFormInfo() argument
81 reply.WriteInt32(error); in SendRequestReplaceFormInfo()
84 reply.WriteInt32(num); in SendRequestReplaceFormInfo()
87 reply.WriteParcelable(&info); in SendRequestReplaceFormInfo()
1607 MessageParcel reply; in HWTEST_F() local
1631 MessageParcel reply; HWTEST_F() local
[all...] |
| /kernel/linux/linux-5.10/fs/ceph/ |
| H A D | mds_client.c | 69 * mds reply parsing
285 * parse a normal reply, which may contain a (dir+)dentry and/or a
523 /* Malformed reply? */ in parse_reply_info_create()
574 * parse entire mds reply
2009 * after dropping auth caps. It doesn't hurt because reply in trim_caps_cb()
3049 /* only abort if we didn't race with a real reply */ in ceph_mdsc_wait_request()
3117 * Handle mds reply.
3119 * We take the session mutex and parse and process the reply immediately.
3128 struct ceph_mds_reply_info_parsed *rinfo; /* parsed reply info */ in handle_reply()
3135 pr_err("mdsc_handle_reply got corrupt (short) reply\ in handle_reply()
3615 struct ceph_msg *reply; send_reconnect_partial() local
3977 struct ceph_msg *reply; send_mds_reconnect() local
[all...] |