2 Copyright (C) 2009 Paul Davis
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.
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.
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.
20 #include "boost/lambda/lambda.hpp"
22 #include "ardour/session.h"
23 #include "ardour/dB.h"
24 #include "ardour/meter.h"
27 #include "osc_global_observer.h"
33 using namespace ARDOUR;
34 using namespace ArdourSurface;
36 OSCGlobalObserver::OSCGlobalObserver (Session& s, lo_address a, uint32_t gm, std::bitset<32> fb)
41 addr = lo_address_new (lo_address_get_hostname(a) , lo_address_get_port(a));
45 // connect to all the things we want to send feed back from
52 // Master channel first
53 boost::shared_ptr<Stripable> strip = session->master_out();
55 boost::shared_ptr<Controllable> mute_controllable = boost::dynamic_pointer_cast<Controllable>(strip->mute_control());
56 mute_controllable->Changed.connect (strip_connections, MISSING_INVALIDATOR, bind (&OSCGlobalObserver::send_change_message, this, X_("/master/mute"), strip->mute_control()), OSC::instance());
57 send_change_message ("/master/mute", strip->mute_control());
59 boost::shared_ptr<Controllable> trim_controllable = boost::dynamic_pointer_cast<Controllable>(strip->trim_control());
60 trim_controllable->Changed.connect (strip_connections, MISSING_INVALIDATOR, bind (&OSCGlobalObserver::send_trim_message, this, X_("/master/trimdB"), strip->trim_control()), OSC::instance());
61 send_trim_message ("/master/trimdB", strip->trim_control());
63 boost::shared_ptr<Controllable> pan_controllable = boost::dynamic_pointer_cast<Controllable>(strip->pan_azimuth_control());
64 pan_controllable->Changed.connect (strip_connections, MISSING_INVALIDATOR, bind (&OSCGlobalObserver::send_change_message, this, X_("/master/pan_stereo_position"), strip->pan_azimuth_control()), OSC::instance());
65 send_change_message ("/master/pan_stereo_position", strip->pan_azimuth_control());
67 boost::shared_ptr<Controllable> gain_controllable = boost::dynamic_pointer_cast<Controllable>(strip->gain_control());
69 gain_controllable->Changed.connect (strip_connections, MISSING_INVALIDATOR, bind (&OSCGlobalObserver::send_gain_message, this, X_("/master/fader"), strip->gain_control()), OSC::instance());
70 send_gain_message ("/master/fader", strip->gain_control());
72 gain_controllable->Changed.connect (strip_connections, MISSING_INVALIDATOR, bind (&OSCGlobalObserver::send_gain_message, this, X_("/master/gain"), strip->gain_control()), OSC::instance());
73 send_gain_message ("/master/gain", strip->gain_control());
85 strip = session->monitor_out();
88 // Hmm, it seems the monitor mute is not at route->mute_control()
89 /*boost::shared_ptr<Controllable> mute_controllable2 = boost::dynamic_pointer_cast<Controllable>(strip->mute_control());
90 //mute_controllable = boost::dynamic_pointer_cast<Controllable>(r2->mute_control());
91 mute_controllable2->Changed.connect (monitor_mute_connection, MISSING_INVALIDATOR, bind (&OSCGlobalObserver::send_change_message, this, X_("/monitor/mute"), strip->mute_control()), OSC::instance());
92 send_change_message ("/monitor/mute", strip->mute_control());
94 gain_controllable = boost::dynamic_pointer_cast<Controllable>(strip->gain_control());
96 gain_controllable->Changed.connect (strip_connections, MISSING_INVALIDATOR, bind (&OSCGlobalObserver::send_gain_message, this, X_("/monitor/fader"), strip->gain_control()), OSC::instance());
97 send_gain_message ("/monitor/fader", strip->gain_control());
99 gain_controllable->Changed.connect (strip_connections, MISSING_INVALIDATOR, bind (&OSCGlobalObserver::send_gain_message, this, X_("/monitor/gain"), strip->gain_control()), OSC::instance());
100 send_gain_message ("/monitor/gain", strip->gain_control());
109 session->TransportStateChange.connect(session_connections, MISSING_INVALIDATOR, boost::bind (&OSCGlobalObserver::send_transport_state_changed, this), OSC::instance());
110 send_transport_state_changed ();
111 session->TransportLooped.connect(session_connections, MISSING_INVALIDATOR, boost::bind (&OSCGlobalObserver::send_transport_state_changed, this), OSC::instance());
112 session->RecordStateChanged.connect(session_connections, MISSING_INVALIDATOR, boost::bind (&OSCGlobalObserver::send_record_state_changed, this), OSC::instance());
113 send_record_state_changed ();
116 session->StateSaved.connect(session_connections, MISSING_INVALIDATOR, boost::bind (&OSCGlobalObserver::send_session_saved, this, _1), OSC::instance());
117 send_session_saved (session->snap_name());
118 session->SoloActive.connect(session_connections, MISSING_INVALIDATOR, boost::bind (&OSCGlobalObserver::solo_active, this, _1), OSC::instance());
119 solo_active (session->soloing() || session->listening());
127 OSCGlobalObserver::~OSCGlobalObserver ()
130 strip_connections.drop_connections ();
131 session_connections.drop_connections ();
133 lo_address_free (addr);
137 OSCGlobalObserver::tick ()
139 framepos_t now_frame = session->transport_frame();
140 if (now_frame != _last_frame) {
141 if (feedback[6]) { // timecode enabled
142 Timecode::Time timecode;
143 session->timecode_time (now_frame, timecode);
145 // Timecode mode: Hours/Minutes/Seconds/Frames
147 os << setw(2) << setfill('0') << timecode.hours;
149 os << setw(2) << setfill('0') << timecode.minutes;
151 os << setw(2) << setfill('0') << timecode.seconds;
153 os << setw(2) << setfill('0') << timecode.frames;
155 lo_message msg = lo_message_new ();
156 lo_message_add_string (msg, os.str().c_str());
157 lo_send_message (addr, "/position/smpte", msg);
158 lo_message_free (msg);
160 if (feedback[5]) { // Bar beat enabled
161 Timecode::BBT_Time bbt_time;
163 session->bbt_time (now_frame, bbt_time);
165 // semantics: BBB/bb/tttt
168 os << setw(3) << setfill('0') << bbt_time.bars;
170 os << setw(2) << setfill('0') << bbt_time.beats;
172 os << setw(4) << setfill('0') << bbt_time.ticks;
174 lo_message msg = lo_message_new ();
175 lo_message_add_string (msg, os.str().c_str());
176 lo_send_message (addr, "/position/bbt", msg);
177 lo_message_free (msg);
179 if (feedback[11]) { // minutes/seconds enabled
180 framepos_t left = now_frame;
181 int hrs = (int) floor (left / (session->frame_rate() * 60.0f * 60.0f));
182 left -= (framecnt_t) floor (hrs * session->frame_rate() * 60.0f * 60.0f);
183 int mins = (int) floor (left / (session->frame_rate() * 60.0f));
184 left -= (framecnt_t) floor (mins * session->frame_rate() * 60.0f);
185 int secs = (int) floor (left / (float) session->frame_rate());
186 left -= (framecnt_t) floor ((double)(secs * session->frame_rate()));
187 int millisecs = floor (left * 1000.0 / (float) session->frame_rate());
189 // Min/sec mode: Hours/Minutes/Seconds/msec
191 os << setw(2) << setfill('0') << hrs;
193 os << setw(2) << setfill('0') << mins;
195 os << setw(2) << setfill('0') << secs;
197 os << setw(3) << setfill('0') << millisecs;
199 lo_message msg = lo_message_new ();
200 lo_message_add_string (msg, os.str().c_str());
201 lo_send_message (addr, "/position/time", msg);
202 lo_message_free (msg);
204 if (feedback[10]) { // samples
207 lo_message msg = lo_message_new ();
208 lo_message_add_string (msg, os.str().c_str());
209 lo_send_message (addr, "/position/samples", msg);
210 lo_message_free (msg);
212 _last_frame = now_frame;
214 if (feedback[3]) { //heart beat enabled
215 if (_heartbeat == 10) {
216 lo_message msg = lo_message_new ();
217 lo_message_add_float (msg, 1.0);
218 lo_send_message (addr, "/heartbeat", msg);
219 lo_message_free (msg);
222 lo_message msg = lo_message_new ();
223 lo_message_add_float (msg, 0.0);
224 lo_send_message (addr, "/heartbeat", msg);
225 lo_message_free (msg);
228 if (_heartbeat > 20) _heartbeat = 0;
230 if (feedback[7] || feedback[8] || feedback[9]) { // meters enabled
231 // the only meter here is master
232 float now_meter = session->master_out()->peak_meter()->meter_level(0, MeterMCP);
233 if (now_meter < -193) now_meter = -193;
234 if (_last_meter != now_meter) {
235 if (feedback[7] || feedback[8]) {
236 lo_message msg = lo_message_new ();
237 if (gainmode && feedback[7]) {
238 uint32_t lev1023 = (uint32_t)((now_meter + 54) * 17.05);
239 lo_message_add_int32 (msg, lev1023);
240 lo_send_message (addr, "/master/meter", msg);
241 } else if ((!gainmode) && feedback[7]) {
242 lo_message_add_float (msg, now_meter);
243 lo_send_message (addr, "/master/meter", msg);
244 } else if (feedback[8]) {
245 uint32_t ledlvl = (uint32_t)(((now_meter + 54) / 3.75)-1);
246 uint32_t ledbits = ~(0xfff<<ledlvl);
247 lo_message_add_int32 (msg, ledbits);
248 lo_send_message (addr, "/master/meter", msg);
250 lo_message_free (msg);
253 lo_message msg = lo_message_new ();
255 if (now_meter < -40) {
260 lo_message_add_float (msg, signal);
261 lo_send_message (addr, "/master/signal", msg);
262 lo_message_free (msg);
265 _last_meter = now_meter;
271 OSCGlobalObserver::send_change_message (string path, boost::shared_ptr<Controllable> controllable)
273 lo_message msg = lo_message_new ();
275 lo_message_add_float (msg, (float) controllable->get_value());
278 lo_send_message (addr, path.c_str(), msg);
279 lo_message_free (msg);
283 OSCGlobalObserver::send_gain_message (string path, boost::shared_ptr<Controllable> controllable)
285 lo_message msg = lo_message_new ();
288 if (controllable->get_value() == 1) {
289 lo_message_add_int32 (msg, 800);
291 lo_message_add_int32 (msg, gain_to_slider_position (controllable->get_value()) * 1023);
294 if (controllable->get_value() < 1e-15) {
295 lo_message_add_float (msg, -200);
297 lo_message_add_float (msg, accurate_coefficient_to_dB (controllable->get_value()));
301 lo_send_message (addr, path.c_str(), msg);
302 lo_message_free (msg);
306 OSCGlobalObserver::send_trim_message (string path, boost::shared_ptr<Controllable> controllable)
308 lo_message msg = lo_message_new ();
310 lo_message_add_float (msg, (float) accurate_coefficient_to_dB (controllable->get_value()));
312 lo_send_message (addr, path.c_str(), msg);
313 lo_message_free (msg);
318 OSCGlobalObserver::send_transport_state_changed()
321 lo_message msg = lo_message_new ();
322 lo_message_add_int32 (msg, session->get_play_loop());
323 lo_send_message (addr, "/loop_toggle", msg);
324 lo_message_free (msg);
326 msg = lo_message_new ();
327 lo_message_add_int32 (msg, session->transport_speed() == 1.0);
328 lo_send_message (addr, "/transport_play", msg);
329 lo_message_free (msg);
331 msg = lo_message_new ();
332 lo_message_add_int32 (msg, session->transport_stopped ());
333 lo_send_message (addr, "/transport_stop", msg);
334 lo_message_free (msg);
336 msg = lo_message_new ();
337 lo_message_add_int32 (msg, session->transport_speed() < 0.0);
338 lo_send_message (addr, "/rewind", msg);
339 lo_message_free (msg);
341 msg = lo_message_new ();
342 lo_message_add_int32 (msg, session->transport_speed() > 1.0);
343 lo_send_message (addr, "/ffwd", msg);
344 lo_message_free (msg);
349 OSCGlobalObserver::send_record_state_changed ()
351 lo_message msg = lo_message_new ();
352 lo_message_add_int32 (msg, (int)session->get_record_enabled ());
353 lo_send_message (addr, "/rec_enable_toggle", msg);
354 lo_message_free (msg);
356 msg = lo_message_new ();
357 if (session->have_rec_enabled_track ()) {
358 lo_message_add_int32 (msg, 1);
360 lo_message_add_int32 (msg, 0);
362 lo_send_message (addr, "/record_tally", msg);
363 lo_message_free (msg);
368 OSCGlobalObserver::send_session_saved (std::string name)
370 lo_message msg = lo_message_new ();
371 lo_message_add_string (msg, name.c_str());
372 lo_send_message (addr, "/session_name", msg);
373 lo_message_free (msg);
378 OSCGlobalObserver::solo_active (bool active)
380 lo_message msg = lo_message_new ();
381 lo_message_add_float (msg, (float) active);
382 lo_send_message (addr, "/cancel_all_solos", msg);
383 lo_message_free (msg);