Line data Source code
1 : /*
2 : * If not stated otherwise in this file or this component's LICENSE file the
3 : * following copyright and licenses apply:
4 : *
5 : * Copyright 2025 Sky UK
6 : *
7 : * Licensed under the Apache License, Version 2.0 (the "License");
8 : * you may not use this file except in compliance with the License.
9 : * You may obtain a copy of the License at
10 : *
11 : * http://www.apache.org/licenses/LICENSE-2.0
12 : *
13 : * Unless required by applicable law or agreed to in writing, software
14 : * distributed under the License is distributed on an "AS IS" BASIS,
15 : * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 : * See the License for the specific language governing permissions and
17 : * limitations under the License.
18 : */
19 :
20 : #ifndef FIREBOLT_RIALTO_SERVER_FLUSH_WATCHER_H_
21 : #define FIREBOLT_RIALTO_SERVER_FLUSH_WATCHER_H_
22 :
23 : #include "IFlushWatcher.h"
24 : #include <mutex>
25 : #include <set>
26 :
27 : namespace firebolt::rialto::server
28 : {
29 : class FlushWatcher : public IFlushWatcher
30 : {
31 : public:
32 2 : FlushWatcher() = default;
33 3 : ~FlushWatcher() override = default;
34 :
35 : void setFlushing(const MediaSourceType &type) override;
36 : void setFlushed(const MediaSourceType &type) override;
37 : bool isFlushOngoing() const override;
38 :
39 : private:
40 : mutable std::mutex m_mutex;
41 : std::set<MediaSourceType> m_flushingSources;
42 : };
43 : } // namespace firebolt::rialto::server
44 : #endif // FIREBOLT_RIALTO_SERVER_FLUSH_WATCHER_H_
|