/kernel/linux/linux-5.10/net/openvswitch/ |
H A D | datapath.c | 69 /* Check if need to build a reply message. 70 * OVS userspace sets the NLM_F_ECHO flag if it needs the reply. */ 934 struct sk_buff *reply; in ovs_flow_cmd_new() local 992 reply = ovs_flow_cmd_alloc_info(acts, &new_flow->id, info, false, in ovs_flow_cmd_new() 994 if (IS_ERR(reply)) { in ovs_flow_cmd_new() 995 error = PTR_ERR(reply); in ovs_flow_cmd_new() 1021 if (unlikely(reply)) { in ovs_flow_cmd_new() 1024 reply, info->snd_portid, in ovs_flow_cmd_new() 1063 if (unlikely(reply)) { in ovs_flow_cmd_new() 1066 reply, inf in ovs_flow_cmd_new() 1181 struct sk_buff *reply = NULL; ovs_flow_cmd_set() local 1282 struct sk_buff *reply; ovs_flow_cmd_get() local 1341 struct sk_buff *reply; ovs_flow_cmd_del() local 1676 struct sk_buff *reply; ovs_dp_cmd_new() local 1811 struct sk_buff *reply; ovs_dp_cmd_del() local 1844 struct sk_buff *reply; ovs_dp_cmd_set() local 1879 struct sk_buff *reply; ovs_dp_cmd_get() local 2128 struct sk_buff *reply; ovs_vport_cmd_new() local 2215 struct sk_buff *reply; ovs_vport_cmd_set() local 2269 struct sk_buff *reply; ovs_vport_cmd_del() local 2324 struct sk_buff *reply; ovs_vport_cmd_get() local [all...] |
/kernel/linux/linux-6.6/net/openvswitch/ |
H A D | datapath.c | 73 /* Check if need to build a reply message. 74 * OVS userspace sets the NLM_F_ECHO flag if it needs the reply. */ 973 struct sk_buff *reply; in ovs_flow_cmd_new() local 1031 reply = ovs_flow_cmd_alloc_info(acts, &new_flow->id, info, false, in ovs_flow_cmd_new() 1033 if (IS_ERR(reply)) { in ovs_flow_cmd_new() 1034 error = PTR_ERR(reply); in ovs_flow_cmd_new() 1060 if (unlikely(reply)) { in ovs_flow_cmd_new() 1063 reply, info->snd_portid, in ovs_flow_cmd_new() 1102 if (unlikely(reply)) { in ovs_flow_cmd_new() 1105 reply, inf in ovs_flow_cmd_new() 1220 struct sk_buff *reply = NULL; ovs_flow_cmd_set() local 1321 struct sk_buff *reply; ovs_flow_cmd_get() local 1380 struct sk_buff *reply; ovs_flow_cmd_del() local 1787 struct sk_buff *reply; ovs_dp_cmd_new() local 1929 struct sk_buff *reply; ovs_dp_cmd_del() local 1963 struct sk_buff *reply; ovs_dp_cmd_set() local 1999 struct sk_buff *reply; ovs_dp_cmd_get() local 2254 struct sk_buff *reply; ovs_vport_cmd_new() local 2345 struct sk_buff *reply; ovs_vport_cmd_set() local 2399 struct sk_buff *reply; ovs_vport_cmd_del() local 2454 struct sk_buff *reply; ovs_vport_cmd_get() local [all...] |
/base/customization/enterprise_device_management/interfaces/inner_api/bundle_manager/src/ |
H A D | bundle_manager_proxy.cpp | 76 MessageParcel reply; in Uninstall() local 85 ErrCode ret = proxy->HandleDevicePolicy(funcCode, data, reply); in Uninstall() 87 retMessage = reply.ReadString(); in Uninstall() 142 MessageParcel reply; in GetBundlesByPolicyType() local 150 proxy->GetPolicy(policyTypeMap_[policyType], data, reply); in GetBundlesByPolicyType() 156 bool blRes = reply.ReadInt32(ret) && (ret == ERR_OK); in GetBundlesByPolicyType() 161 int32_t size = reply.ReadInt32(); in GetBundlesByPolicyType() 166 reply.ReadStringVector(&bundles); in GetBundlesByPolicyType() 190 MessageParcel reply; in Install() local 198 ErrCode ret = proxy->HandleDevicePolicy(funcCode, data, reply); in Install() 206 WriteFileToInner(MessageParcel &reply, const std::string &realPath, std::vector<std::string> &servicePaths, std::string &errMessage) WriteFileToInner() argument 255 MessageParcel reply; WriteFileToStream() local 262 proxy->GetPolicy(POLICY_FUNC_CODE((std::uint32_t)FuncOperateType::GET, EdmInterfaceCode::INSTALL), data, reply); WriteFileToStream() local [all...] |
/foundation/multimedia/audio_framework/services/audio_policy/test/unittest/audio_client_tracker_callback_stub_unit_test/src/ |
H A D | audio_client_tracker_callback_stub_unit_test.cpp | 152 MessageParcel reply; in HWTEST() local 154 int result = audioClientTrackerCallbackStub_->OnRemoteRequest(code, data, reply, option); in HWTEST() 158 result = audioClientTrackerCallbackStub_->OnRemoteRequest(code, data, reply, option); in HWTEST() 163 result = audioClientTrackerCallbackStub_->OnRemoteRequest(code, data, reply, option); in HWTEST() 168 result = audioClientTrackerCallbackStub_->OnRemoteRequest(code, data, reply, option); in HWTEST() 173 result = audioClientTrackerCallbackStub_->OnRemoteRequest(code, data, reply, option); in HWTEST() 191 MessageParcel reply; in HWTEST() local 194 int result = audioClientTrackerCallbackStub_->OnRemoteRequest(code, data, reply, option); in HWTEST() 212 MessageParcel reply; in HWTEST() local 215 int result = audioClientTrackerCallbackStub_->OnRemoteRequest(code, data, reply, optio in HWTEST() 233 MessageParcel reply; HWTEST() local 254 MessageParcel reply; HWTEST() local 280 MessageParcel reply; HWTEST() local 301 MessageParcel reply; HWTEST() local [all...] |
/base/hiviewdfx/hiview/plugins/faultlogger/service/idl/src/ |
H A D | faultlog_query_result_stub.cpp | 28 MessageParcel &reply, MessageOption &option) in OnRemoteRequest() 39 if (!reply.WriteBool(HasNext())) { in OnRemoteRequest() 52 if (!result->Marshalling(reply)) { in OnRemoteRequest() 60 if (!reply.WriteFileDescriptor(result->fd)) { in OnRemoteRequest() 74 return IPCObjectStub::OnRemoteRequest(code, data, reply, option); in OnRemoteRequest() 27 OnRemoteRequest(uint32_t code, MessageParcel &data, MessageParcel &reply, MessageOption &option) OnRemoteRequest() argument
|
/base/request/request/services/src/service/command/ |
H A D | unsubscribe.rs | 21 pub(crate) fn unsubscribe(&self, data: &mut MsgParcel, reply: &mut MsgParcel) -> IpcResult<()> { 27 reply.write(&(ErrorCode::TaskNotFound as i32))?; 33 reply.write(&(ErrorCode::TaskNotFound as i32))?; 38 reply.write(&(ErrorCode::ErrOk as i32))?; 41 reply.write(&(ErrorCode::TaskNotFound as i32))?;
|
/base/security/access_token/interfaces/innerkits/accesstoken/include/ |
H A D | accesstoken_callback_stubs.h | 35 int32_t OnRemoteRequest(uint32_t code, MessageParcel& data, MessageParcel& reply, MessageOption& option) override; 44 int32_t OnRemoteRequest(uint32_t code, MessageParcel& data, MessageParcel& reply, MessageOption& option) override; 46 void GetRemoteHapTokenInfoInner(MessageParcel& data, MessageParcel& reply); 47 void DeleteRemoteHapTokenInfoInner(MessageParcel& data, MessageParcel& reply); 48 void UpdateRemoteHapTokenInfoInner(MessageParcel& data, MessageParcel& reply);
|
/base/security/access_token/services/common/app_manager/include/ |
H A D | app_status_change_callback.h | 33 uint32_t code, MessageParcel &data, MessageParcel &reply, MessageOption &option) override; 42 int32_t HandleOnProcessStateChanged(MessageParcel &data, MessageParcel &reply); 43 int32_t HandleOnProcessDied(MessageParcel &data, MessageParcel &reply); 44 int32_t HandleOnAppStateChanged(MessageParcel &data, MessageParcel &reply); 45 int32_t HandleOnAppStopped(MessageParcel &data, MessageParcel &reply);
|
/base/security/access_token/frameworks/inner_api/privacy/test/unittest/app_manager_client/ |
H A D | app_manager_access_proxy.cpp | 31 MessageParcel reply; in GetForegroundApplications() local 38 static_cast<uint32_t>(IAppMgr::Message::GET_FOREGROUND_APPLICATIONS), data, reply, option); in GetForegroundApplications() 43 uint32_t infoSize = reply.ReadUint32(); in GetForegroundApplications() 49 std::unique_ptr<AppStateData> info(reply.ReadParcelable<AppStateData>()); in GetForegroundApplications() 54 return reply.ReadInt32(); in GetForegroundApplications()
|
/base/useriam/pin_auth/frameworks/ipc/src/ |
H A D | inputer_set_data_proxy.cpp | 29 MessageParcel reply; in OnSetData() local 45 bool ret = SendRequest(InputerSetDataInterfaceCode::ON_SET_DATA, dataParcel, reply); in OnSetData() 47 int32_t result = reply.ReadInt32(); in OnSetData() 52 bool InputerSetDataProxy::SendRequest(uint32_t code, MessageParcel &data, MessageParcel &reply) in SendRequest() argument 61 int32_t result = remote->SendRequest(code, data, reply, option); in SendRequest()
|
/foundation/ability/form_fwk/interfaces/inner_api/src/ |
H A D | form_publish_interceptor_stub.cpp | 35 MessageParcel &data, MessageParcel &reply, MessageOption &option) in OnRemoteRequest() 47 return HandleProcessPublishForm(data, reply); in OnRemoteRequest() 49 return IPCObjectStub::OnRemoteRequest(code, data, reply, option); in OnRemoteRequest() 53 int FormPublishInterceptorStub::HandleProcessPublishForm(MessageParcel &data, MessageParcel &reply) in HandleProcessPublishForm() argument 61 reply.WriteInt32(result); in HandleProcessPublishForm() 34 OnRemoteRequest(uint32_t code, MessageParcel &data, MessageParcel &reply, MessageOption &option) OnRemoteRequest() argument
|
H A D | form_host_delegate_stub.cpp | 33 MessageParcel &reply, MessageOption &option) in OnRemoteRequest() 45 return HandleRouterEvent(data, reply); in OnRemoteRequest() 47 return IPCObjectStub::OnRemoteRequest(code, data, reply, option); in OnRemoteRequest() 51 int32_t FormHostDelegateStub::HandleRouterEvent(MessageParcel &data, MessageParcel &reply) in HandleRouterEvent() argument 62 reply.WriteInt32(result); in HandleRouterEvent() 32 OnRemoteRequest(uint32_t code, MessageParcel &data, MessageParcel &reply, MessageOption &option) OnRemoteRequest() argument
|
/foundation/ability/ability_runtime/test/mock/services_abilitymgr_test/libs/appexecfwk_core/src/appmgr/ |
H A D | app_state_callback_host.cpp | 32 uint32_t code, MessageParcel& data, MessageParcel& reply, MessageOption& option) in OnRemoteRequest() 57 int32_t AppStateCallbackHost::HandleOnAppStateChanged(MessageParcel& data, MessageParcel& reply) in HandleOnAppStateChanged() argument 62 int32_t AppStateCallbackHost::HandleOnAbilityRequestDone(MessageParcel& data, MessageParcel& reply) in HandleOnAbilityRequestDone() argument 67 int32_t AppStateCallbackHost::HandleNotifyStartResidentProcess(MessageParcel &data, MessageParcel &reply) in HandleNotifyStartResidentProcess() argument 71 int32_t AppStateCallbackHost::HandleNotifyAppPreCache(MessageParcel &data, MessageParcel &reply) in HandleNotifyAppPreCache() argument 31 OnRemoteRequest( uint32_t code, MessageParcel& data, MessageParcel& reply, MessageOption& option) OnRemoteRequest() argument
|
/foundation/ability/ability_runtime/interfaces/inner_api/app_manager/include/appmgr/ |
H A D | start_specified_ability_response_stub.h | 32 uint32_t code, MessageParcel &data, MessageParcel &reply, MessageOption &option) override; 35 int32_t HandleOnAcceptWantResponse(MessageParcel &data, MessageParcel &reply); 36 int32_t HandleOnTimeoutResponse(MessageParcel &data, MessageParcel &reply); 37 int32_t HandleOnNewProcessRequestResponse(MessageParcel &data, MessageParcel &reply); 38 int32_t HandleOnNewProcessRequestTimeoutResponse(MessageParcel &data, MessageParcel &reply);
|
/foundation/barrierfree/accessibility/services/aams/test/mock/include/ |
H A D | mock_accessible_ability_client_stub_impl.h | 30 uint32_t code, MessageParcel& data, MessageParcel& reply, MessageOption& option) override; 38 ErrCode HandleInit(MessageParcel& data, MessageParcel& reply); 39 ErrCode HandleDisconnect(MessageParcel& data, MessageParcel& reply); 40 ErrCode HandleOnAccessibilityEvent(MessageParcel& data, MessageParcel& reply); 41 ErrCode HandleOnKeyPressEvent(MessageParcel& data, MessageParcel& reply);
|
/foundation/barrierfree/accessibility/services/test/moduletest/mock/include/ |
H A D | mock_mt_accessible_ability_client_stub_impl.h | 30 uint32_t code, MessageParcel& data, MessageParcel& reply, MessageOption& option) override; 38 ErrCode HandleInit(MessageParcel& data, MessageParcel& reply); 39 ErrCode HandleDisconnect(MessageParcel& data, MessageParcel& reply); 40 ErrCode HandleOnAccessibilityEvent(MessageParcel& data, MessageParcel& reply); 41 ErrCode HandleOnKeyPressEvent(MessageParcel& data, MessageParcel& reply);
|
/foundation/communication/bluetooth/frameworks/inner/ipc/include/ |
H A D | bluetooth_ble_central_manager_callback_stub.h | 32 uint32_t code, MessageParcel &data, MessageParcel &reply, MessageOption &option) override; 36 BluetoothBleCentralManagerCallBackStub *stub, MessageParcel &data, MessageParcel &reply); 38 BluetoothBleCentralManagerCallBackStub *stub, MessageParcel &data, MessageParcel &reply); 40 BluetoothBleCentralManagerCallBackStub *stub, MessageParcel &data, MessageParcel &reply); 42 BluetoothBleCentralManagerCallBackStub *stub, MessageParcel &data, MessageParcel &reply);
|
/foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_manage/wifi_sta_sa/ |
H A D | wifi_device_mgr_stub.cpp | 36 uint32_t code, MessageParcel &data, MessageParcel &reply, MessageOption &option) in GetWifiRemoteInner() 40 int ret = reply.WriteRemoteObject(obj); in GetWifiRemoteInner() 45 uint32_t code, MessageParcel &data, MessageParcel &reply, MessageOption &option) in OnRemoteRequest() 54 return IPCObjectStub::OnRemoteRequest(code, data, reply, option); in OnRemoteRequest() 56 (this->*(iter->second))(code, data, reply, option); in OnRemoteRequest() 35 GetWifiRemoteInner( uint32_t code, MessageParcel &data, MessageParcel &reply, MessageOption &option) GetWifiRemoteInner() argument 44 OnRemoteRequest( uint32_t code, MessageParcel &data, MessageParcel &reply, MessageOption &option) OnRemoteRequest() argument
|
/foundation/deviceprofile/device_info_manager/common/src/interfaces/ |
H A D | dp_inited_callback_stub.cpp | 38 MessageParcel& reply, MessageOption& option) in OnRemoteRequest() 49 return IPCObjectStub::OnRemoteRequest(code, data, reply, option); in OnRemoteRequest() 51 return OnDpInitedInner(data, reply); in OnRemoteRequest() 54 int32_t DpInitedCallbackStub::OnDpInitedInner(MessageParcel& data, MessageParcel& reply) in OnDpInitedInner() argument 59 if (!reply.WriteInt32(ret)) { in OnDpInitedInner() 60 HILOGE("Write reply failed"); in OnDpInitedInner() 37 OnRemoteRequest(uint32_t code, MessageParcel& data, MessageParcel& reply, MessageOption& option) OnRemoteRequest() argument
|
/foundation/distributedhardware/distributed_camera/services/cameraservice/sinkservice/src/distributedcamera/ |
H A D | dcamera_sink_callback_proxy.cpp | 35 MessageParcel reply; in OnNotifyResourceInfo() local 47 remote->SendRequest(NOTIFY_RESOURCEINFO, req, reply, option); in OnNotifyResourceInfo() 48 int32_t result = reply.ReadInt32(); in OnNotifyResourceInfo() 49 isSensitive = reply.ReadBool(); in OnNotifyResourceInfo() 50 isSameAccout = reply.ReadBool(); in OnNotifyResourceInfo()
|
/kernel/linux/linux-5.10/net/bpfilter/ |
H A D | main.c | 35 struct mbox_reply reply; in loop() local 44 reply.status = req.is_set ? in loop() 48 n = write(1, &reply, sizeof(reply)); in loop() 49 if (n != sizeof(reply)) { in loop() 50 fprintf(debug_f, "reply failed %d\n", n); in loop()
|
/kernel/linux/linux-6.6/net/bpfilter/ |
H A D | main.c | 35 struct mbox_reply reply; in loop() local 44 reply.status = req.is_set ? in loop() 48 n = write(1, &reply, sizeof(reply)); in loop() 49 if (n != sizeof(reply)) { in loop() 50 fprintf(debug_f, "reply failed %d\n", n); in loop()
|
/third_party/lwip/src/apps/mdns/ |
H A D | mdns.c | 248 /** If reply should be sent unicast */ 251 * question again in reply before answer) */ 271 /** unicast reply requested */ 665 * if reply bit has REPLY_HOST_PTR_V6 set 896 * reply with a unicast packet 951 * Write answer to reply packet. 955 * @param reply The outpacket to write to 960 * this reply replaces any earlier answer for this domain/type/class 968 mdns_add_answer(struct mdns_outpacket *reply, struct mdns_domain *domain, u16_t type, u16_t klass, u16_t cache_flush, in mdns_add_answer() argument 978 if (!reply in mdns_add_answer() 1171 mdns_add_a_answer(struct mdns_outpacket *reply, u16_t cache_flush, struct netif *netif) mdns_add_a_answer() argument 1181 mdns_add_hostv4_ptr_answer(struct mdns_outpacket *reply, u16_t cache_flush, struct netif *netif) mdns_add_hostv4_ptr_answer() argument 1194 mdns_add_aaaa_answer(struct mdns_outpacket *reply, u16_t cache_flush, struct netif *netif, int addrindex) mdns_add_aaaa_answer() argument 1204 mdns_add_hostv6_ptr_answer(struct mdns_outpacket *reply, u16_t cache_flush, struct netif *netif, int addrindex) mdns_add_hostv6_ptr_answer() argument 1216 mdns_add_servicetype_ptr_answer(struct mdns_outpacket *reply, struct mdns_service *service) mdns_add_servicetype_ptr_answer() argument 1227 mdns_add_servicename_ptr_answer(struct mdns_outpacket *reply, struct mdns_service *service) mdns_add_servicename_ptr_answer() argument 1238 mdns_add_srv_answer(struct mdns_outpacket *reply, u16_t cache_flush, struct mdns_host *mdns, struct mdns_service *service) mdns_add_srv_answer() argument 1261 mdns_add_txt_answer(struct mdns_outpacket *reply, u16_t cache_flush, struct mdns_service *service) mdns_add_txt_answer() argument 1565 struct mdns_outpacket reply; mdns_handle_question() local [all...] |
/kernel/linux/linux-6.6/drivers/usb/gadget/function/ |
H A D | f_mass_storage.c | 51 * release Information used as a reply to INQUIRY 648 return -EIO; /* No default reply */ in do_read() 731 return -EIO; /* No default reply */ in do_read() 920 return -EIO; /* No default reply */ in do_write() 984 return -EIO; /* No default reply */ in do_verify() 1742 * We can't reply at all until we know the correct data direction in check_command() 1866 int reply = -EINVAL; in do_scsi_command() local 1887 reply = check_command(common, 6, DATA_DIR_TO_HOST, in do_scsi_command() 1890 if (reply == 0) in do_scsi_command() 1891 reply in do_scsi_command() [all...] |
/base/tee/tee_client/services/cadaemon/src/ca_daemon/ |
H A D | cadaemon_service.cpp | 422 TEEC_Result CaDaemonService::InitializeContext(const char *name, MessageParcel &reply) in InitializeContext() argument 452 writeRet = reply.WriteInt32((int32_t)ret); in InitializeContext() 457 writeRet = reply.WriteInt32(contextInner->fd); in InitializeContext() 541 static bool WriteSession(MessageParcel &reply, TEEC_Session *session) in WriteSession() argument 544 return reply.WriteBool(false); in WriteSession() 547 bool parRet = reply.WriteBool(true); in WriteSession() 556 return reply.WriteBuffer(&retSession, sizeof(retSession)); in WriteSession() 559 static bool WriteOperation(MessageParcel &reply, TEEC_Operation *operation) in WriteOperation() argument 562 return reply.WriteBool(false); in WriteOperation() 565 bool parRet = reply in WriteOperation() 745 RecOpenReply(uint32_t returnOrigin, TEEC_Result ret, TEEC_Session *outSession, TEEC_Operation *operation, MessageParcel &reply) RecOpenReply() argument 788 OpenSession(TEEC_Context *context, const char *taPath, int32_t fd, const TEEC_UUID *destination, uint32_t connectionMethod, TEEC_Operation *operation, uint32_t optMemSize, sptr<Ashmem> &optMem, MessageParcel &reply) OpenSession() argument 887 InvokeCommand(TEEC_Context *context, TEEC_Session *session, uint32_t commandID, TEEC_Operation *operation, uint32_t optMemSize, sptr<Ashmem> &optMem, MessageParcel &reply) InvokeCommand() argument 975 RegisterSharedMemory(TEEC_Context *context, TEEC_SharedMemory *sharedMem, MessageParcel &reply) RegisterSharedMemory() argument 1040 RecAllocReply(TEEC_Result ret, TEEC_SharedMemory *sharedMem, uint32_t offset, int32_t fd, MessageParcel &reply) RecAllocReply() argument 1057 AllocateSharedMemory(TEEC_Context *context, TEEC_SharedMemory *sharedMem, MessageParcel &reply) AllocateSharedMemory() argument 1115 ReleaseSharedMemory(TEEC_Context *context, TEEC_SharedMemory *sharedMem, uint32_t shmOffset, MessageParcel &reply) ReleaseSharedMemory() argument 1274 SendSecfile(const char *path, int fd, FILE *fp, MessageParcel &reply) SendSecfile() argument 1285 GetTeeVersion(MessageParcel &reply) GetTeeVersion() argument [all...] |