Add Content::set_paths().
[dcpomatic.git] / src / lib / audio_ring_buffers.cc
1 /*
2     Copyright (C) 2016-2017 Carl Hetherington <cth@carlh.net>
3
4     This file is part of DCP-o-matic.
5
6     DCP-o-matic is free software; you can redistribute it and/or modify
7     it under the terms of the GNU General Public License as published by
8     the Free Software Foundation; either version 2 of the License, or
9     (at your option) any later version.
10
11     DCP-o-matic is distributed in the hope that it will be useful,
12     but WITHOUT ANY WARRANTY; without even the implied warranty of
13     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14     GNU General Public License for more details.
15
16     You should have received a copy of the GNU General Public License
17     along with DCP-o-matic.  If not, see <http://www.gnu.org/licenses/>.
18
19 */
20
21 #include "audio_ring_buffers.h"
22 #include "dcpomatic_assert.h"
23 #include "exceptions.h"
24 #include <boost/foreach.hpp>
25
26 using std::min;
27 using std::cout;
28 using boost::shared_ptr;
29
30 AudioRingBuffers::AudioRingBuffers ()
31         : _used_in_head (0)
32 {
33
34 }
35
36 void
37 AudioRingBuffers::put (shared_ptr<const AudioBuffers> data)
38 {
39         boost::mutex::scoped_lock lm (_mutex);
40
41         if (!_buffers.empty ()) {
42                 DCPOMATIC_ASSERT (_buffers.front()->channels() == data->channels());
43         }
44
45         _buffers.push_back (data);
46 }
47
48 void
49 AudioRingBuffers::get (float* out, int channels, int frames)
50 {
51         boost::mutex::scoped_lock lm (_mutex);
52
53         while (frames > 0) {
54                 if (_buffers.empty ()) {
55                         for (int i = 0; i < frames; ++i) {
56                                 for (int j = 0; j < channels; ++j) {
57                                         *out++ = 0;
58                                 }
59                         }
60                         cout << "audio underrun; missing " << frames << "!\n";
61                         return;
62                 }
63
64                 shared_ptr<const AudioBuffers> front = _buffers.front ();
65
66                 int const to_do = min (frames, front->frames() - _used_in_head);
67                 float** p = front->data();
68                 int const c = min (front->channels(), channels);
69                 for (int i = 0; i < to_do; ++i) {
70                         for (int j = 0; j < c; ++j) {
71                                 *out++ = p[j][i + _used_in_head];
72                         }
73                         for (int j = c; j < channels; ++j) {
74                                 *out++ = 0;
75                         }
76                 }
77                 _used_in_head += to_do;
78                 frames -= to_do;
79
80                 if (_used_in_head == front->frames()) {
81                         _buffers.pop_front ();
82                         _used_in_head = 0;
83                 }
84         }
85 }
86
87 void
88 AudioRingBuffers::clear ()
89 {
90         boost::mutex::scoped_lock lm (_mutex);
91         _buffers.clear ();
92         _used_in_head = 0;
93 }
94
95 Frame
96 AudioRingBuffers::size () const
97 {
98         boost::mutex::scoped_lock lm (_mutex);
99         Frame s = 0;
100         BOOST_FOREACH (shared_ptr<const AudioBuffers> i, _buffers) {
101                 s += i->frames ();
102         }
103         return s - _used_in_head;
104 }