Home
last modified time | relevance | path

Searched refs:ReceiveMessage (Results 1 – 19 of 19) sorted by relevance

/ohos5.0/foundation/communication/netmanager_base/services/netpolicymanager/include/
H A Dnet_policy_core.h108 class ReceiveMessage : public EventFwk::CommonEventSubscriber {
110ReceiveMessage(const EventFwk::CommonEventSubscribeInfo &subscriberInfo, std::shared_ptr<NetPolicy…
123 std::shared_ptr<ReceiveMessage> subscriber_ = nullptr;
/ohos5.0/foundation/communication/netmanager_base/services/netpolicymanager/src/core/
H A Dnet_policy_core.cpp105 subscriber_ = std::make_shared<ReceiveMessage>(subscribeInfo, shared_from_this()); in SubscribeCommonEvent()
124 void NetPolicyCore::ReceiveMessage::OnReceiveEvent(const EventFwk::CommonEventData &eventData) in OnReceiveEvent()
184 NetPolicyCore::ReceiveMessage::ReceiveMessage(const EventFwk::CommonEventSubscribeInfo &subscriberI… in ReceiveMessage() function in OHOS::NetManagerStandard::NetPolicyCore::ReceiveMessage
/ohos5.0/foundation/communication/netmanager_ext/services/netfirewallmanager/include/
H A Dnetfirewall_service.h52 class ReceiveMessage : public OHOS::EventFwk::CommonEventSubscriber {
54 explicit ReceiveMessage(const EventFwk::CommonEventSubscribeInfo &subscriberInfo, in ReceiveMessage() function
196 std::shared_ptr<ReceiveMessage> subscriber_ = nullptr;
/ohos5.0/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/wrapper/
H A Ddata_receiver.cpp54 ssize_t recvTimes = TEMP_FAILURE_RETRY(ReceiveMessage(isRepair, uid)); in StartReceive()
72 ssize_t DataReceiver::ReceiveMessage(bool isRepair, uid_t &uid) in ReceiveMessage() function in OHOS::nmd::DataReceiver
/ohos5.0/foundation/communication/netmanager_ext/services/vpnmanager/include/
H A Dnetworkvpn_service.h77 class ReceiveMessage : public OHOS::EventFwk::CommonEventSubscriber {
79 …explicit ReceiveMessage(const EventFwk::CommonEventSubscribeInfo &subscriberInfo, NetworkVpnServic… in ReceiveMessage() function
238 std::shared_ptr<ReceiveMessage> subscriber_ = nullptr;
/ohos5.0/foundation/communication/netmanager_base/services/netmanagernative/include/netsys/wrapper/
H A Ddata_receiver.h56 ssize_t ReceiveMessage(bool isRepair, uid_t &uid);
/ohos5.0/foundation/communication/netmanager_base/test/netmanagernative/unittest/netsys_wrapper_test/
H A Ddata_receiver_test.cpp84 ssize_t count = instance_->ReceiveMessage(true, uid);
/ohos5.0/base/sensors/sensor/frameworks/native/include/
H A Dsensor_service_client.h54 void ReceiveMessage(const char *buf, size_t size);
/ohos5.0/foundation/communication/netmanager_ext/services/netfirewallmanager/src/
H A Dnetfirewall_service.cpp399 subscriber_ = std::make_shared<ReceiveMessage>(subscribeInfo, shared_from_this()); in SubscribeCommonEvent()
412 void NetFirewallService::ReceiveMessage::OnReceiveEvent(const EventFwk::CommonEventData &eventData) in OnReceiveEvent()
/ohos5.0/drivers/peripheral/camera/vdi_base/common/buffer_manager/src/
H A Dbuffer_loop_tracking.cpp360 std::shared_ptr<BufferTrackingMessage> BufferLoopTracking::ReceiveMessage() in ReceiveMessage() function in OHOS::Camera::BufferLoopTracking
397 auto message = ReceiveMessage(); in HandleMessage()
/ohos5.0/drivers/peripheral/camera/vdi_base/common/buffer_manager/include/
H A Dbuffer_loop_tracking.h124 std::shared_ptr<BufferTrackingMessage> ReceiveMessage();
/ohos5.0/base/sensors/sensor/frameworks/native/src/
H A Dsensor_service_client.cpp429 void SensorServiceClient::ReceiveMessage(const char *buf, size_t size) in ReceiveMessage() function in OHOS::Sensors::SensorServiceClient
521 [this] (const char *buf, size_t size) { this->ReceiveMessage(buf, size); }, in HandleNetPacke()
/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/external/dummy/include/stub/
H A Dmap_service.h221 int ReceiveMessage(int type, std::string id = "")
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dremote_executor.h65 int ReceiveMessage(const std::string &targetDev, Message *inMsg);
H A Dremote_executor.cpp97 int RemoteExecutor::ReceiveMessage(const std::string &targetDev, Message *inMsg) in ReceiveMessage() function in DistributedDB::RemoteExecutor
H A Dsync_engine.cpp1203 errCode = executor->ReceiveMessage(targetDev, inMsg); in HandleRemoteExecutorMsg()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dgeneric_virtual_device.cpp152 executor_->ReceiveMessage(deviceId, inMsg); in MessageCallback()
H A Ddistributeddb_mock_sync_module_test.cpp1573 executor->ReceiveMessage("DEVICE", message);
/ohos5.0/foundation/communication/netmanager_ext/services/vpnmanager/src/
H A Dnetworkvpn_service.cpp1005 subscriber_ = std::make_shared<ReceiveMessage>(subscribeInfo, *this); in SubscribeCommonEvent()
1020 void NetworkVpnService::ReceiveMessage::OnReceiveEvent(const EventFwk::CommonEventData &eventData) in OnReceiveEvent()