/base/msdp/device_status/intention/cooperate/plugin/src/ |
H A D | cooperate.cpp | 53 auto ret = context_.Sender().Send(CooperateEvent( in AddObserver() 66 auto ret = context_.Sender().Send(CooperateEvent( in RemoveObserver() 79 auto ret = context_.Sender().Send(CooperateEvent( in RegisterListener() 93 auto ret = context_.Sender().Send(CooperateEvent( in UnregisterListener() 107 auto ret = context_.Sender().Send(CooperateEvent( in RegisterHotAreaListener() 121 auto ret = context_.Sender().Send(CooperateEvent( in UnregisterHotAreaListener() 135 auto ret = context_.Sender().Send(CooperateEvent( in Enable() 151 auto ret = context_.Sender().Send(CooperateEvent( in Disable() 180 auto ret = context_.Sender().Send(CooperateEvent(CooperateEventType::START, event)); in Start() 190 auto ret = context_.Sender().Send(CooperateEven in Stop() [all...] |
H A D | cooperate_context.cpp | 47 auto ret = sender_.Send(CooperateEvent( 60 auto ret = sender_.Send(CooperateEvent( 77 auto ret = sender_.Send(CooperateEvent( in OnDeviceAdded() 92 auto ret = sender_.Send(CooperateEvent( in OnDeviceRemoved()
|
/base/msdp/device_status/rust/modules/scheduler/sys/src/ |
H A D | lib.rs | 86 F: Fn() -> R + Send + 'static, in post_sync_task() 87 R: Send + 'static, in post_sync_task() 118 F: Fn() -> R + Send + 'static, in post_async_task() 119 R: Send + 'static, in post_async_task() 134 F: Fn() -> R + Send + 'static, in post_delayed_task() 135 R: Send + 'static, in post_delayed_task() 157 F: Fn() + Send + 'static in post_perioric_task() 176 F: Fn() -> R + Send + 'static, in post_blocking_task() 177 R: Send + 'static, in post_blocking_task()
|
/base/msdp/device_status/test/unittest/intention/common/src/ |
H A D | channel_test.cpp | 57 EXPECT_EQ(sender.Send(index), Channel<size_t>::NO_ERROR); in HWTEST_F() 86 EXPECT_EQ(sender.Send(index), Channel<size_t>::NO_ERROR); in HWTEST_F() 111 EXPECT_EQ(sender.Send(data), Channel<size_t>::INACTIVE_CHANNEL); in HWTEST_F() 127 EXPECT_EQ(sender.Send(data++), Channel<size_t>::NO_ERROR); in HWTEST_F() 129 EXPECT_EQ(sender.Send(data), Channel<size_t>::QUEUE_IS_FULL); in HWTEST_F()
|
/base/request/request/services/src/task/ |
H A D | client.rs | 35 ) -> Result<Client, Box<dyn Error + Send + Sync>> { 123 fn build_task_proxy(config: &TaskConfig) -> Result<Option<Proxy>, Box<dyn Error + Send + Sync>> { in build_task_proxy() 136 ) -> Result<Option<PubKeyPins>, Box<dyn Error + Send + Sync>> { in build_task_certificate_pins() 153 ) -> Result<Option<Proxy>, Box<dyn Error + Send + Sync>> { in build_system_proxy() 175 fn build_task_certs(config: &TaskConfig) -> Result<Vec<Certificate>, Box<dyn Error + Send + Sync>> { in build_task_certs()
|
/base/msdp/device_status/intention/common/channel/include/ |
H A D | channel.h | 74 int32_t Send(const Event &event) in Send() function in OHOS::Msdp::DeviceStatus::Channel::final 79 return channel_->Send(event); in Send() 167 int32_t Send(const Event &event); 203 int32_t Channel<Event>::Send(const Event &event) in Send() function in OHOS::Msdp::DeviceStatus::Channel
|
/base/location/test/fuzztest/locator/locator_fuzzer/ |
H A D | locator_fuzzer.cpp | 138 cachedCallbackHost->Send(locationsForSend); in CachedLocationsCallbackHostFuzzerTest() 157 callbackHost->Send(countryCodePtr); in CountryCodeCallbackHostFuzzerTest() 177 gnssCallbackHost->Send(statusInfo); in GnssStatusCallbackHostFuzzerTest() 196 switchCallbackHost->Send(SWITCH_STATE_ON); in LocationSwitchCallbackHostFuzzerTest() 241 nmeaCallbackHost->Send(msg); in NmeaMessageCallbackHostFuzzerTest()
|
/base/update/updater/services/flashd/daemon/ |
H A D | daemon.cpp | 159 Send(hSession->sessionId, channelId, CMD_KERNEL_HANDSHAKE, (uint8_t *)bufString.c_str(), bufString.size()); in HandDaemonAuth() 177 Send(hSession->sessionId, channelId, CMD_KERNEL_HANDSHAKE, (uint8_t *)bufString.c_str(), in HandDaemonAuth() 231 Send(hSession->sessionId, channelId, CMD_KERNEL_HANDSHAKE, (uint8_t *)bufString.c_str(), bufString.size()); in DaemonSessionHandshake() 255 Send(hSession->sessionId, channelId, CMD_KERNEL_CHANNEL_CLOSE, payload, 1); in FetchCommand() 299 return Send(sessionId, channelId, command, (uint8_t *)bufPtr, size) > 0; in ServerCommand()
|
/base/location/frameworks/cj/include/ |
H A D | gnss_status_callback.h | 36 bool Send(std::unique_ptr<Location::SatelliteStatus>& statusInfo);
|
/base/location/frameworks/js/napi/include/ |
H A D | country_code_callback_napi.h | 37 bool Send(const std::shared_ptr<CountryCode>& country);
|
H A D | nmea_message_callback_napi.h | 41 bool Send(const std::string msg);
|
H A D | location_switch_callback_napi.h | 39 bool Send(int switchState);
|
H A D | location_error_callback_napi.h | 41 bool Send(int switchState);
|
H A D | cached_locations_callback_napi.h | 42 bool Send(std::vector<std::unique_ptr<Location>>& locations);
|
H A D | gnss_status_callback_napi.h | 40 bool Send(std::unique_ptr<SatelliteStatus>& statusInfo);
|
H A D | locating_required_data_callback_napi.h | 38 bool Send(const std::vector<std::shared_ptr<LocatingRequiredData>>& data);
|
/base/telephony/core_service/services/network_search/src/ |
H A D | network_utils.cpp | 377 return Send<EventGetMode::GET_EVENT_BY_HANDLERID, RilFunc_Event>(parameters); in SendBase() 385 return Send<EventGetMode::GET_EVENT_BY_PARAM, RilFunc_Int_Event, int32_t>(parameters, param); in SendBase() 393 return Send<EventGetMode::GET_EVENT_BY_PARAM, RilFunc_Int_Int_Event, int32_t, int32_t>( in SendBase() 402 return Send<EventGetMode::GET_EVENT_BY_PARAM, RilFunc_Int_String_Event, int32_t, std::string>( in SendBase() 411 return Send<EventGetMode::GET_EVENT_BY_INDEX, RilFunc_Event>(parameters); in SendCallback() 420 return Send<EventGetMode::GET_EVENT_BY_PARAM, RilFunc_Event>(parameters); in SendCallback() 429 return Send<EventGetMode::GET_EVENT_BY_INDEX, RilFunc_Int_Event, int32_t>(parameters, param); in SendCallbackEx() 438 return Send<EventGetMode::GET_EVENT_BY_INDEX, RilFunc_Int_Int_Event, int32_t, int32_t>( in SendCallback() 448 return Send<EventGetMode::GET_EVENT_BY_INDEX, RilFunc_Int_String_Event, int32_t, std::string>( in SendCallback() 458 return Send<EventGetMod in SendCallbackNetworkExt() [all...] |
/base/msdp/device_status/rust/data/sys/src/ |
H A D | plugin_manager.rs | 35 pub trait IPlugin: Any + Send + Sync + std::panic::RefUnwindSafe {
|
/base/location/frameworks/js/napi/source/ |
H A D | nmea_message_callback_napi.cpp | 129 bool NmeaMessageCallbackNapi::Send(const std::string msg) in Send() function in OHOS::Location::NmeaMessageCallbackNapi 221 Send(msg); in OnMessageChange()
|
H A D | location_switch_callback_napi.cpp | 123 bool LocationSwitchCallbackNapi::Send(int switchState) in Send() function in OHOS::Location::LocationSwitchCallbackNapi 213 Send(switchState); in OnSwitchChange()
|
H A D | location_error_callback_napi.cpp | 109 bool LocationErrorCallbackNapi::Send(int32_t errorCode) in Send() function in OHOS::Location::LocationErrorCallbackNapi 208 Send(errorCode); in OnErrorReport()
|
H A D | gnss_status_callback_napi.cpp | 57 Send(statusInfo); in OnRemoteRequest() 122 bool GnssStatusCallbackNapi::Send(std::unique_ptr<SatelliteStatus>& statusInfo) in Send() function in OHOS::Location::GnssStatusCallbackNapi
|
H A D | country_code_callback_napi.cpp | 83 bool CountryCodeCallbackNapi::Send(const std::shared_ptr<CountryCode>& country) in Send() function in OHOS::Location::CountryCodeCallbackNapi 186 Send(country); in OnCountryCodeChange()
|
H A D | cached_locations_callback_napi.cpp | 60 Send(locations); in OnRemoteRequest() 126 bool CachedLocationsCallbackNapi::Send(std::vector<std::unique_ptr<Location>>& locations) in Send() function in OHOS::Location::CachedLocationsCallbackNapi
|
/base/hiviewdfx/hisysevent/interfaces/rust/innerkits/src/ |
H A D | sys_event_manager.rs | 280 F1: Fn(&[HiSysEventRecord]) + Send + Sync + 'static, in new() 281 F2: Fn(i32, i32) + Send + Sync + 'static, in new() 310 F: Fn(&[HiSysEventRecord]) + Send + Sync + 'static, 333 F: Fn(i32, i32) + Send + Sync + 'static, 440 F1: Fn(HiSysEventRecord) + Send + Sync + 'static, in new() 441 F2: Fn() + Send + Sync + 'static, in new() 469 F: Fn(HiSysEventRecord) + Send + Sync + 'static, 484 F: Fn() + Send + Sync + 'static,
|