14514f5e3Sopenharmony_ci/*
24514f5e3Sopenharmony_ci * Copyright (c) 2024 Huawei Device Co., Ltd.
34514f5e3Sopenharmony_ci * Licensed under the Apache License, Version 2.0 (the "License");
44514f5e3Sopenharmony_ci * you may not use this file except in compliance with the License.
54514f5e3Sopenharmony_ci * You may obtain a copy of the License at
64514f5e3Sopenharmony_ci *
74514f5e3Sopenharmony_ci *     http://www.apache.org/licenses/LICENSE-2.0
84514f5e3Sopenharmony_ci *
94514f5e3Sopenharmony_ci * Unless required by applicable law or agreed to in writing, software
104514f5e3Sopenharmony_ci * distributed under the License is distributed on an "AS IS" BASIS,
114514f5e3Sopenharmony_ci * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
124514f5e3Sopenharmony_ci * See the License for the specific language governing permissions and
134514f5e3Sopenharmony_ci * limitations under the License.
144514f5e3Sopenharmony_ci */
154514f5e3Sopenharmony_ci
164514f5e3Sopenharmony_ci#include "ecmascript/mem/mem_controller_utils.h"
174514f5e3Sopenharmony_ci
184514f5e3Sopenharmony_ci#include "ecmascript/mem/mem_common.h"
194514f5e3Sopenharmony_ci
204514f5e3Sopenharmony_cinamespace panda::ecmascript {
214514f5e3Sopenharmony_ci
224514f5e3Sopenharmony_cidouble MemControllerUtils::CalculateAverageSpeed(const base::GCRingBuffer<BytesAndDuration, LENGTH> &buffer)
234514f5e3Sopenharmony_ci{
244514f5e3Sopenharmony_ci    return CalculateAverageSpeed(buffer, MakeBytesAndDuration(0, 0), 0);
254514f5e3Sopenharmony_ci}
264514f5e3Sopenharmony_ci
274514f5e3Sopenharmony_cidouble MemControllerUtils::CalculateAverageSpeed(const base::GCRingBuffer<BytesAndDuration, LENGTH> &buffer,
284514f5e3Sopenharmony_ci    const BytesAndDuration &initial, const double timeMs)
294514f5e3Sopenharmony_ci{
304514f5e3Sopenharmony_ci    BytesAndDuration sum = buffer.Sum(
314514f5e3Sopenharmony_ci        [timeMs](BytesAndDuration a, BytesAndDuration b) {
324514f5e3Sopenharmony_ci            if (timeMs != 0 && a.second >= timeMs) {
334514f5e3Sopenharmony_ci                return a;
344514f5e3Sopenharmony_ci            }
354514f5e3Sopenharmony_ci            return std::make_pair(a.first + b.first, a.second + b.second);
364514f5e3Sopenharmony_ci        },
374514f5e3Sopenharmony_ci        initial);
384514f5e3Sopenharmony_ci    uint64_t bytes = sum.first;
394514f5e3Sopenharmony_ci    double durations = sum.second;
404514f5e3Sopenharmony_ci    if (fabs(durations) <= 1e-6) {
414514f5e3Sopenharmony_ci        return 0;
424514f5e3Sopenharmony_ci    }
434514f5e3Sopenharmony_ci    double speed = bytes / durations;
444514f5e3Sopenharmony_ci    const int maxSpeed = static_cast<int>(1_GB);
454514f5e3Sopenharmony_ci    const int minSpeed = 1;
464514f5e3Sopenharmony_ci    if (speed >= maxSpeed) {
474514f5e3Sopenharmony_ci        return maxSpeed;
484514f5e3Sopenharmony_ci    }
494514f5e3Sopenharmony_ci    if (speed <= minSpeed) {
504514f5e3Sopenharmony_ci        return minSpeed;
514514f5e3Sopenharmony_ci    }
524514f5e3Sopenharmony_ci    return speed;
534514f5e3Sopenharmony_ci}
544514f5e3Sopenharmony_ci
554514f5e3Sopenharmony_ci}