get diskreader working, and remove per-track varispeed API and mechanism
[ardour.git] / libs / ardour / ardour / disk_io.h
1 /*
2     Copyright (C) 2009-2016 Paul Davis
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 2 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, write to the Free Software
16     Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
17
18 */
19
20 #ifndef __ardour_disk_io_h__
21 #define __ardour_disk_io_h__
22
23 #include <vector>
24 #include <string>
25 #include <exception>
26
27 #include "pbd/ringbufferNPT.h"
28 #include "pbd/rcu.h"
29
30 #include "ardour/interpolation.h"
31 #include "ardour/processor.h"
32
33 namespace ARDOUR {
34
35 class AudioFileSource;
36 class AudioPlaylist;
37 class Location;
38 class MidiPlaylist;
39 class Playlist;
40 class Route;
41 class Route;
42 class Session;
43
44 template<typename T> class MidiRingBuffer;
45
46 class LIBARDOUR_API DiskIOProcessor : public Processor
47 {
48   public:
49         enum Flag {
50                 Recordable  = 0x1,
51                 Hidden      = 0x2,
52                 Destructive = 0x4,
53                 NonLayered   = 0x8
54         };
55
56         static const std::string state_node_name;
57
58         DiskIOProcessor (Session&, const std::string& name, Flag f);
59
60         void set_route (boost::shared_ptr<Route>);
61
62         static void set_buffering_parameters (BufferingPreset bp);
63
64         int set_block_size (pframes_t);
65         bool configure_io (ChanCount in, ChanCount out);
66         bool can_support_io_configuration (const ChanCount& in, ChanCount& out);
67
68         /** @return A number between 0 and 1, where 0 indicates that the playback/capture buffer
69          *  is dry (ie the disk subsystem could not keep up) and 1 indicates that the
70          *  buffer is full.
71          */
72         virtual float buffer_load() const = 0;
73
74         void set_flag (Flag f)   { _flags = Flag (_flags | f); }
75         void unset_flag (Flag f) { _flags = Flag (_flags & ~f); }
76
77         bool           hidden()      const { return _flags & Hidden; }
78         bool           recordable()  const { return _flags & Recordable; }
79         bool           non_layered()  const { return _flags & NonLayered; }
80         bool           reversed()    const { return _actual_speed < 0.0f; }
81
82         virtual void non_realtime_locate (framepos_t);
83
84         void non_realtime_set_speed ();
85         bool realtime_set_speed (double sp, bool global);
86
87         virtual void punch_in()  {}
88         virtual void punch_out() {}
89
90         bool slaved() const      { return _slaved; }
91         void set_slaved(bool yn) { _slaved = yn; }
92
93         int set_loop (Location *loc);
94
95         PBD::Signal1<void,Location *> LoopSet;
96         PBD::Signal0<void>            SpeedChanged;
97         PBD::Signal0<void>            ReverseChanged;
98
99         int set_state (const XMLNode&, int version);
100
101         int add_channel (uint32_t how_many);
102         int remove_channel (uint32_t how_many);
103
104         bool need_butler() const { return _need_butler; }
105
106         boost::shared_ptr<Playlist>      get_playlist (DataType dt) const { return _playlists[dt]; }
107         boost::shared_ptr<MidiPlaylist>  midi_playlist() const;
108         boost::shared_ptr<AudioPlaylist> audio_playlist() const;
109
110         virtual void playlist_modified () {}
111         virtual int use_playlist (DataType, boost::shared_ptr<Playlist>);
112
113         PBD::Signal1<void,DataType>   PlaylistChanged;
114
115         virtual void adjust_buffering() = 0;
116
117   protected:
118         friend class Auditioner;
119         virtual int  seek (framepos_t which_sample, bool complete_refill = false) = 0;
120
121   protected:
122         Flag         _flags;
123         uint32_t      i_am_the_modifier;
124         double       _actual_speed;
125         double       _target_speed;
126         /* items needed for speed change logic */
127         bool         _buffer_reallocation_required;
128         bool         _seek_required;
129         bool         _slaved;
130         Location*     loop_location;
131         bool          in_set_state;
132         framepos_t     file_frame;
133         framepos_t     playback_sample;
134         framecnt_t    wrap_buffer_size;
135         framecnt_t    speed_buffer_size;
136         bool         _need_butler;
137         boost::shared_ptr<Route> _route;
138
139         void init ();
140
141         Glib::Threads::Mutex state_lock;
142
143         static bool get_buffering_presets (BufferingPreset bp,
144                                            framecnt_t& read_chunk_size,
145                                            framecnt_t& read_buffer_size,
146                                            framecnt_t& write_chunk_size,
147                                            framecnt_t& write_buffer_size);
148
149         enum TransitionType {
150                 CaptureStart = 0,
151                 CaptureEnd
152         };
153
154         struct CaptureTransition {
155                 TransitionType   type;
156                 framepos_t       capture_val; ///< The start or end file frame position
157         };
158
159         /** Information about one audio channel, playback or capture
160          * (depending on the derived class)
161          */
162         struct ChannelInfo : public boost::noncopyable {
163
164                 ChannelInfo (framecnt_t buffer_size);
165                 ~ChannelInfo ();
166
167                 /** A ringbuffer for data to be played back, written to in the
168                     butler thread, read from in the process thread.
169                 */
170                 PBD::RingBufferNPT<Sample>* buf;
171
172                 Sample* scrub_buffer;
173                 Sample* scrub_forward_buffer;
174                 Sample* scrub_reverse_buffer;
175
176                 PBD::RingBufferNPT<Sample>::rw_vector rw_vector;
177
178                 /* used only by capture */
179                 boost::shared_ptr<AudioFileSource> write_source;
180                 PBD::RingBufferNPT<CaptureTransition> * capture_transition_buf;
181                 // the following are used in the butler thread only
182                 framecnt_t                     curr_capture_cnt;
183
184                 void resize (framecnt_t);
185         };
186
187         typedef std::vector<ChannelInfo*> ChannelList;
188         SerializedRCUManager<ChannelList> channels;
189
190         int add_channel_to (boost::shared_ptr<ChannelList>, uint32_t how_many);
191         int remove_channel_from (boost::shared_ptr<ChannelList>, uint32_t how_many);
192
193         CubicInterpolation interpolation;
194
195         boost::shared_ptr<Playlist> _playlists[DataType::num_types];
196         PBD::ScopedConnectionList playlist_connections;
197
198         virtual void playlist_changed (const PBD::PropertyChange&) {}
199         virtual void playlist_deleted (boost::weak_ptr<Playlist>);
200         virtual void playlist_ranges_moved (std::list< Evoral::RangeMove<framepos_t> > const &, bool) {}
201
202         /* The MIDI stuff */
203
204         MidiRingBuffer<framepos_t>*  _midi_buf;
205         gint                         _frames_written_to_ringbuffer;
206         gint                         _frames_read_from_ringbuffer;
207         CubicMidiInterpolation        midi_interpolation;
208
209         static void get_location_times (const Location* location, framepos_t* start, framepos_t* end, framepos_t* length);
210 };
211
212 } // namespace ARDOUR
213
214 #endif /* __ardour_disk_io_h__ */