1/*
2 * Copyright (c) 2023 Huawei Device Co., Ltd.
3 * Licensed under the Apache License, Version 2.0 (the "License");
4 * you may not use this file except in compliance with the License.
5 * You may obtain a copy of the License at
6 *
7 *     http://www.apache.org/licenses/LICENSE-2.0
8 *
9 * Unless required by applicable law or agreed to in writing, software
10 * distributed under the License is distributed on an "AS IS" BASIS,
11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 * See the License for the specific language governing permissions and
13 * limitations under the License.
14 */
15
16#include "sched/frame_interval.h"
17#include "dfx/log/ffrt_log_api.h"
18#include "sched/workgroup_internal.h"
19#include "util/ffrt_facade.h"
20
21#define GET_TID() syscall(SYS_gettid)
22
23namespace ffrt {
24FrameInterval::FrameInterval(uint64_t deadline, const QoS& qos) : Interval(deadline, qos), qos(qos)
25{
26    wg = nullptr;
27    isBegun = false;
28    wg = WorkgroupCreate(deadline);
29    if (wg == nullptr) {
30        FFRT_LOGE("[WorkGroup][Interface] Create WorkGroup Failed");
31    } else {
32        FFRTFacade::GetEUInstance().BindWG(DevType::CPU, this->qos);
33    }
34}
35
36FrameInterval::~FrameInterval()
37{
38    if (wg == nullptr) {
39        FFRT_LOGE("[Error] WorkGroup is nullptr");
40    } else {
41        WorkgroupClear(wg);
42    }
43}
44
45void FrameInterval::OnQoSIntervals(IntervalState state)
46{
47    if (wg == nullptr) {
48        FFRT_LOGE("[Error] Interval's workgroup is null in %s", __func__);
49        return;
50    }
51    if (state == IntervalState::DEADLINE_BEGIN) {
52        WorkgroupStartInterval(wg);
53    } else if (state == IntervalState::DEADLINE_END) {
54        WorkgroupStopInterval(wg);
55    }
56}
57
58int FrameInterval::Begin()
59{
60    if (isBegun) {
61        FFRT_LOGD("[Error] Interval is already begun");
62        return -1;
63    }
64    isBegun = true;
65    OnQoSIntervals(ffrt::IntervalState::DEADLINE_BEGIN);
66
67    return 0;
68}
69
70void FrameInterval::End()
71{
72    if (!isBegun) {
73        FFRT_LOGD("[Error] Interval is already end");
74        return;
75    }
76    isBegun = false;
77    OnQoSIntervals(ffrt::IntervalState::DEADLINE_END);
78}
79
80void FrameInterval::Join()
81{
82    if (wg == nullptr) {
83        FFRT_LOGD("[Error] Interval has no workgroup");
84        return;
85    }
86    int tid = GET_TID();
87    WorkgroupJoin(wg, tid);
88}
89}
90