2 * Copyright (C) 2006 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., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
31 #include <glibmm/miscutils.h>
33 #include <pbd/pthread_utils.h>
35 #include <ardour/osc.h>
36 #include <ardour/session.h>
37 #include <ardour/route.h>
38 #include <ardour/audio_track.h>
39 #include <ardour/dB.h>
43 using namespace ARDOUR
;
47 static void error_callback(int num
, const char *m
, const char *path
)
50 fprintf(stderr
, "liblo server error %d in path %s: %s\n", num
, path
, m
);
54 OSC::OSC (uint32_t port
)
73 for (int j
=0; j
< 20; ++j
) {
74 snprintf(tmpstr
, sizeof(tmpstr
), "%d", _port
);
76 if ((_osc_server
= lo_server_new (tmpstr
, error_callback
))) {
80 cerr
<< "can't get osc at port: " << _port
<< endl
;
86 #ifdef ARDOUR_OSC_UNIX_SERVER
88 // APPEARS sluggish for now
90 // attempt to create unix socket server too
92 snprintf(tmpstr
, sizeof(tmpstr
), "/tmp/sooperlooper_XXXXXX");
93 int fd
= mkstemp(tmpstr
);
99 _osc_unix_server
= lo_server_new (tmpstr
, error_callback
);
101 if (_osc_unix_server
) {
102 _osc_unix_socket_path
= tmpstr
;
107 cerr
<< "OSC @ " << get_server_url () << endl
;
109 _osc_url_file
= Glib::build_filename (get_user_ardour_path (), "osc_url");
112 urlfile
.open(_osc_url_file
.c_str(),ios::trunc
);
115 urlfile
<< get_server_url () << endl
;
118 cerr
<< "Couldn't write '" << _osc_url_file
<< "'" <<endl
;
121 register_callbacks();
123 // lo_server_thread_add_method(_sthread, NULL, NULL, OSC::_dummy_handler, this);
125 if (!init_osc_thread()) {
134 if (_osc_server
== 0) {
135 /* already stopped */
139 // stop server thread
140 terminate_osc_thread();
142 lo_server_free (_osc_server
);
145 if (!_osc_unix_socket_path
.empty()) {
147 unlink(_osc_unix_socket_path
.c_str());
150 if (! _osc_url_file
.empty() ) {
151 unlink(_osc_url_file
.c_str() );
162 OSC::register_callbacks()
167 srvs
[0] = _osc_server
;
168 srvs
[1] = _osc_unix_server
;
170 for (size_t i
= 0; i
< 2; ++i
) {
178 #define REGISTER_CALLBACK(serv,path,types, function) lo_server_add_method (serv, path, types, OSC::_ ## function, this)
180 REGISTER_CALLBACK (serv
, "/ardour/add_marker", "", add_marker
);
181 REGISTER_CALLBACK (serv
, "/ardour/access_action", "s", access_action
);
182 REGISTER_CALLBACK (serv
, "/ardour/loop_toggle", "", loop_toggle
);
183 REGISTER_CALLBACK (serv
, "/ardour/goto_start", "", goto_start
);
184 REGISTER_CALLBACK (serv
, "/ardour/goto_end", "", goto_end
);
185 REGISTER_CALLBACK (serv
, "/ardour/rewind", "", rewind
);
186 REGISTER_CALLBACK (serv
, "/ardour/ffwd", "", ffwd
);
187 REGISTER_CALLBACK (serv
, "/ardour/transport_stop", "", transport_stop
);
188 REGISTER_CALLBACK (serv
, "/ardour/transport_play", "", transport_play
);
189 REGISTER_CALLBACK (serv
, "/ardour/set_transport_speed", "f", set_transport_speed
);
190 REGISTER_CALLBACK (serv
, "/ardour/save_state", "", save_state
);
191 REGISTER_CALLBACK (serv
, "/ardour/prev_marker", "", prev_marker
);
192 REGISTER_CALLBACK (serv
, "/ardour/next_marker", "", next_marker
);
193 REGISTER_CALLBACK (serv
, "/ardour/undo", "", undo
);
194 REGISTER_CALLBACK (serv
, "/ardour/redo", "", redo
);
195 REGISTER_CALLBACK (serv
, "/ardour/toggle_punch_in", "", toggle_punch_in
);
196 REGISTER_CALLBACK (serv
, "/ardour/toggle_punch_out", "", toggle_punch_out
);
197 REGISTER_CALLBACK (serv
, "/ardour/rec_enable_toggle", "", rec_enable_toggle
);
198 REGISTER_CALLBACK (serv
, "/ardour/toggle_all_rec_enables", "", toggle_all_rec_enables
);
200 REGISTER_CALLBACK (serv
, "/ardour/routes/mute", "ii", route_mute
);
201 REGISTER_CALLBACK (serv
, "/ardour/routes/solo", "ii", route_solo
);
202 REGISTER_CALLBACK (serv
, "/ardour/routes/recenable", "ii", route_recenable
);
203 REGISTER_CALLBACK (serv
, "/ardour/routes/gainabs", "if", route_set_gain_abs
);
204 REGISTER_CALLBACK (serv
, "/ardour/routes/gaindB", "if", route_set_gain_dB
);
207 REGISTER_CALLBACK (serv
, "/ardour/*/#current_value", "", current_value
);
208 REGISTER_CALLBACK (serv
, "/ardour/set", "", set
);
212 // un/register_update args= s:ctrl s:returl s:retpath
213 lo_server_add_method(serv
, "/register_update", "sss", OSC::global_register_update_handler
, this);
214 lo_server_add_method(serv
, "/unregister_update", "sss", OSC::global_unregister_update_handler
, this);
215 lo_server_add_method(serv
, "/register_auto_update", "siss", OSC::global_register_auto_update_handler
, this);
216 lo_server_add_method(serv
, "/unregister_auto_update", "sss", OSC::_global_unregister_auto_update_handler
, this);
222 OSC::init_osc_thread ()
224 // create new thread to run server
225 if (pipe (_request_pipe
)) {
226 cerr
<< "Cannot create osc request signal pipe" << strerror (errno
) << endl
;
230 if (fcntl (_request_pipe
[0], F_SETFL
, O_NONBLOCK
)) {
231 cerr
<< "osc: cannot set O_NONBLOCK on signal read pipe " << strerror (errno
) << endl
;
235 if (fcntl (_request_pipe
[1], F_SETFL
, O_NONBLOCK
)) {
236 cerr
<< "osc: cannot set O_NONBLOCK on signal write pipe " << strerror (errno
) << endl
;
241 pthread_attr_init(&attr
);
242 pthread_attr_setstacksize(&attr
, 500000);
244 pthread_create_and_store (X_("OSC"), &_osc_thread
, &attr
, &OSC::_osc_receiver
, this);
248 pthread_attr_destroy(&attr
);
250 //pthread_detach (_osc_thread);
255 OSC::terminate_osc_thread ()
263 pthread_join (_osc_thread
, &status
);
267 OSC::poke_osc_thread ()
271 if (write (_request_pipe
[1], &c
, 1) != 1) {
272 cerr
<< "cannot send signal to osc thread! " << strerror (errno
) << endl
;
277 OSC::get_server_url()
283 urlstr
= lo_server_get_url (_osc_server
);
292 OSC::get_unix_server_url()
297 if (_osc_unix_server
) {
298 urlstr
= lo_server_get_url (_osc_unix_server
);
310 OSC::_osc_receiver(void * arg
)
312 PBD::notify_gui_about_thread_creation (pthread_self(), X_("OSC"));
313 static_cast<OSC
*> (arg
)->osc_receiver();
320 struct pollfd pfd
[3];
327 fds
[0] = _request_pipe
[0];
330 if (_osc_server
&& lo_server_get_socket_fd(_osc_server
) >= 0) {
331 fds
[nfds
] = lo_server_get_socket_fd(_osc_server
);
332 srvs
[nfds
] = _osc_server
;
336 if (_osc_unix_server
&& lo_server_get_socket_fd(_osc_unix_server
) >= 0) {
337 fds
[nfds
] = lo_server_get_socket_fd(_osc_unix_server
);
338 srvs
[nfds
] = _osc_unix_server
;
345 for (int i
=0; i
< nfds
; ++i
) {
347 pfd
[i
].events
= POLLIN
|POLLPRI
|POLLHUP
|POLLERR
;
352 //cerr << "poll on " << nfds << " for " << timeout << endl;
353 if ((ret
= poll (pfd
, nfds
, timeout
)) < 0) {
354 if (errno
== EINTR
) {
355 /* gdb at work, perhaps */
359 cerr
<< "OSC thread poll failed: " << strerror (errno
) << endl
;
364 //cerr << "poll returned " << ret << " pfd[0].revents = " << pfd[0].revents << " pfd[1].revents = " << pfd[1].revents << endl;
370 if ((pfd
[0].revents
& ~POLLIN
)) {
371 cerr
<< "OSC: error polling extra port" << endl
;
375 for (int i
=1; i
< nfds
; ++i
) {
376 if (pfd
[i
].revents
& POLLIN
)
378 // this invokes callbacks
379 // cerr << "invoking recv on " << pfd[i].fd << endl;
380 lo_server_recv(srvs
[i
]);
386 //cerr << "SL engine shutdown" << endl;
389 int fd
= lo_server_get_socket_fd(_osc_server
);
394 lo_server_free (_osc_server
);
398 if (_osc_unix_server
) {
399 cerr
<< "freeing unix server" << endl
;
400 lo_server_free (_osc_unix_server
);
401 _osc_unix_server
= 0;
404 close(_request_pipe
[0]);
405 close(_request_pipe
[1]);
409 OSC::set_session (Session
& s
)
412 session
->GoingAway
.connect (mem_fun (*this, &OSC::session_going_away
));
414 // "Application Hooks"
416 session
->Exported
.connect( mem_fun( *this, &OSC::session_exported
) );
420 OSC::session_going_away ()
425 // "Application Hook" Handlers //
427 OSC::session_loaded( Session
& s
) {
428 lo_address listener
= lo_address_new( NULL
, "7770" );
429 lo_send( listener
, "/session/loaded", "ss", s
.path().c_str(), s
.name().c_str() );
433 OSC::session_exported( std::string path
, std::string name
) {
434 lo_address listener
= lo_address_new( NULL
, "7770" );
435 lo_send( listener
, "/session/exported", "ss", path
.c_str(), name
.c_str() );
438 // end "Application Hook" Handlers //
443 OSC::current_value (const char *path
, const char *types
, lo_arg
**argv
, int argc
, void *data
, void* user_data
)
448 if (argc
< 3 || types
== 0 || strlen (types
) < 3 || types
[0] != 's' || types
[1] != 's' || types
[2] != s
) {
452 const char *returl
= argv
[1]->s
;
453 lo_address addr
= find_or_cache_addr (returl
);
455 const char *retpath
= argv
[2]->s
;
458 if (strcmp (argv
[0]->s
, "transport_frame")) {
461 lo_send (addr
, retpath
, "i", session
->transport_frame());
464 } else if (strcmp (argv
[0]->s
, "transport_speed")) {
467 lo_send (addr
, retpath
, "i", session
->transport_frame());
470 } else if (strcmp (argv
[0]->s
, "transport_locked")) {
473 lo_send (addr
, retpath
, "i", session
->transport_frame());
476 } else if (strcmp (argv
[0]->s
, "punch_in") {
479 lo_send (addr
, retpath
, "i", session
->transport_frame());
482 } else if (strcmp (argv
[0]->s
, "punch_out") {
485 lo_send (addr
, retpath
, "i", session
->transport_frame());
488 } else if (strcmp (argv
[0]->s
, "rec_enable") {
491 lo_send (addr
, retpath
, "i", session
->transport_frame());
503 OSC::route_mute (int rid
, int yn
)
505 if (!session
) return -1;
507 boost::shared_ptr
<Route
> r
= session
->route_by_remote_id (rid
);
510 r
->set_mute (yn
, this);
516 OSC::route_solo (int rid
, int yn
)
518 if (!session
) return -1;
520 boost::shared_ptr
<Route
> r
= session
->route_by_remote_id (rid
);
523 r
->set_solo (yn
, this);
529 OSC::route_recenable (int rid
, int yn
)
531 if (!session
) return -1;
533 boost::shared_ptr
<Route
> r
= session
->route_by_remote_id (rid
);
536 r
->set_record_enable (yn
, this);
542 OSC::route_set_gain_abs (int rid
, float level
)
544 if (!session
) return -1;
546 boost::shared_ptr
<Route
> r
= session
->route_by_remote_id (rid
);
549 r
->set_gain (level
, this);
556 OSC::route_set_gain_dB (int rid
, float dB
)
558 if (!session
) return -1;
560 boost::shared_ptr
<Route
> r
= session
->route_by_remote_id (rid
);
563 r
->set_gain (dB_to_coefficient (dB
), this);