106f6ba60Sopenharmony_ci/* 206f6ba60Sopenharmony_ci * Copyright (c) Huawei Technologies Co., Ltd. 2023. All rights reserved. 306f6ba60Sopenharmony_ci * Licensed under the Apache License, Version 2.0 (the "License"); 406f6ba60Sopenharmony_ci * you may not use this file except in compliance with the License. 506f6ba60Sopenharmony_ci * You may obtain a copy of the License at 606f6ba60Sopenharmony_ci * 706f6ba60Sopenharmony_ci * http://www.apache.org/licenses/LICENSE-2.0 806f6ba60Sopenharmony_ci * 906f6ba60Sopenharmony_ci * Unless required by applicable law or agreed to in writing, software 1006f6ba60Sopenharmony_ci * distributed under the License is distributed on an "AS IS" BASIS, 1106f6ba60Sopenharmony_ci * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 1206f6ba60Sopenharmony_ci * See the License for the specific language governing permissions and 1306f6ba60Sopenharmony_ci * limitations under the License. 1406f6ba60Sopenharmony_ci */ 1506f6ba60Sopenharmony_ci 1606f6ba60Sopenharmony_ci#include "sampling.h" 1706f6ba60Sopenharmony_ci 1806f6ba60Sopenharmony_civoid Sampling::Reset() 1906f6ba60Sopenharmony_ci{ 2006f6ba60Sopenharmony_ci sampleInterval_ = 0; 2106f6ba60Sopenharmony_ci sampleRate_ = 0; 2206f6ba60Sopenharmony_ci nextSampleInterval_ = 0; 2306f6ba60Sopenharmony_ci exponentialDist_.reset(); 2406f6ba60Sopenharmony_ci} 2506f6ba60Sopenharmony_ci 2606f6ba60Sopenharmony_civoid Sampling::InitSampling(uint64_t sampleInterval) 2706f6ba60Sopenharmony_ci{ 2806f6ba60Sopenharmony_ci sampleInterval_ = sampleInterval; 2906f6ba60Sopenharmony_ci sampleRate_ = 1.0 / static_cast<double>(sampleInterval_); 3006f6ba60Sopenharmony_ci exponentialDist_ = std::exponential_distribution<double>(sampleRate_); 3106f6ba60Sopenharmony_ci nextSampleInterval_ = CalcNextSampleInterval(); 3206f6ba60Sopenharmony_ci} 3306f6ba60Sopenharmony_ci 3406f6ba60Sopenharmony_cisize_t Sampling::CalcSamplings(size_t allocSize) 3506f6ba60Sopenharmony_ci{ 3606f6ba60Sopenharmony_ci size_t counts = 0; 3706f6ba60Sopenharmony_ci { 3806f6ba60Sopenharmony_ci Spinlock s; 3906f6ba60Sopenharmony_ci for (nextSampleInterval_ -= static_cast<int64_t>(allocSize); nextSampleInterval_ <= 0; 4006f6ba60Sopenharmony_ci nextSampleInterval_ += CalcNextSampleInterval()) { 4106f6ba60Sopenharmony_ci ++counts; 4206f6ba60Sopenharmony_ci } 4306f6ba60Sopenharmony_ci } 4406f6ba60Sopenharmony_ci return counts; 4506f6ba60Sopenharmony_ci}