/foundation/CastEngine/castengine_wifi_display/services/interaction/interprocess/ |
H A D | ipc_msg_adapter.h | 32 virtual void OnRequest(std::shared_ptr<BaseMsg> msg, std::shared_ptr<BaseMsg> &reply) = 0; 50 virtual int32_t OnRequest(std::shared_ptr<BaseMsg> msg, std::shared_ptr<BaseMsg> &reply) = 0; 51 virtual int32_t SendRequest(std::shared_ptr<BaseMsg> msg, std::shared_ptr<BaseMsg> &reply) = 0; 66 int32_t OnRequest(std::shared_ptr<BaseMsg> msg, std::shared_ptr<BaseMsg> &reply) override; 67 int32_t SendRequest(std::shared_ptr<BaseMsg> msg, std::shared_ptr<BaseMsg> [all...] |
H A D | inter_ipc_stub.h | 32 virtual void OnIpcRequest(std::shared_ptr<BaseMsg> msg, std::shared_ptr<BaseMsg> &reply) = 0; 45 virtual int32_t SendIpcRequest(std::string tokenId, std::shared_ptr<BaseMsg> msg, std::shared_ptr<BaseMsg> &reply); 48 int32_t DoIpcCommand(std::shared_ptr<BaseMsg> msg, std::shared_ptr<BaseMsg> &replyMsg) override;
|
H A D | ipc_msg_adapter.cpp | 28 int32_t IpcMsgAdapter::SendRequest(std::shared_ptr<BaseMsg> msg, std::shared_ptr<BaseMsg> &reply) in SendRequest() 40 int32_t IpcMsgAdapter::OnRequest(std::shared_ptr<BaseMsg> msg, std::shared_ptr<BaseMsg> &reply) in OnRequest() 69 void IpcMsgAdapter::OnIpcRequest(std::shared_ptr<BaseMsg> msg, std::shared_ptr<BaseMsg> &reply) in OnIpcRequest()
|
H A D | inter_ipc_stub.cpp | 87 std::shared_ptr<BaseMsg> msg = nullptr; in DoIpcCommand() 94 std::shared_ptr<BaseMsg> replyMsg = std::make_shared<BaseMsg>(); in DoIpcCommand() 120 int32_t InterIpcStub::DoIpcCommand(std::shared_ptr<BaseMsg> msg, std::shared_ptr<BaseMsg> &replyMsg) in DoIpcCommand() 159 int32_t InterIpcStub::SendIpcRequest(std::string key, std::shared_ptr<BaseMsg> msg, std::shared_ptr<BaseMsg> &reply) in SendIpcRequest()
|
H A D | inter_ipc_sub_stub.h | 32 int32_t DoIpcCommand(std::shared_ptr<BaseMsg> msg, std::shared_ptr<BaseMsg> &replyMsg) override;
|
H A D | inter_ipc_client_stub.h | 31 int32_t DoIpcCommand(std::shared_ptr<BaseMsg> msg, std::shared_ptr<BaseMsg> &replyMsg) override;
|
H A D | inter_ipc_service_stub.h | 33 int32_t DoIpcCommand(std::shared_ptr<BaseMsg> msg, std::shared_ptr<BaseMsg> &replyMsg) override;
|
H A D | i_inter_ipc.h | 34 virtual int32_t DoIpcCommand(std::shared_ptr<BaseMsg> msg, std::shared_ptr<BaseMsg> &replyMsg) = 0;
|
H A D | inter_ipc_proxy.h | 31 int32_t DoIpcCommand(std::shared_ptr<BaseMsg> msg, std::shared_ptr<BaseMsg> &replyMsg) override;
|
H A D | inter_ipc_client_stub.cpp | 65 int32_t InterIpcClientStub::DoIpcCommand(std::shared_ptr<BaseMsg> msg, std::shared_ptr<BaseMsg> &replyMsg) in DoIpcCommand()
|
H A D | inter_ipc_client.h | 48 int32_t Send(std::shared_ptr<BaseMsg> msg, std::shared_ptr<BaseMsg> &reply);
|
/foundation/CastEngine/castengine_wifi_display/services/interaction/domain/ |
H A D | domain_manager.cpp | 42 int32_t DomainManager::SendDomainRequest(std::string remoteId, std::shared_ptr<BaseDomainMsg> BaseMsg) in SendDomainRequest() argument 45 RETURN_INVALID_IF_NULL(BaseMsg); in SendDomainRequest() 46 auto mgr = FindMgrByRemoteId(BaseMsg->toDevId); in SendDomainRequest() 49 mgr->SendDomainRequest(BaseMsg->toDevId, BaseMsg); in SendDomainRequest() 51 if (!BaseMsg->toDevId.empty()) { in SendDomainRequest() 54 DomainRpcManager::GetInstance()->AddRpcClient(BaseMsg->toDevId); in SendDomainRequest() 55 DomainRpcManager::GetInstance()->SendDomainRequest(BaseMsg->toDevId, BaseMsg); in SendDomainRequest() 64 void DomainManager::OnDomainRequest(std::string remoteId, std::shared_ptr<BaseDomainMsg> BaseMsg) in OnDomainRequest() argument [all...] |
H A D | domain_def.h | 39 virtual void OnDomainRequest(std::string remoteId, std::shared_ptr<BaseDomainMsg> BaseMsg) = 0; 80 virtual int32_t SendDomainRequest(std::string remoteId, std::shared_ptr<BaseDomainMsg> BaseMsg) = 0; 99 virtual void OnDomainRequest(std::string remoteId, std::shared_ptr<BaseDomainMsg> BaseMsg) = 0; 119 virtual int32_t SendDomainRequest(std::string remoteId, std::shared_ptr<BaseDomainMsg> BaseMsg) = 0;
|
/foundation/CastEngine/castengine_wifi_display/services/interaction/ipc_codec/ |
H A D | ipc_msg.h | 25 struct BaseMsg { struct 31 BaseMsg() = default; 32 virtual ~BaseMsg() = default; 35 struct BaseDomainMsg : public BaseMsg {
|
H A D | ipc_msg_decoder.cpp | 22 int32_t IpcMsgDecoder::MsgDecode(std::shared_ptr<BaseMsg> &sharingMsg, MessageParcel &ipcMsg) in MsgDecode() 32 std::shared_ptr<BaseMsg> reply = nullptr; in DomainMsgDecode()
|
H A D | ipc_msg_encoder.cpp | 22 int32_t IpcMsgEncoder::MsgEncode(MessageParcel &ipcMsg, std::shared_ptr<BaseMsg> &sharingMsg) in MsgEncode() 34 auto msg = std::static_pointer_cast<BaseMsg>(sharingMsg); in DomainMsgEncode()
|
H A D | ipc_msg_bind_macros.h | 23 virtual int32_t OnIpcMessage(const int32_t nMsgType, MessageParcel &ipcMsg, std::shared_ptr<BaseMsg> &sharingMsg) \ 47 virtual int32_t OnIpcMessage(const int32_t nMsgType, std::shared_ptr<BaseMsg> &sharingMsg, MessageParcel &ipcMsg) \
|
/foundation/CastEngine/castengine_wifi_display/services/interaction/domain/rpc/ |
H A D | domain_rpc_manager.cpp | 42 int32_t DomainRpcManager::SendDomainRequest(std::string remoteId, std::shared_ptr<BaseDomainMsg> BaseMsg) in SendDomainRequest() argument 45 RETURN_INVALID_IF_NULL(BaseMsg); in SendDomainRequest() 46 BaseMsg->fromDevId = DmKit::GetLocalDevicesInfo().deviceId; in SendDomainRequest() 47 SHARING_LOGD("msg from %{public}s -> to %{public}s.", GetAnonyString(BaseMsg->fromDevId).c_str(), in SendDomainRequest() 48 GetAnonyString(BaseMsg->toDevId).c_str()); in SendDomainRequest() 50 if (rpcClients_.find(BaseMsg->toDevId) != rpcClients_.end()) { in SendDomainRequest() 51 rpcClients_[BaseMsg->toDevId]->SendDomainRequest(remoteId, BaseMsg); in SendDomainRequest() 158 void DomainRpcManager::OnDomainRequest(std::string remoteId, std::shared_ptr<BaseDomainMsg> BaseMsg) in OnDomainRequest() argument 163 listener->OnDomainRequest(remoteId, BaseMsg); in OnDomainRequest() [all...] |
H A D | domain_rpc_manager.h | 35 int32_t SendDomainRequest(std::string remoteId, std::shared_ptr<BaseDomainMsg> BaseMsg) override; 44 void OnDomainRequest(std::string remoteId, std::shared_ptr<BaseDomainMsg> BaseMsg) final;
|
/foundation/CastEngine/castengine_wifi_display/services/impl/scene/wfd/ |
H A D | wfd_msg.h | 56 struct WfdCommonRsp : public BaseMsg { 76 struct WfdSinkStartReq : public BaseMsg { 83 struct WfdSinkStopReq : public BaseMsg { 90 struct WfdAppendSurfaceReq : public BaseMsg { 115 struct WfdRemoveSurfaceReq : public BaseMsg { 144 struct SetMediaFormatReq : public BaseMsg { 168 struct WfdPlayReq : public BaseMsg { 188 struct WfdPauseReq : public BaseMsg { 208 struct WfdCloseReq : public BaseMsg { 228 struct SetSceneTypeReq : public BaseMsg { [all...] |
H A D | wfd_source_scene.h | 92 void OnRequest(std::shared_ptr<BaseMsg> msg, std::shared_ptr<BaseMsg> &reply) final; 114 int32_t HandleStartDiscovery(std::shared_ptr<BaseMsg> &baseMsg, std::shared_ptr<WfdCommonRsp> &reply); 115 int32_t HandleStopDiscovery(std::shared_ptr<BaseMsg> &baseMsg, std::shared_ptr<WfdCommonRsp> &reply); 116 int32_t HandleAddDevice(std::shared_ptr<BaseMsg> &baseMsg, std::shared_ptr<WfdCommonRsp> &reply); 117 int32_t HandleRemoveDevice(std::shared_ptr<BaseMsg> &baseMsg, std::shared_ptr<WfdCommonRsp> &reply);
|
/foundation/CastEngine/castengine_wifi_display/frameworks/innerkitsimpl/native/wfd/ |
H A D | wfd_source_impl.cpp | 77 auto reply = std::static_pointer_cast<BaseMsg>(std::make_shared<WfdCommonRsp>()); in StartDiscover() 97 auto replyStopDiscoveryReq = std::static_pointer_cast<BaseMsg>(std::make_shared<WfdCommonRsp>()); in StopDiscover() 122 auto reply = std::static_pointer_cast<BaseMsg>(std::make_shared<WfdCommonRsp>()); in AddDevice() 146 auto reply = std::static_pointer_cast<BaseMsg>(std::make_shared<WfdCommonRsp>()); in RemoveDevice() 169 void WfdSourceImpl::OnRequest(std::shared_ptr<BaseMsg> msg, std::shared_ptr<BaseMsg> &reply) in OnRequest() 192 std::shared_ptr<BaseMsg> baseMsg = std::static_pointer_cast<BaseMsg>(msg); in OnRemoteDied()
|
H A D | wfd_sink_impl.cpp | 83 auto reply = std::static_pointer_cast<BaseMsg>(std::make_shared<GetSinkConfigRsp>()); in GetSinkConfig() 135 auto reply = std::static_pointer_cast<BaseMsg>(std::make_shared<WfdCommonRsp>()); in AppendSurface() 158 auto reply = std::static_pointer_cast<BaseMsg>(std::make_shared<WfdCommonRsp>()); in RemoveSurface() 178 auto reply = std::static_pointer_cast<BaseMsg>(std::make_shared<WfdCommonRsp>()); in Start() 198 auto reply = std::static_pointer_cast<BaseMsg>(std::make_shared<WfdCommonRsp>()); in Stop() 222 auto reply = std::static_pointer_cast<BaseMsg>(std::make_shared<WfdCommonRsp>()); in SetMediaFormat() 243 auto reply = std::static_pointer_cast<BaseMsg>(std::make_shared<WfdCommonRsp>()); in Play() 264 auto reply = std::static_pointer_cast<BaseMsg>(std::make_shared<WfdCommonRsp>()); in Pause() 285 auto reply = std::static_pointer_cast<BaseMsg>(std::make_shared<WfdCommonRsp>()); in Close() 309 auto reply = std::static_pointer_cast<BaseMsg>(st in SetSceneType() [all...] |
/foundation/CastEngine/castengine_wifi_display/tests/unittest/interaction/interprocess/ |
H A D | interprocess_unit_test.cpp | 62 void OnIpcRequest(std::shared_ptr<BaseMsg> msg, std::shared_ptr<BaseMsg> &reply) in OnIpcRequest() 72 void OnRequest(std::shared_ptr<BaseMsg> msg, std::shared_ptr<BaseMsg> &reply) in OnRequest() 128 auto msg = std::make_shared<BaseMsg>(); in HWTEST_F() 130 auto replyMsg = std::make_shared<BaseMsg>(); in HWTEST_F() 215 auto msg = std::make_shared<BaseMsg>(); in HWTEST_F() 217 auto replyMsg = std::make_shared<BaseMsg>(); in HWTEST_F() 225 auto replyMsg = std::make_shared<BaseMsg>(); in HWTEST_F() 294 auto msg = std::make_shared<BaseMsg>(); in HWTEST_F() [all...] |
/foundation/CastEngine/castengine_wifi_display/tests/unittest/impl/scene/mock/ |
H A D | mock_ipc_msg_adapter.h | 27 MOCK_METHOD(int32_t, SendRequest, (std::shared_ptr<BaseMsg> msg, std::shared_ptr<BaseMsg> &reply));
|