| /foundation/communication/netmanager_ext/services/mdnsmanager/src/protocol/ |
| D | mdns_packet_parser.cpp | 34 const uint8_t *begin = reinterpret_cast<const uint8_t *>(&data); in WriteRawData() local
35 payload.insert(payload.end(), begin, begin + sizeof(T)); in WriteRawData()
40 const uint8_t *begin = reinterpret_cast<const uint8_t *>(&data); in WriteRawData() local
42 ptr[i] = *begin++; in WriteRawData()
90 const uint8_t *MDnsPayloadParser::Parse(const uint8_t *begin, const MDnsPayload &payload, MDnsMessa… in Parse() argument
92 begin = ParseHeader(begin, payload, msg.header); in Parse()
94 return begin; in Parse()
97 begin = ParseQuestion(begin, payload, msg.questions); in Parse()
99 return begin; in Parse()
103 begin = ParseRR(begin, payload, msg.answers); in Parse()
[all …]
|
| /foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_manage/wifi_p2p/ |
| D | wifi_p2p_dns_txt_record.cpp | 47 data.insert(data.begin(), oldData.begin(), oldData.begin() + insertIndex); in InsertData()
49 data.insert(data.begin() + newDataLength - secondHalfLength, in InsertData()
50 oldData.begin() + insertIndex, in InsertData()
51 oldData.begin() + insertIndex + secondHalfLength); in InsertData()
52 data.insert(data.begin() + insertIndex, static_cast<unsigned char>(addLength)); in InsertData()
53 data.insert(data.begin() + insertIndex + mapLengthSize, keyBytes.begin(), keyBytes.end()); in InsertData()
56 data.insert(data.begin() + insertIndex + mapLengthSize + keyBytes.size(), 0x3d); in InsertData()
57 … data.insert(data.begin() + insertIndex + keyBytes.size() + mapLengthSize + equalSeparatorSize, in InsertData()
58 valBytes.begin(), in InsertData()
79 std::transform(dataStr.begin(), dataStr.end(), dataStr.begin(), ::tolower); in RemoveData()
[all …]
|
| D | wifi_p2p_group_manager.cpp | 44 for (auto it = groupsInfo.begin(); it != groupsInfo.end(); ++it) { in AddGroup()
56 for (auto it = groupsInfo.begin(); it != groupsInfo.end(); ++it) { in AddOrUpdateGroup()
68 for (auto it = groupsInfo.begin(); it != groupsInfo.end(); ++it) { in RemoveGroup()
87 for (auto it = groupsInfo.begin(); it != groupsInfo.end(); ++it) { in UpdateWpaGroup()
107 auto it = groupsInfo.begin(); in RemoveClientFromGroup()
135 std::transform(deviceAddr.begin(), deviceAddr.end(), deviceAddr.begin(), ::tolower); in GetNetworkIdFromClients()
138 for (auto it = groupsInfo.begin(); it != groupsInfo.end(); ++it) { in GetNetworkIdFromClients()
140 for (auto client = clients.begin(); client != clients.end(); client++) { in GetNetworkIdFromClients()
142 std::transform(clientAddr.begin(), clientAddr.end(), clientAddr.begin(), ::tolower); in GetNetworkIdFromClients()
155 std::transform(deviceMac.begin(), deviceMac.end(), deviceMac.begin(), ::tolower); in GetGroupNetworkId()
[all …]
|
| /foundation/distributeddatamgr/kv_store/kvstoremock/frameworks/innerkitsimpl/kvdb/src/ |
| D | device_convertor.cpp | 42 dbKey.insert(dbKey.end(), uuid.begin(), uuid.end()); in ToLocal()
43 dbKey.insert(dbKey.end(), original.begin(), original.end()); in ToLocal()
73 deviceId = DevManager::GetInstance().ToNetworkId({key.begin(), key.begin() + length}); in ToKey()
76 key.erase(key.begin(), key.begin() + length); in ToKey()
115 size_t begin = 0; in ConvertNetwork() local
119 std::string deviceLen(in.Data().begin() + begin, in.Data().begin() + begin + sizeof(uint32_t)); in ConvertNetwork()
133 begin += sizeof(uint32_t); in ConvertNetwork()
135 std::string networkId(in.Data().begin() + begin, in.Data().begin() + begin + devLen); in ConvertNetwork()
142 begin += devLen; in ConvertNetwork()
148 std::vector<uint8_t> original { in.Data().begin() + begin, in.Data().end() }; in ConvertNetwork()
[all …]
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/ |
| D | device_convertor.cpp | 43 dbKey.insert(dbKey.end(), uuid.begin(), uuid.end()); in ToLocal()
44 dbKey.insert(dbKey.end(), original.begin(), original.end()); in ToLocal()
75 deviceId = DevManager::GetInstance().ToNetworkId({ key.begin(), key.begin() + length }); in ToKey()
79 key.erase(key.begin(), key.begin() + length); in ToKey()
118 size_t begin = 0; in ConvertNetwork() local
122 std::string deviceLen(in.Data().begin() + begin, in.Data().begin() + begin + sizeof(uint32_t)); in ConvertNetwork()
136 begin += sizeof(uint32_t); in ConvertNetwork()
138 std::string networkId(in.Data().begin() + begin, in.Data().begin() + begin + devLen); in ConvertNetwork()
145 begin += devLen; in ConvertNetwork()
151 std::vector<uint8_t> original{ in.Data().begin() + begin, in.Data().end() }; in ConvertNetwork()
[all …]
|
| /foundation/arkui/ace_engine/frameworks/core/animation/ |
| D | evaluator.h | 34 virtual T Evaluate(const T& begin, const T& end, float fraction) = 0;
44 T Evaluate(const T& begin, const T& end, float fraction) override in Evaluate() argument
46 return begin + (end - begin) * fraction; in Evaluate()
53 Color Evaluate(const Color& begin, const Color& end, float fraction) override in Evaluate() argument
59 double beginAlpha = begin.GetAlpha(); in Evaluate()
60 ConvertGammaToLinear(begin, beginLinearRed, beginLinearGreen, beginLinearBlue); in Evaluate()
112 BorderStyle Evaluate(const BorderStyle& begin, const BorderStyle& end, float fraction) override in Evaluate() argument
117 return begin; in Evaluate()
126 …TransformOperation Evaluate(const TransformOperation& begin, const TransformOperation& end, float … in Evaluate() argument
128 return TransformOperation::Blend(end, begin, fraction); in Evaluate()
[all …]
|
| /foundation/multimedia/av_codec/test/unittest/hcodec_test/helper/ |
| D | tester_codecbase.cpp | 52 auto begin = std::chrono::steady_clock::now(); in Create() local
58 CostRecorder::Instance().Update(begin, "Create"); in Create()
65 auto begin = std::chrono::steady_clock::now(); in SetCallback() local
71 CostRecorder::Instance().Update(begin, "SetCallback"); in SetCallback()
77 auto begin = std::chrono::steady_clock::now(); in Start() local
83 CostRecorder::Instance().Update(begin, "Start"); in Start()
89 auto begin = std::chrono::steady_clock::now(); in Stop() local
95 CostRecorder::Instance().Update(begin, "Stop"); in Stop()
101 auto begin = std::chrono::steady_clock::now(); in Release() local
107 CostRecorder::Instance().Update(begin, "Release"); in Release()
[all …]
|
| D | tester_capi.cpp | 62 auto begin = std::chrono::steady_clock::now(); in Create() local
68 CostRecorder::Instance().Update(begin, in Create()
81 auto begin = std::chrono::steady_clock::now(); in SetCallback() local
88 CostRecorder::Instance().Update(begin, in SetCallback()
95 auto begin = std::chrono::steady_clock::now(); in Start() local
102 CostRecorder::Instance().Update(begin, in Start()
109 auto begin = std::chrono::steady_clock::now(); in Stop() local
116 CostRecorder::Instance().Update(begin, in Stop()
123 auto begin = std::chrono::steady_clock::now(); in Release() local
130 CostRecorder::Instance().Update(begin, in Release()
[all …]
|
| /foundation/resourceschedule/device_usage_statistics/interfaces/kits/bundlestats/js/ |
| D | @ohos.bundleState.d.ts | 271 …function queryBundleStateInfos(begin: number, end: number, callback: AsyncCallback<BundleActiveInf…
288 function queryBundleStateInfos(begin: number, end: number): Promise<BundleActiveInfoResponse>;
358 begin: number,
381 begin: number,
398 …function queryBundleActiveStates(begin: number, end: number, callback: AsyncCallback<Array<BundleA…
413 function queryBundleActiveStates(begin: number, end: number): Promise<Array<BundleActiveState>>;
427 begin: number,
443 …function queryCurrentBundleActiveStates(begin: number, end: number): Promise<Array<BundleActiveSta…
|
| D | @ohos.resourceschedule.usageStatistics.d.ts | 648 …function queryBundleStatsInfos(begin: number, end: number, callback: AsyncCallback<BundleStatsMap>…
673 function queryBundleStatsInfos(begin: number, end: number): Promise<BundleStatsMap>;
752 begin: number,
784 begin: number,
810 …function queryBundleEvents(begin: number, end: number, callback: AsyncCallback<Array<BundleEvents>…
834 function queryBundleEvents(begin: number, end: number): Promise<Array<BundleEvents>>;
857 …function queryCurrentBundleEvents(begin: number, end: number, callback: AsyncCallback<Array<Bundle…
880 function queryCurrentBundleEvents(begin: number, end: number): Promise<Array<BundleEvents>>;
1182 …function queryDeviceEventStats(begin: number, end: number, callback: AsyncCallback<Array<DeviceEve…
1206 function queryDeviceEventStats(begin: number, end: number): Promise<Array<DeviceEventStats>>;
[all …]
|
| /foundation/resourceschedule/ffrt/src/sched/ |
| D | load_predictor.h | 50 std::fill(loadHist.begin(), loadHist.end(), 0UL); in SimpleLoadPredictor()
64 for (auto begin = loadHist.rbegin(); begin < end; ++begin) { in UpdateLoadImpl() local
65 *begin = *(begin + 1); in UpdateLoadImpl()
66 sum += *begin; in UpdateLoadImpl()
76 std::fill(loadHist.begin(), loadHist.end(), 0UL); in ClearImpl()
|
| /foundation/graphic/graphic_2d/rosen/modules/texgine/src/ |
| D | text_reverser.cpp | 32 for (auto it = lineSpans.begin(); it != lineSpans.end(); it++) { in ReverseRTLText()
71 void TextReverser::ReverseConDirectionText(std::vector<VariantSpan> &lineSpans, int begin, int end) in ReverseConDirectionText() argument
73 while (begin < end) { in ReverseConDirectionText()
74 if (lineSpans[begin].GetVisibleWidth() == 0) { in ReverseConDirectionText()
75 begin++; in ReverseConDirectionText()
82 if (begin >= end) { in ReverseConDirectionText()
86 auto temp = lineSpans[begin]; in ReverseConDirectionText()
87 lineSpans[begin] = lineSpans[end]; in ReverseConDirectionText()
89 begin++; in ReverseConDirectionText()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/ |
| D | multi_ver_natural_store_transfer_data.cpp | 41 …std::copy(oriValue.begin() + i * sizeByte, oriValue.begin() + sizeByte * (i + 1), tempValue.begin(… in SegmentAndTransferValueToHash()
45 std::copy(oriValue.begin() + partNum * sizeByte, oriValue.end(), tailValue.begin()); in SegmentAndTransferValueToHash()
|
| /foundation/multimedia/histreamer/engine/plugin/plugins/ffmpeg_adapter/utils/ |
| D | bit_reader.cpp | 30 BitReader::BitReader(const uint8_t* begin, const uint8_t* end) : begin_(begin), cur_(begin), end_(e… in BitReader() argument
81 void BitReader::Reset(const uint8_t* begin, const uint8_t* end) in Reset() argument
83 begin_ = begin; in Reset()
84 cur_ = begin; in Reset()
|
| D | bit_reader.h | 32 BitReader(const uint8_t* begin, const uint8_t* end);
40 BitReader(const T* begin, const T* end) in BitReader() argument
41 …: BitReader(reinterpret_cast<const uint8_t*>(begin), reinterpret_cast<const uint8_t*>(end)) // NOL… in BitReader()
91 void Reset(const T* begin, const T* end) in Reset() argument
93 …Reset(reinterpret_cast<const uint8_t*>(begin), reinterpret_cast<const uint8_t*>(end)); // NOLINT: … in Reset()
97 void Reset(const uint8_t* begin, const uint8_t* end);
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/gaussdb_rd/src/interface/src/ |
| D | collection.cpp | 28 …std::transform(lowerCaseName.begin(), lowerCaseName.end(), lowerCaseName.begin(), [](unsigned char… in Collection()
42 key.assign(id.begin(), id.end()); in InsertUntilSuccess()
46 key.assign(docKey.key.begin(), docKey.key.end()); in InsertUntilSuccess()
65 Value valSet(document.begin(), document.end()); in InsertDocument()
69 key.assign(id.begin(), id.end()); in InsertDocument()
127 Value valSet(newDocument.begin(), newDocument.end()); in UpsertDocument()
131 key.assign(id.begin(), id.end()); in UpsertDocument()
150 Key keyId(id.begin(), id.end()); in UpdateDocument()
151 Value valSet(newDocument.begin(), newDocument.end()); in UpdateDocument()
|
| /foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/src/distributedcameramgr/dcameradata/ |
| D | dcamera_source_data_process.cpp | 55 auto buffer = *(buffers.begin()); in FeedStream()
59 for (auto iter = streamProcess_.begin(); iter != streamProcess_.end(); iter++) { in FeedStream()
74 for (auto iter = streamInfos.begin(); iter != streamInfos.end(); iter++) { in ConfigStreams()
90 for (auto iter = streamConfigs.begin(); iter != streamConfigs.end(); iter++) { in ConfigStreams()
114 std::set<int32_t> streamIdSet(streamIds.begin(), streamIds.end()); in ReleaseStreams()
115 auto iter = streamProcess_.begin(); in ReleaseStreams()
128 for (auto iterSet = streamIdSet.begin(); iterSet != streamIdSet.end(); iterSet++) { in ReleaseStreams()
151 std::set<int32_t> streamIds(captureInfo->streamIds_.begin(), captureInfo->streamIds_.end()); in StartCapture()
152 for (auto iterSet = streamIds.begin(); iterSet != streamIds.end(); iterSet++) { in StartCapture()
156 for (auto iter = streamProcess_.begin(); iter != streamProcess_.end(); iter++) { in StartCapture()
[all …]
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/src/ |
| D | distributeddb_nb_schema_upgrade_test.cpp | 81 Value value(stringValue.begin(), stringValue.end());
105 Value value1(stringValue1.begin(), stringValue1.end()); in InsertFieldWithNullValue()
113 Value value2(stringValue2.begin(), stringValue2.end()); in InsertFieldWithNullValue()
121 Value value3(stringValue3.begin(), stringValue3.end()); in InsertFieldWithNullValue()
129 Value value4(stringValue4.begin(), stringValue4.end()); in InsertFieldWithNullValue()
137 Value value5(stringValue5.begin(), stringValue5.end()); in InsertFieldWithNullValue()
145 Value value6(stringValue6.begin(), stringValue6.end()); in InsertFieldWithNullValue()
189 Value value1(stringValue1.begin(), stringValue1.end()); in InsertVoidFieldSteps()
197 Value value2(stringValue2.begin(), stringValue2.end()); in InsertVoidFieldSteps()
205 Value value3(stringValue3.begin(), stringValue3.end()); in InsertVoidFieldSteps()
[all …]
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/metadata/ |
| D | meta_data_manager.cpp | 85 std::string key(entry.key.begin(), entry.key.end()); in OnChange()
89 observer_(key, { entry.value.begin(), entry.value.end() }, action); in OnChange()
130 …auto status = isLocal ? metaStore_->PutLocal({ key.begin(), key.end() }, { data.begin(), data.end(… in SaveMeta()
131 … : metaStore_->Put({ key.begin(), key.end() }, { data.begin(), data.end() }); in SaveMeta()
152 auto status = isLocal ? metaStore_->GetLocal({ key.begin(), key.end() }, data) in LoadMeta()
153 : metaStore_->Get({ key.begin(), key.end() }, data); in LoadMeta()
157 Serializable::Unmarshall({ data.begin(), data.end() }, value); in LoadMeta()
167 auto status = isLocal ? metaStore_->GetLocalEntries({ prefix.begin(), prefix.end() }, dbEntries) in GetEntries()
168 : metaStore_->GetEntries({ prefix.begin(), prefix.end() }, dbEntries); in GetEntries()
188 auto status = isLocal ? metaStore_->DeleteLocal({ key.begin(), key.end() }) in DelMeta()
[all …]
|
| /foundation/resourceschedule/resource_schedule_service/cgroup_sched/framework/sched_controller/ |
| D | supervisor.cpp | 26 auto a = std::find_if(abilities_.begin(), abilities_.end(), [ token ] (const auto& a) { in GetAbilityInfoNonNull()
39 auto a = std::find_if(abilities_.begin(), abilities_.end(), [ token ] (const auto& a) { in GetAbilityInfo()
50 auto w = std::find_if(windows_.begin(), windows_.end(), [ windowId ] (const auto& w) { in GetWindowInfoNonNull()
63 for (auto iter = abilities_.begin(); iter != abilities_.end(); ++iter) { in RemoveAbilityByToken()
73 return std::any_of(abilities_.begin(), abilities_.end(), [ token ] (const auto& abi) { in HasAbility()
80 return std::any_of(abilities_.begin(), abilities_.end(), [] (const auto& abi) { in HasServiceExtension()
89 return std::any_of(windows_.begin(), windows_.end(), [] (const auto& w) { in IsVisible()
138 for (auto iter = pidsMap_.begin(); iter != pidsMap_.end(); iter++) { in FindProcessRecordByToken()
163 for (auto iter = pidsMap_.begin(); iter != pidsMap_.end(); iter++) { in FindProcessRecordByWindowId()
165 if (std::any_of(pr->windows_.begin(), pr->windows_.end(), in FindProcessRecordByWindowId()
[all …]
|
| /foundation/communication/dhcp/test/services/dhcp_server/unittest/ |
| D | common_util_test.cpp | 26 uint64_t begin = Tmspsec(); variable
27 EXPECT_TRUE(begin > 0);
30 EXPECT_TRUE(curr > begin);
31 begin = Tmspusec();
32 EXPECT_TRUE(begin > 0);
|
| /foundation/multimedia/player_framework/services/engine/common/avcodeclist/ |
| D | avcodec_ability_singleton.cpp | 67 capabilityDataArray_.insert(capabilityDataArray_.end(), data.begin(), data.end()); in ParseCodecXml()
75 …capabilityDataArray_.insert(capabilityDataArray_.begin() + hdiCapLen_, registerCapabilityDataArray… in RegisterCapability()
84 capabilityDataArray_.insert(capabilityDataArray_.begin(), registerCapabilityDataArray.begin(), in RegisterHdiCapability()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| D | sqlite_single_ver_continue_token.cpp | 19 SQLiteSingleVerContinueToken::SQLiteSingleVerContinueToken(Timestamp begin, Timestamp end) in SQLiteSingleVerContinueToken() argument
20 : timeRanges_(MulDevTimeRanges{{"", {begin, end}}}) in SQLiteSingleVerContinueToken()
110 return queryObject_.begin()->second; in GetQuery()
122 iter = timeRanges.erase(timeRanges.begin(), iter); in RemovePrevDevAndSetBeginTime()
131 return timeRanges.begin()->second.first; in GetBeginTimestamp()
139 return timeRanges.begin()->second.second; in GetEndTimestamp()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| D | distributeddb_interfaces_nb_delegate_schema_put_test.cpp | 88 Value value(lessData.begin(), lessData.end()); in CheckPutSchemaData()
96 value.assign(typeDiffData.begin(), typeDiffData.end()); in CheckPutSchemaData()
104 value.assign(constrainDiffData.begin(), constrainDiffData.end()); in CheckPutSchemaData()
112 value.assign(invalidJsonData.begin(), invalidJsonData.end()); in CheckPutSchemaData()
127 value.assign(validJsonData.begin(), validJsonData.end()); in CheckPutSchemaData()
141 Value value(invalidData.begin(), invalidData.end()); in CheckPutBatchSchemaData()
147 value.assign(validData.begin(), validData.end()); in CheckPutBatchSchemaData()
161 value.assign(validData.begin(), validData.end()); in CheckPutBatchSchemaData()
222 Value value(moreData.begin(), moreData.end());
230 Value value1(diffData.begin(), diffData.end());
[all …]
|
| /foundation/resourceschedule/ffrt/src/queue/ |
| D | serial_queue.cpp | 36 for (auto it = whenMap_.begin(); it != whenMap_.end(); it++) { in Quit()
37 for (auto itList = it->second.begin(); itList != it->second.end(); itList++) { in Quit()
53 if (upTime == whenMap_.begin()->first) { in PushTask()
65 for (auto it = whenMap_.begin(); it != whenMap_.end();) { in RemoveTask()
66 for (auto itList = it->second.begin(); itList != it->second.end();) { in RemoveTask()
102 auto it = whenMap_.begin(); in Next()
108 auto nextTask = *it->second.begin(); in Next()
|