/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/src/ |
H A D | distributeddb_nb_crud_power_test.cpp | 92 for (int cnt = 0; cnt < 5; cnt++) { // the loop times are 5. in RepeatExeCrud() 97 for (int cnt = 0; cnt < 5; cnt++) { // the loop times are 5. in RepeatExeCrud() 101 for (int cnt = 0; cnt < 2; cnt++) { // the loop times are 2. in RepeatExeCrud() 105 for (int cnt in RepeatExeCrud() [all...] |
/foundation/arkui/ace_engine/frameworks/core/components_ng/pattern/list/ |
H A D | list_lanes_layout_algorithm.cpp | 118 int32_t cnt = 0; in LayoutALineForward() local 136 if (isGroup && cnt > 0) { in LayoutALineForward() 141 cnt++; in LayoutALineForward() 151 if (cnt > 0) { in LayoutALineForward() 153 for (int32_t i = 0; i < cnt; i++) { in LayoutALineForward() 160 return cnt; in LayoutALineForward() 168 int32_t cnt = 0; in LayoutALineBackward() local 190 if (isGroup && cnt > 0) { in LayoutALineBackward() 196 cnt++; in LayoutALineBackward() 208 if (cnt > in LayoutALineBackward() 454 int32_t cnt = 0; LayoutCachedALineForward() local 502 int32_t cnt = 0; LayoutCachedALineBackward() local 576 int32_t cnt = 0; LayoutCachedForward() local 628 int32_t cnt = 0; LayoutCachedBackward() local [all...] |
/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/ |
H A D | util.rs | 34 let mut cnt = 1; in seed() variables 38 hasher.write_usize(cnt); in seed() 43 cnt += 1; in seed()
|
/foundation/arkui/ace_engine/frameworks/core/gestures/ |
H A D | velocity_tracker.cpp | 38 for (int32_t cnt = VelocityTracker::POINT_NUMBER; i > 0 && cnt > 0; --cnt) { in CheckExtremePoint() 40 LOGI("Last tracker points[%{public}d] x=%{public}f y=%{public}f", cnt, x[i], y[i]); in CheckExtremePoint() 209 for (int32_t cnt = VelocityTracker::POINT_NUMBER; i > 0 && cnt > 0; --cnt) { in DumpVelocityPoints() 211 LOGI("%{public}s last tracker points[%{public}d] x=%{public}f y=%{public}f", str, cnt, xVal[i], yVal[i]); in DumpVelocityPoints()
|
/foundation/multimedia/media_foundation/engine/pipeline/filters/codec/ |
H A D | codec_mode.cpp | 89 for (size_t cnt = 0; cnt < bufferCnt; cnt++) { in CreateOutBufferPool() 92 MEDIA_LOG_I("Alloc buffer " PUBLIC_LOG_U32 " failed.", static_cast<uint32_t>(cnt)); in CreateOutBufferPool()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/common/distributeddb/src/ |
H A D | distributeddb_schema_test_tools.cpp | 159 for (int cnt = startPoint; cnt < (startPoint + recordNo); cnt++) { in GenerateCombineSchemaEntries() 161 std::string keyNo = std::to_string(cnt); in GenerateCombineSchemaEntries() 213 int cnt = 0; in CombinationCheckQueryResult() local 214 result = (delegate.GetCount(query, cnt) == status) && result; in CombinationCheckQueryResult() 215 result = (cnt == expectCnt) && result; in CombinationCheckQueryResult() 268 for (int cnt = 0; cnt < beginNum + endNum; cnt in GenerateRandQuery() [all...] |
H A D | distributeddb_data_generator.cpp | 126 for (unsigned int cnt = start; cnt < start + recordNum; ++cnt) { in GenerateRecords() 127 GenerateRecord(cnt, entryCurrent, keyPrifix); in GenerateRecords() 157 for (unsigned int cnt = start; cnt < start + recordNum; ++cnt) { in GenerateMaxBigRecords() 158 GenerateMaxBigRecord(cnt, entryCurrent, K_SEARCH_3, (cnt - start)); in GenerateMaxBigRecords() 170 for (unsigned int cnt in GenerateTenThousandRecords() [all...] |
H A D | distributeddb_nb_test_tools.cpp | 289 for (int cnt = 0; cnt < static_cast<int>(entries.size()); cnt += 128) { // 128 is the max records of deleteBatch. in PutBatch() 290 auto last = std::min(static_cast<int>(entries.size()), cnt + 128); // 128 is the max records of deleteBatch. in PutBatch() 291 std::vector<DistributedDB::Entry> entriesBatch(entries.begin() + cnt, entries.begin() + last); in PutBatch() 328 for (int cnt = 0; cnt < static_cast<int>(keys.size()); cnt = cnt + 128) { // 128 is the max records of deleteBatch. in DeleteBatch() 329 auto last = std::min(static_cast<int>(keys.size()), cnt in DeleteBatch() 381 int cnt = 0; PutLocalBatch() local 418 int cnt = 0; DeleteLocalBatch() local [all...] |
/foundation/communication/bluetooth_service/services/bluetooth/service/src/obex/ |
H A D | obex_session.cpp | 215 int cnt = bodyReader_->Read(buf.get(), remainLength); in SetBodyToHeader() local 216 if (cnt < 0) { in SetBodyToHeader() 219 if (cnt < remainLength) { in SetBodyToHeader() 223 OBEX_LOG_DEBUG("GetNextReqHeader Add End-Body count %{public}d", cnt); in SetBodyToHeader() 225 header.AppendItemEndBody(buf.get(), cnt); in SetBodyToHeader() 227 OBEX_LOG_DEBUG("GetNextReqHeader Add Body count %{public}d", cnt); in SetBodyToHeader() 229 header.AppendItemBody(buf.get(), cnt); in SetBodyToHeader() 543 int cnt = bodyReader_->Read(buf.get(), remainLength); in SetBodyToHeader() local 544 if (cnt < 0) { in SetBodyToHeader() 547 if (cnt < remainLengt in SetBodyToHeader() [all...] |
/foundation/bundlemanager/app_domain_verify/frameworks/verifier/src/ |
H A D | verify_task.cpp | 89 staHandlerMap[STATE_SUCCESS] = [this](std::string time, int cnt)->bool { in VerifyTask() 90 return HandleStateSuccess(time, cnt); in VerifyTask() 92 staHandlerMap[FAILURE_CLIENT_ERROR] = [this](std::string time, int cnt)->bool { in VerifyTask() 93 return HandleFailureClientError(time, cnt); in VerifyTask() 95 staHandlerMap[FORBIDDEN_FOREVER] = [this](std::string time, int cnt)->bool { in VerifyTask() 96 return HandleForbiddenForever(time, cnt); in VerifyTask() 197 std::get<2>(iter->second) = verifyCnt; // 2 is cnt in UpdateVerifyResultInfo()
|
/foundation/communication/dsoftbus/sdk/frame/standard/src/ |
H A D | softbus_server_proxy_frame.cpp | 186 int32_t cnt = 0; in ClientDeathProcTask() local 187 for (cnt = 0; cnt < CYCLE_NUMBER_MAX; cnt++) { in ClientDeathProcTask() 193 if (cnt == CYCLE_NUMBER_MAX) { in ClientDeathProcTask() 194 COMM_LOGE(COMM_SDK, "server proxy init reached the maximum count=%{public}d", cnt); in ClientDeathProcTask()
|
/foundation/communication/dsoftbus/sdk/frame/small/src/ |
H A D | softbus_client_stub.c | 135 int32_t cnt = 0; in DeathProcTask() local 136 for (cnt = 0; cnt < CYCLE_NUM_MAX; cnt++) { in DeathProcTask() 145 if (cnt == CYCLE_NUM_MAX) { in DeathProcTask() 146 COMM_LOGE(COMM_SDK, "server proxy init reached the maximum count=%{public}d", cnt); in DeathProcTask()
|
/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/src/ |
H A D | lf_ring.c | 277 FILLP_INT cnt; in FillpRingFreeEntries() local 288 cnt = (int)remain; in FillpRingFreeEntries() 289 if (cnt < 0) { in FillpRingFreeEntries() 290 FILLP_LOGERR("cnt is %d, real size:%lu", cnt, remain); in FillpRingFreeEntries() 291 cnt = 0; in FillpRingFreeEntries() 294 return cnt; in FillpRingFreeEntries()
|
/foundation/communication/bluetooth_service/services/bluetooth/stack/src/rfcomm/ |
H A D | rfcomm.c | 29 for (uint8_t cnt = 0; cnt < MAX_SERVER_COUNT; cnt++) { in RfcommInitialize() 30 g_serverNum[cnt] = false; in RfcommInitialize() 54 for (uint8_t cnt = 0; cnt < MAX_SERVER_COUNT; cnt++) { in RfcommFinalize() 55 g_serverNum[cnt] = false; in RfcommFinalize()
|
/foundation/communication/dsoftbus/core/transmission/trans_channel/manager/src/ |
H A D | trans_auth_negotiation.c | 36 uint32_t cnt; member 80 item->cnt = 0; in TransAddAuthReqToPendingList() 91 g_reqAuthPendingList->cnt++; in TransAddAuthReqToPendingList() 110 g_reqAuthPendingList->cnt--; in TransDelAuthReqFromPendingList() 142 static int32_t TransCheckAuthNegoStatusByReqId(uint32_t authRequestId, bool *isFinished, int32_t *errCode, int32_t *cnt) in TransCheckAuthNegoStatusByReqId() argument 154 *cnt = ++item->cnt; in TransCheckAuthNegoStatusByReqId() 345 int32_t cnt = 0; in TransAuthNegoTaskManager() local 346 int32_t ret = TransCheckAuthNegoStatusByReqId(authRequestId, &isFinished, &errCode, &cnt); in TransAuthNegoTaskManager() 354 if (cnt > in TransAuthNegoTaskManager() [all...] |
/foundation/filemanagement/storage_service/services/storage_daemon/mtpfs/src/ |
H A D | mtpfs_tmp_files_pool.cpp | 47 static int cnt = 0; in MakeTmpPath() local 49 ss << pathDevice << ++cnt; in MakeTmpPath() local
|
/foundation/graphic/graphic_3d/lume/LumeEngine/ecshelper/PropertyTools/ |
H A D | property_value.h | 45 explicit constexpr PropertyValue(const Property* type, void* rawData, size_t cnt) noexcept 46 : type_(type), count_(cnt), data_(rawData), index_(0U) 159 explicit constexpr PropertyValue(const Property* type, void* rawData, size_t cnt, size_t index) in PropertyValue() argument 160 : type_(type), count_(cnt), data_(rawData), index_(index) in PropertyValue()
|
/foundation/graphic/graphic_2d/rosen/modules/render_service_client/test/ |
H A D | render_service_client_gesture_interrupt_animation_demo.cpp | 129 int cnt = 0; in main() local 154 std::cout << "rs app demo stage " << cnt++ << std::endl; in main() 166 std::cout << "rs app demo stage " << cnt++ << std::endl; in main() 189 std::cout << "rs app demo stage " << cnt++ << std::endl; in main() 251 std::cout << "rs app demo stage " << cnt++ << std::endl; in main()
|
/foundation/multimedia/media_foundation/engine/plugin/plugins/codec_adapter/ |
H A D | codec_utils.cpp | 134 for (size_t cnt = 0; cnt < mapSize; cnt++) { in TranslatesByMap() 135 if (t == transMap[cnt].first) { in TranslatesByMap() 136 u = transMap[cnt].second; in TranslatesByMap()
|
/foundation/communication/dsoftbus/core/bus_center/lnn/net_ledger/distributed_ledger/src/ |
H A D | lnn_meta_node_ledger.c | 100 if (g_metaNodeList->cnt >= MAX_META_NODE_NUM) { in LnnActiveMetaNode() 113 g_metaNodeList->cnt++; in LnnActiveMetaNode() 150 g_metaNodeList->cnt--; in LnnDeactiveMetaNode() 177 if (*infoNum < (int32_t)g_metaNodeList->cnt) { in LnnGetAllMetaNodeInfo() 281 g_metaNodeList->cnt--; in LnnDeinitMetaNodeLedger()
|
/foundation/communication/dsoftbus/core/connection/manager/ |
H A D | softbus_conn_manager.c | 84 int32_t cnt = 0; in GetAllListener() local 88 return cnt; in GetAllListener() 96 if (g_listenerList->cnt == 0) { in GetAllListener() 97 CONN_LOGE(CONN_COMMON, "listener cnt is null"); in GetAllListener() 99 return cnt; in GetAllListener() 102 *node = SoftBusCalloc(g_listenerList->cnt * sizeof(ConnListenerNode)); in GetAllListener() 106 return cnt; in GetAllListener() 109 if (memcpy_s(*node + cnt, sizeof(ConnListenerNode), listenerNode, sizeof(ConnListenerNode)) != EOK) { in GetAllListener() 113 cnt++; in GetAllListener() 116 return cnt; in GetAllListener() [all...] |
/foundation/communication/dsoftbus/core/common/dfx/statistics/ |
H A D | trans_network_statistics.c | 66 if ((int32_t)g_channelDfxInfoList->cnt >= MAX_CHANNEL_INFO_NUM) { in AddChannelStatisticsInfo() 89 g_channelDfxInfoList->cnt++; in AddChannelStatisticsInfo() 107 if ((int32_t)g_networkResourceList->cnt >= MAX_NETWORK_RESOURCE_NUM) { in AddNetworkResource() 137 g_networkResourceList->cnt++; in AddNetworkResource() 188 g_channelDfxInfoList->cnt--; in RemoveChannelDfxInfo() 356 g_networkResourceList->cnt--; in DeleteNetworkResourceByLaneId() 413 g_networkResourceList->cnt = 0; in TransNetworkResourceDeinit() 436 g_channelDfxInfoList->cnt = 0; in TransChannelStatisticsDeinit()
|
/foundation/bundlemanager/app_domain_verify/interfaces/inner_api/common/src/ |
H A D | bundle_verify_status_info.cpp | 28 auto [status, verifyTime, cnt] = it.second; in Marshalling() 32 WRITE_PARCEL_AND_RETURN_FALSE_IF_FAIL(Int32, parcel, cnt); in Marshalling() 107 auto [status, verifyTime, cnt] = it.second; in WriteHostVerifyStatusMap() 110 WRITE_PARCEL_AND_RETURN_FALSE_IF_FAIL(Int32, parcel, cnt); in WriteHostVerifyStatusMap()
|
/foundation/communication/dsoftbus/core/bus_center/lnn/lane_hub/lane_manager/src/ |
H A D | lnn_lane_model.c | 225 uint32_t cnt = 0; in GetLaneIdList() local 228 (*laneIdList)[cnt] = infoNode->laneId; in GetLaneIdList() 229 cnt++; in GetLaneIdList() 231 *listSize = cnt; in GetLaneIdList()
|
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/statistics/src/ |
H A D | client_trans_statistics.c | 72 if ((int32_t)g_channelStatisticsList->cnt >= MAX_SOCKET_RESOURCE_NUM) { in AddSocketResource() 104 g_channelStatisticsList->cnt++; in AddSocketResource() 209 g_channelStatisticsList->cnt--; in DeleteSocketResourceByChannelId() 247 g_channelStatisticsList->cnt = 0; in ClientTransStatisticsDeinit()
|