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}