/base/request/request/services/src/ |
H A D | lib.rs | 74 static ONCE: std::sync::Once = std::sync::Once::new(); 79 let _ = std::fs::create_dir("test_files/"); 92 DB_LOCK = std::sync::Mutex::new(()); 101 _inner: std::sync::MutexGuard<'a, ()>, 112 static mut DB_LOCK: std::sync::Mutex<()> = std::sync::Mutex::new(());
|
/base/security/access_token/test/fuzztest/innerkits/accesstoken/getpermissionsstatus_fuzzer/ |
H A D | getpermissionsstatus_fuzzer.cpp | 29 using namespace std; 79 std::string GetStringFromData(int strlen) in GetStringFromData() 86 std::string str(cstr); in GetStringFromData() 100 if (size > sizeof(uint32_t) + sizeof(std::string)) { in GetPermissionsStatusFuzzTest() 102 std::string testPerName = GetStringFromData(int(size)); in GetPermissionsStatusFuzzTest() 103 std::vector<PermissionListState> permsList; in GetPermissionsStatusFuzzTest()
|
/base/security/access_token/services/tokensyncmanager/test/mock/src/ |
H A D | soft_bus_socket_mock.cpp | 29 static std::string g_uuid = ""; 69 std::string str(reinterpret_cast<char *>(buf)); in DecompressMock() 73 std::size_t id_post = str.find("\"id\":"); in DecompressMock() 75 std::string id_string = str.substr(id_post + 6, 9); in DecompressMock() 81 void CompressMock(const std::string &json, const unsigned char *compressedBytes, int &compressedLength) in CompressMock() 104 std::string GetUuidMock() in GetUuidMock()
|
/base/security/dataclassification/test/fuzztest/datatransmitmgr/gethighestseclevelasync_fuzzer/ |
H A D | gethighestseclevelasync_fuzzer.cpp | 59 std::string isEnforcing; in BeginFuzzCase1() 76 static std::mutex g_mtx; 77 static std::condition_variable g_cv; 104 std::unique_lock<std::mutex> lck(g_mtx); in FuzzDoGetHighestSecLevelAsync() 105 g_cv.wait_for(lck, std::chrono::milliseconds(DELAY_TIME), []() { return (g_cnt == 1); }); in FuzzDoGetHighestSecLevelAsync()
|
/base/sensors/medical_sensor/utils/src/ |
H A D | dmd_report.cpp | 33 std::map<int32_t, int64_t> DmdReport::eventMap_ = { 46 std::mutex DmdReport::eventMutex_; 48 static std::string GetEventName(int32_t eventId) in GetEventName() 76 void DmdReport::ReportException(int32_t eventId, const std::string &interfaceName, int32_t error) in ReportException() 79 std::lock_guard<std::mutex> eventLock(eventMutex_); in ReportException()
|
/base/security/security_component_manager/services/security_component_service/sa/sa_main/ |
H A D | sec_comp_service.h | 43 int32_t RegisterSecurityComponent(SecCompType type, const std::string& componentInfo, int32_t& scId) override; 44 int32_t UpdateSecurityComponent(int32_t scId, const std::string& componentInfo) override; 47 const std::string& componentInfo, const SecCompClickEvent& clickInfo, 53 int Dump(int fd, const std::vector<std::u16string>& args) override; 56 int32_t ParseParams(const std::string& componentInfo, SecCompCallerInfo& caller, nlohmann::json& jsonRes);
|
/base/telephony/call_manager/services/distributed_call/src/transmission/ |
H A D | server_session.cpp | 26 void ServerSession::Create(const std::string &localName) in Create() 33 std::lock_guard<ffrt::mutex> lock(mutex_); in Create() 63 std::lock_guard<ffrt::mutex> lockAdd(mutex_); in Create() 69 std::lock_guard<ffrt::mutex> lock(mutex_); in Destroy() 81 std::lock_guard<ffrt::mutex> lock(mutex_); in OnSessionBind() 95 std::lock_guard<ffrt::mutex> lock(mutex_); in OnSessionShutdown()
|
/base/telephony/cellular_data/services/src/ |
H A D | traffic_management.cpp | 40 const std::string interfaceName = GetIfaceName(); in UpdatePacketData() 47 std::string TrafficManagement::GetIfaceName() in GetIfaceName() 49 std::string ifaceName = ""; in GetIfaceName() 51 std::list<int32_t> netIdList; in GetIfaceName() 52 int32_t ret = NetConnClient::GetInstance().GetNetIdByIdentifier(IDENT_PREFIX + std::to_string(simId), netIdList); in GetIfaceName() 57 std::list<sptr<NetManagerStandard::NetHandle>> netList; in GetIfaceName()
|
/base/telephony/call_manager/services/distributed_call/include/transmission/ |
H A D | session_adapter.h | 41 explicit SessionAdapter(const std::shared_ptr<ISessionCallback> &callback); 44 virtual void Create(const std::string &localName) = 0; 46 virtual void Connect(const std::string &peerDevId, const std::string &localName, const std::string &peerName) = 0; 62 std::shared_ptr<ISessionCallback> callback_{};
|
/base/telephony/cellular_call/interfaces/innerkits/satellite/ |
H A D | satellite_call_client.h | 59 int32_t slotId, const std::shared_ptr<AppExecFwk::EventHandler> &handler); 67 std::shared_ptr<AppExecFwk::EventHandler> GetHandler(int32_t slotId); 155 std::map<int32_t, std::shared_ptr<AppExecFwk::EventHandler>> handlerMap_; 157 std::mutex mutexProxy_; 158 std::mutex mutexMap_;
|
/base/time/time_service/framework/js/napi/common/include/ |
H A D | napi_work.h | 31 using NapiCbInfoParser = std::function<void(size_t argc, napi_value *argv)>; 32 using NapiExecute = std::function<void(void)>; 33 using NapiComplete = std::function<void(napi_value &)>; 43 std::string errMessage; 63 static napi_value AsyncEnqueue(napi_env env, ContextBase *ctxt, const std::string &name, 65 static napi_value SyncEnqueue(napi_env env, ContextBase *ctxt, const std::string &name,
|
/base/update/updater/services/flashd/daemon/ |
H A D | flash_commander.cpp | 30 void FlashCommander::DoCommand(const std::string &cmmParam, size_t fileSize) in DoCommand() 80 bool FlashCommander::InitPartition(const std::string &partName, const uint8_t *buffer, int bufferSize) in InitPartition() 85 std::unique_ptr<FlashdWriter> writer = FlashdImageWriter::GetInstance().GetWriter( in InitPartition() 91 partition_ = std::make_unique<Partition>(partName, std::move(writer)); in InitPartition() 104 auto writeSize = std::min(static_cast<size_t>(payloadSize), fileSize_ - currentSize_); in DoFlash()
|
/base/update/updater/services/ptable_parse/ |
H A D | composite_ptable.cpp | 26 std::vector<PtnInfo>().swap(partitionInfo_); in ParsePartitionFromBuffer() 43 std::vector<PtnInfo>().swap(partitionInfo_); in LoadPtableFromDevice() 92 bool CompositePtable::EditPartitionBuf(uint8_t *imageBuf, uint64_t imgBufSize, std::vector<PtnInfo> &modifyList) in EditPartitionBuf() 111 void CompositePtable::AddChildPtable(std::unique_ptr<Ptable> child) in AddChildPtable() 121 childs_.emplace_back(std::move(child)); in AddChildPtable() 124 void CompositePtable::AppendChildPtnInfo(const std::vector<PtnInfo> &ptnInfo) in AppendChildPtnInfo()
|
/base/time/time_service/services/ipc/proxy/inner_api_include/ |
H A D | time_service_proxy.h | 32 int32_t SetTimeZone(const std::string &timeZoneId, APIVersion apiVersion = APIVersion::API_VERSION_7) override; 33 int32_t GetTimeZone(std::string &timeZoneId) override; 36 int32_t CreateTimer(const std::shared_ptr<ITimerInfo> &timerOptions, sptr<IRemoteObject> &timerCallback, 42 bool ProxyTimer(std::set<int> pidList, bool isProxy, bool needRetrigger) override; 44 int32_t SetTimerExemption(const std::unordered_set<std::string> &nameArr, bool isExemption) override;
|
/base/update/sys_installer/services/ab_update/src/ |
H A D | ab_update.cpp | 29 UpdaterStatus ABUpdate::StartABUpdate(const std::string &pkgPath) in StartABUpdate() 58 if (!DeleteUpdaterPath(GetWorkPath()) || !DeleteUpdaterPath(std::string(UPDATER_PATH))) { in StartABUpdate() 67 if (pkgPath.find(PATCH_PACKAGE_NAME) != std::string::npos) { in StartABUpdate() 71 if (!DeleteUpdaterPath(GetWorkPath()) || !DeleteUpdaterPath(std::string(UPDATER_PATH))) { in StartABUpdate() 80 std::string errStr = ""; in PerformAction() 86 errStr = std::to_string(updateRet); in PerformAction()
|
/base/telephony/state_registry/frameworks/native/observer/src/ |
H A D | telephony_observer_client.cpp | 32 std::lock_guard<std::mutex> lock(mutexProxy_); in GetProxy() 47 std::unique_ptr<StateRegistryDeathRecipient> recipient = std::make_unique<StateRegistryDeathRecipient>(*this); in GetProxy() 69 std::lock_guard<std::mutex> lock(mutexProxy_); in OnRemoteDied()
|
/base/theme/screenlock_mgr/frameworks/js/napi/src/ |
H A D | screenlock_system_ability_callback.cpp | 29 std::mutex ScreenlockSystemAbilityCallback::eventHandlerMutex_; 30 std::shared_ptr<AppExecFwk::EventHandler> ScreenlockSystemAbilityCallback::handler_{ nullptr }; 46 auto entry = std::make_shared<ScreenlockOnCallBack>(); in OnCallBack() 71 std::shared_ptr<AppExecFwk::EventHandler> ScreenlockSystemAbilityCallback::GetEventHandler() in GetEventHandler() 73 std::lock_guard<std::mutex> lock(eventHandlerMutex_); in GetEventHandler()
|
/base/time/time_service/interfaces/inner_api/include/ |
H A D | time_service_interface.h | 43 * @param timezoneId std::string &timezoneId string 46 virtual int32_t SetTimeZone(const std::string &timezoneId, APIVersion apiVersion = APIVersion::API_VERSION_7) = 0; 51 * @param timezoneId std::string &timezoneId string 54 virtual int32_t GetTimeZone(std::string &timezoneId) = 0; 80 virtual int32_t CreateTimer(const std::shared_ptr<ITimerInfo> &timerOptions, sptr<IRemoteObject> &timerCallback, 125 virtual bool ProxyTimer(std::set<int> pidList, bool isProxy, bool needRetrigger) = 0; 141 virtual int32_t SetTimerExemption(const std::unordered_set<std::string> &nameArr, bool isExemption) = 0;
|
/base/update/updater/test/unittest/flow_update/update_bin/ |
H A D | bin_flow_update_unittest.cpp | 45 std::string packagePath = "/data/updater/package/updater_flow.zip"; in TestBinFlowUpdater() 52 std::vector<std::string> components; in TestBinFlowUpdater() 71 std::cout << "binFlowUpdateTest01 start\n"; in HWTEST_F() 74 std::cout << "fopen /data/updater/package/update.bin failed" << " : " << strerror(errno); in HWTEST_F() 90 std::cout << "binFlowUpdateTest01 end\n"; in HWTEST_F()
|
/base/useriam/fingerprint_auth/services_ex/inc/ |
H A D | sensor_illumination_task.h | 45 public std::enable_shared_from_this<SensorIlluminationTask>, 65 std::shared_ptr<Rosen::RSSurfaceNode> rsSurfaceNode_ = nullptr; 66 std::shared_ptr<Rosen::RSSurface> rsSurface_ = nullptr; 67 std::shared_ptr<Rosen::RenderContext> renderContext_ = nullptr; 75 std::recursive_mutex recursiveMutex_; 79 std::shared_ptr<ISensorIlluminationTask> GetSensorIlluminationTask();
|
/base/web/webview/ohos_interface/include/ohos_adapter/ |
H A D | audio_capturer_adapter.h | 88 const std::shared_ptr<AudioCapturerOptionsAdapter> capturerOptions, std::string cachePath = std::string()) = 0;
96 virtual int32_t SetCapturerReadCallback(std::shared_ptr<AudioCapturerReadCallbackAdapter> callbck) = 0;
98 virtual int32_t GetBufferDesc(std::shared_ptr<BufferDescAdapter> bufferDesc) = 0;
100 virtual int32_t Enqueue(const std::shared_ptr<BufferDescAdapter> bufferDesc) = 0;
|
/base/web/webview/ohos_interface/ohos_glue/ohos_adapter/bridge/webcore/ |
H A D | ark_mmi_adapter_wrapper.cpp | 33 int32_t ArkMMIAdapterWrapper::RegisterMMIInputListener(std::shared_ptr<NWeb::MMIInputListenerAdapter> eventCallback) in RegisterMMIInputListener() 47 int32_t ArkMMIAdapterWrapper::RegisterDevListener(std::string type, std::shared_ptr<NWeb::MMIListenerAdapter> listener) in RegisterDevListener() 60 int32_t ArkMMIAdapterWrapper::UnregisterDevListener(std::string type) in UnregisterDevListener() 73 int32_t ArkMMIAdapterWrapper::GetDeviceIds(std::vector<int32_t>& ids) in GetDeviceIds() 82 int32_t ArkMMIAdapterWrapper::GetDeviceInfo(int32_t deviceId, std::shared_ptr<NWeb::MMIDeviceInfoAdapter> info) in GetDeviceInfo()
|
H A D | ark_media_codec_decoder_adapter_wrapper.h | 29 OHOS::NWeb::DecoderAdapterCode CreateVideoDecoderByMime(const std::string& mimetype) override; 31 OHOS::NWeb::DecoderAdapterCode CreateVideoDecoderByName(const std::string& name) override; 34 const std::shared_ptr<OHOS::NWeb::DecoderFormatAdapter> format) override; 37 const std::shared_ptr<OHOS::NWeb::DecoderFormatAdapter> format) override; 57 std::shared_ptr<OHOS::NWeb::DecoderFormatAdapter> format) override; 62 const std::shared_ptr<OHOS::NWeb::DecoderCallbackAdapter> callback) override;
|
/base/web/webview/ohos_interface/ohos_glue/ohos_adapter/bridge/webview/ |
H A D | ark_audio_capturer_adapter_impl.cpp | 26 ArkAudioCapturerAdapterImpl::ArkAudioCapturerAdapterImpl(std::shared_ptr<OHOS::NWeb::AudioCapturerAdapter> ref)
in ArkAudioCapturerAdapterImpl() 33 std::string str = ArkWebStringStructToClass(cachePath);
in Create() 37 return real_->Create(std::make_shared<ArkAudioCapturerOptionsAdapterWrapper>(capturerOptions), str);
in Create() 62 return real_->SetCapturerReadCallback(std::make_shared<ArkAudioCapturerReadCallbackAdapterWrapper>(callback));
in SetCapturerReadCallback() 70 return real_->GetBufferDesc(std::make_shared<ArkBufferDescAdapterWrapper>(bufferDesc));
in GetBufferDesc() 78 return real_->Enqueue(std::make_shared<ArkBufferDescAdapterWrapper>(bufferDesc));
in Enqueue()
|
/base/web/webview/ohos_adapter/enterprise_device_management_adapter/src/ |
H A D | enterprise_device_management_adapter_impl.cpp | 45 std::shared_ptr<EdmPolicyChangedEventCallbackAdapter> eventCallback)
in NWebEdmEventSubscriber() 50 const std::string action = data.GetWant().GetAction();
in OnReceiveEvent() 63 std::shared_ptr<EdmPolicyChangedEventCallbackAdapter> eventCallback)
in RegistPolicyChangeEventCallback() 67 eventCallback_ = std::move(eventCallback);
in RegistPolicyChangeEventCallback() 81 this->commonEventSubscriber_ = std::make_shared<NWebEdmEventSubscriber>(info, this->eventCallback_);
in StartObservePolicyChange() 110 int32_t EnterpriseDeviceManagementAdapterImpl::GetPolicies(std::string& policies)
in GetPolicies()
|