Line data Source code
1 : /*
2 : * Copyright (C) 2004-2026 Savoir-faire Linux Inc.
3 : *
4 : * This program is free software: you can redistribute it and/or modify
5 : * it under the terms of the GNU General Public License as published by
6 : * the Free Software Foundation, either version 3 of the License, or
7 : * (at your option) any later version.
8 : *
9 : * This program is distributed in the hope that it will be useful,
10 : * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 : * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 : * GNU General Public License for more details.
13 : *
14 : * You should have received a copy of the GNU General Public License
15 : * along with this program. If not, see <https://www.gnu.org/licenses/>.
16 : */
17 :
18 : #include "localrecordermanager.h"
19 :
20 : namespace jami {
21 :
22 : LocalRecorderManager&
23 0 : LocalRecorderManager::instance()
24 : {
25 0 : static LocalRecorderManager instance;
26 0 : return instance;
27 : }
28 :
29 : void
30 0 : LocalRecorderManager::removeRecorderByPath(const std::string& path)
31 : {
32 0 : std::lock_guard lock(recorderMapMutex_);
33 0 : recorderMap_.erase(path);
34 0 : }
35 :
36 : void
37 0 : LocalRecorderManager::insertRecorder(const std::string& path, std::unique_ptr<LocalRecorder> rec)
38 : {
39 0 : if (!rec) {
40 0 : throw std::invalid_argument("Unable to insert null recorder");
41 : }
42 :
43 0 : std::lock_guard lock(recorderMapMutex_);
44 0 : auto ret = recorderMap_.emplace(path, std::move(rec));
45 :
46 0 : if (!ret.second) {
47 0 : throw std::invalid_argument("Unable to insert recorder (passed path is already used as key)");
48 : }
49 0 : }
50 :
51 : LocalRecorder*
52 0 : LocalRecorderManager::getRecorderByPath(const std::string& path)
53 : {
54 0 : auto rec = recorderMap_.find(path);
55 0 : return (rec == recorderMap_.end()) ? nullptr : rec->second.get();
56 : }
57 :
58 : bool
59 0 : LocalRecorderManager::hasRunningRecorders()
60 : {
61 0 : for (auto it = recorderMap_.begin(); it != recorderMap_.end(); ++it) {
62 0 : if (it->second->isRecording())
63 0 : return true;
64 : }
65 :
66 0 : return false;
67 : }
68 :
69 : } // namespace jami
|