lbajardsilogic@0: /* -*- c-basic-offset: 4 indent-tabs-mode: nil -*- vi:set ts=8 sts=4 sw=4: */ lbajardsilogic@0: lbajardsilogic@0: /* lbajardsilogic@0: Sonic Visualiser lbajardsilogic@0: An audio file viewer and annotation editor. lbajardsilogic@0: Centre for Digital Music, Queen Mary, University of London. lbajardsilogic@0: lbajardsilogic@0: This program is free software; you can redistribute it and/or lbajardsilogic@0: modify it under the terms of the GNU General Public License as lbajardsilogic@0: published by the Free Software Foundation; either version 2 of the lbajardsilogic@0: License, or (at your option) any later version. See the file lbajardsilogic@0: COPYING included with this distribution for more information. lbajardsilogic@0: */ lbajardsilogic@0: lbajardsilogic@0: /* lbajardsilogic@0: This is a modified version of a source file from the lbajardsilogic@0: Rosegarden MIDI and audio sequencer and notation editor. lbajardsilogic@0: This file copyright 2000-2006 Chris Cannam and QMUL. lbajardsilogic@0: */ lbajardsilogic@0: lbajardsilogic@0: #include "OSCQueue.h" lbajardsilogic@0: lbajardsilogic@0: #include lbajardsilogic@0: lbajardsilogic@0: #define OSC_MESSAGE_QUEUE_SIZE 1023 lbajardsilogic@0: lbajardsilogic@0: #ifdef HAVE_LIBLO lbajardsilogic@0: lbajardsilogic@0: void lbajardsilogic@0: OSCQueue::oscError(int num, const char *msg, const char *path) lbajardsilogic@0: { lbajardsilogic@0: std::cerr << "ERROR: OSCQueue::oscError: liblo server error " << num lbajardsilogic@0: << " in path " << path << ": " << msg << std::endl; lbajardsilogic@0: } lbajardsilogic@0: lbajardsilogic@0: int lbajardsilogic@0: OSCQueue::oscMessageHandler(const char *path, const char *types, lo_arg **argv, lbajardsilogic@0: int argc, lo_message, void *user_data) lbajardsilogic@0: { lbajardsilogic@0: OSCQueue *queue = static_cast(user_data); lbajardsilogic@0: lbajardsilogic@0: int target; lbajardsilogic@0: int targetData; lbajardsilogic@0: QString method; lbajardsilogic@0: lbajardsilogic@0: if (!queue->parseOSCPath(path, target, targetData, method)) { lbajardsilogic@0: return 1; lbajardsilogic@0: } lbajardsilogic@0: lbajardsilogic@0: OSCMessage message; lbajardsilogic@0: message.setTarget(target); lbajardsilogic@0: message.setTargetData(targetData); lbajardsilogic@0: message.setMethod(method); lbajardsilogic@0: lbajardsilogic@0: int i = 0; lbajardsilogic@0: lbajardsilogic@0: while (types && i < argc && types[i]) { lbajardsilogic@0: lbajardsilogic@0: char type = types[i]; lbajardsilogic@0: lo_arg *arg = argv[i]; lbajardsilogic@0: lbajardsilogic@0: switch (type) { lbajardsilogic@0: case 'i': message.addArg(arg->i); break; lbajardsilogic@0: case 'h': message.addArg(arg->h); break; lbajardsilogic@0: case 'f': message.addArg(arg->f); break; lbajardsilogic@0: case 'd': message.addArg(arg->d); break; lbajardsilogic@0: case 'c': message.addArg(arg->c); break; lbajardsilogic@0: case 't': message.addArg(arg->i); break; lbajardsilogic@0: case 's': message.addArg(&arg->s); break; lbajardsilogic@0: default: std::cerr << "WARNING: OSCQueue::oscMessageHandler: " lbajardsilogic@0: << "Unsupported OSC type '" << type << "'" lbajardsilogic@0: << std::endl; lbajardsilogic@0: break; lbajardsilogic@0: } lbajardsilogic@0: lbajardsilogic@0: ++i; lbajardsilogic@0: } lbajardsilogic@0: lbajardsilogic@0: queue->postMessage(message); lbajardsilogic@0: return 0; lbajardsilogic@0: } lbajardsilogic@0: lbajardsilogic@0: #endif lbajardsilogic@0: lbajardsilogic@0: OSCQueue::OSCQueue() : lbajardsilogic@0: #ifdef HAVE_LIBLO lbajardsilogic@0: m_thread(0), lbajardsilogic@0: #endif lbajardsilogic@0: m_buffer(OSC_MESSAGE_QUEUE_SIZE) lbajardsilogic@0: { lbajardsilogic@0: #ifdef HAVE_LIBLO lbajardsilogic@0: m_thread = lo_server_thread_new(NULL, oscError); lbajardsilogic@0: lbajardsilogic@0: lo_server_thread_add_method(m_thread, NULL, NULL, lbajardsilogic@0: oscMessageHandler, this); lbajardsilogic@0: lbajardsilogic@0: lo_server_thread_start(m_thread); lbajardsilogic@0: lbajardsilogic@0: std::cout << "OSCQueue::OSCQueue: Base OSC URL is " lbajardsilogic@0: << lo_server_thread_get_url(m_thread) << std::endl; lbajardsilogic@0: #endif lbajardsilogic@0: } lbajardsilogic@0: lbajardsilogic@0: OSCQueue::~OSCQueue() lbajardsilogic@0: { lbajardsilogic@0: #ifdef HAVE_LIBLO lbajardsilogic@0: if (m_thread) { lbajardsilogic@0: lo_server_thread_stop(m_thread); lbajardsilogic@0: } lbajardsilogic@0: #endif lbajardsilogic@0: lbajardsilogic@0: while (m_buffer.getReadSpace() > 0) { lbajardsilogic@0: delete m_buffer.readOne(); lbajardsilogic@0: } lbajardsilogic@0: } lbajardsilogic@0: lbajardsilogic@0: bool lbajardsilogic@0: OSCQueue::isOK() const lbajardsilogic@0: { lbajardsilogic@0: #ifdef HAVE_LIBLO lbajardsilogic@0: return (m_thread != 0); lbajardsilogic@0: #else lbajardsilogic@0: return false; lbajardsilogic@0: #endif lbajardsilogic@0: } lbajardsilogic@0: lbajardsilogic@0: QString lbajardsilogic@0: OSCQueue::getOSCURL() const lbajardsilogic@0: { lbajardsilogic@0: QString url = ""; lbajardsilogic@0: #ifdef HAVE_LIBLO lbajardsilogic@0: url = lo_server_thread_get_url(m_thread); lbajardsilogic@0: #endif lbajardsilogic@0: return url; lbajardsilogic@0: } lbajardsilogic@0: lbajardsilogic@0: size_t lbajardsilogic@0: OSCQueue::getMessagesAvailable() const lbajardsilogic@0: { lbajardsilogic@0: return m_buffer.getReadSpace(); lbajardsilogic@0: } lbajardsilogic@0: lbajardsilogic@0: OSCMessage lbajardsilogic@0: OSCQueue::readMessage() lbajardsilogic@0: { lbajardsilogic@0: OSCMessage *message = m_buffer.readOne(); lbajardsilogic@0: OSCMessage rmessage = *message; lbajardsilogic@0: delete message; lbajardsilogic@0: return rmessage; lbajardsilogic@0: } lbajardsilogic@0: lbajardsilogic@0: void lbajardsilogic@0: OSCQueue::postMessage(OSCMessage message) lbajardsilogic@0: { lbajardsilogic@0: int count = 0, max = 5; lbajardsilogic@0: while (m_buffer.getWriteSpace() == 0) { lbajardsilogic@0: if (count == max) { lbajardsilogic@0: std::cerr << "ERROR: OSCQueue::postMessage: OSC message queue is full and not clearing -- abandoning incoming message" << std::endl; lbajardsilogic@0: return; lbajardsilogic@0: } lbajardsilogic@0: std::cerr << "WARNING: OSCQueue::postMessage: OSC message queue (capacity " << m_buffer.getSize() << " is full!" << std::endl; lbajardsilogic@0: std::cerr << "Waiting for something to be processed" << std::endl; lbajardsilogic@0: #ifdef _WIN32 lbajardsilogic@0: Sleep(1); lbajardsilogic@0: #else lbajardsilogic@0: sleep(1); lbajardsilogic@0: #endif lbajardsilogic@0: count++; lbajardsilogic@0: } lbajardsilogic@0: lbajardsilogic@0: OSCMessage *mp = new OSCMessage(message); lbajardsilogic@0: m_buffer.write(&mp, 1); lbajardsilogic@0: std::cerr << "OSCQueue::postMessage: Posted OSC message: target " lbajardsilogic@0: << message.getTarget() << ", target data " << message.getTargetData() lbajardsilogic@0: << ", method " << message.getMethod().toStdString() << std::endl; lbajardsilogic@0: emit messagesAvailable(); lbajardsilogic@0: } lbajardsilogic@0: lbajardsilogic@0: bool lbajardsilogic@0: OSCQueue::parseOSCPath(QString path, int &target, int &targetData, lbajardsilogic@0: QString &method) lbajardsilogic@0: { lbajardsilogic@0: while (path.startsWith("/")) { lbajardsilogic@0: path = path.right(path.length()-1); lbajardsilogic@0: } lbajardsilogic@0: lbajardsilogic@0: int i = 0; lbajardsilogic@0: lbajardsilogic@0: bool ok = false; lbajardsilogic@0: target = path.section('/', i, i).toInt(&ok); lbajardsilogic@0: lbajardsilogic@0: if (!ok) { lbajardsilogic@0: target = 0; lbajardsilogic@0: } else { lbajardsilogic@0: ++i; lbajardsilogic@0: targetData = path.section('/', i, i).toInt(&ok); lbajardsilogic@0: if (!ok) { lbajardsilogic@0: targetData = 0; lbajardsilogic@0: } else { lbajardsilogic@0: ++i; lbajardsilogic@0: } lbajardsilogic@0: } lbajardsilogic@0: lbajardsilogic@0: method = path.section('/', i, -1); lbajardsilogic@0: lbajardsilogic@0: if (method.contains('/')) { lbajardsilogic@0: std::cerr << "ERROR: OSCQueue::parseOSCPath: malformed path \"" lbajardsilogic@0: << path.toStdString() << "\" (should be target/data/method or " lbajardsilogic@0: << "target/method or method, where target and data " lbajardsilogic@0: << "are numeric)" << std::endl; lbajardsilogic@0: return false; lbajardsilogic@0: } lbajardsilogic@0: lbajardsilogic@0: std::cerr << "OSCQueue::parseOSCPath: good path \"" << path.toStdString() lbajardsilogic@0: << "\"" << std::endl; lbajardsilogic@0: lbajardsilogic@0: return true; lbajardsilogic@0: } lbajardsilogic@0: