OscReceiver.cpp

#ifdef HAVE_OSC
#include "OscReceiver.h"
#include <iostream>
#include <cstdio>

namespace mmp {

bool OscReceiver::server_is_ok_ = true;

OscReceiver::OscReceiver(const std::string &port) : port_(port), server_(0) {
  server_ = lo_server_thread_new(port_.c_str(), error);
  server_is_ok_ = (server_ != NULL);
// #ifdef CONFIG_DEBUG
//     /* add method that will match any path and args */
//     lo_server_thread_add_method(server_, NULL, NULL, genericHandler, this);
// #endif
}

OscReceiver::~OscReceiver() {
//    std::cout << "Freeing OSC server thread\n";
  lo_server_thread_free(server_);
}

void OscReceiver::addHandler(const char *path, const char *types,
                             lo_method_handler handler, void *userData) {
  if (server_is_ok_)
    lo_server_thread_add_method(server_, path, types, handler, userData);
  else
    std::cout << "Could not add OSC handler " << path << std::endl;
}

void OscReceiver::listen() {
  if (server_is_ok_) {
    int lo_fd = lo_server_get_socket_fd(lo_server_thread_get_server(server_));
    if (lo_fd == 0) {
      std::cout << "OSC port " << port_ << " is already in use." << std::endl;
    } else {
      std::cout << "Listening on port " << port_ << std::endl;
      lo_server_thread_start(server_);
    }
  }
  else {
    std::cout << "Could not start OSC receiver. Maybe that ";
    std::cout << "OSC port " << port_ << " is already in use." << std::endl;
  }
}

void OscReceiver::error(int num, const char *msg, const char *path) {
  std::cerr << "liblo server error " << num << " in path " << path << ": " << msg << std::endl;
  OscReceiver::server_is_ok_ = false;
}

// #ifdef CONFIG_DEBUG
// /* catch any incoming messages and display them. returning 1 means that the 
//  *  * message has not been fully handled and the server should try other methods */
// int OscReceiver::genericHandler(const char *path, 
//         const char *types, lo_arg **argv, 
//         int argc, void * /*data*/, void * /*user_data*/) 
// { 
//     //OscReceiver *context = static_cast<OscReceiver*>(user_data);
//     printf("path: <%s>\n", path); 
//     for (int i = 0; i < argc; ++i) 
//     { 
//         printf("arg %d '%c' ", i, types[i]); 
//         lo_arg_pp(static_cast<lo_type>(types[i]), argv[i]); 
//         printf("\n"); 
//     } 
//     printf("\n"); 
//     fflush(stdout); 
// 
//     return 1; 
// } 
// #endif // CONFIG_DEBUG

std::string OscReceiver::toString() const {
  return "port:" + port_;
}

}

#endif // HAVE_OSC