diff options
| -rw-r--r-- | src/libs/shared/OSCSender.cpp | 118 | ||||
| -rw-r--r-- | src/libs/shared/OSCSender.hpp | 59 |
2 files changed, 177 insertions, 0 deletions
diff --git a/src/libs/shared/OSCSender.cpp b/src/libs/shared/OSCSender.cpp new file mode 100644 index 00000000..340786db --- /dev/null +++ b/src/libs/shared/OSCSender.cpp @@ -0,0 +1,118 @@ +/* This file is part of Ingen. + * Copyright (C) 2008 Dave Robillard <http://drobilla.net> + * + * Ingen is free software; you can redistribute it and/or modify it under the + * terms of the GNU General Public License as published by the Free Software + * Foundation; either version 2 of the License, or (at your option) any later + * version. + * + * Ingen is distributed in the hope that it will be useful, but WITHOUT ANY + * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS + * FOR A PARTICULAR PURPOSE. See the GNU General Public License for details. + * + * You should have received a copy of the GNU General Public License along + * with this program; if not, write to the Free Software Foundation, Inc., + * 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA + */ + +#include "OSCSender.hpp" +#include <cassert> +#include <iostream> + +using namespace std; + +namespace Ingen { +namespace Shared { + + +OSCSender::OSCSender() + : _transfer(NULL) + , _address(NULL) + , _enabled(true) +{ +} + + +void +OSCSender::bundle_begin() +{ + assert(!_transfer); + _transfer = lo_bundle_new(LO_TT_IMMEDIATE); + _send_state = SendingBundle; +} + + +void +OSCSender::bundle_end() +{ + transfer_end(); +} + + +void +OSCSender::transfer_begin() +{ + assert(!_transfer); + _transfer = lo_bundle_new(LO_TT_IMMEDIATE); + _send_state = SendingTransfer; +} + + +void +OSCSender::transfer_end() +{ + assert(_transfer); + lo_send_bundle(_address, _transfer); + lo_bundle_free(_transfer); + _transfer = NULL; + _send_state = Immediate; +} + + +int +OSCSender::send(const char *path, const char *types, ...) +{ + if (!_enabled) + return 0; + + va_list args; + va_start(args, types); + + lo_message msg = lo_message_new(); + int ret = lo_message_add_varargs(msg, types, args); + + if (!ret) + send_message(path, msg); + + va_end(args); + + return ret; +} + + +void +OSCSender::send_message(const char* path, lo_message msg) +{ + // FIXME: size? liblo doesn't export this. + // Don't want to exceed max UDP packet size (1500 bytes?) + static const size_t MAX_BUNDLE_SIZE = 1500 - 32*5; + + if (!_enabled) + return; + + if (_transfer) { + if (lo_bundle_length(_transfer) + lo_message_length(msg, path) > MAX_BUNDLE_SIZE) { + if (_send_state == SendingBundle) + cerr << "WARNING: Maximum bundle size reached, bundle split" << endl; + lo_send_bundle(_address, _transfer); + _transfer = lo_bundle_new(LO_TT_IMMEDIATE); + } + lo_bundle_add_message(_transfer, path, msg); + + } else { + lo_send_message(_address, path, msg); + } +} + +} // namespace Shared +} // namespace Ingen diff --git a/src/libs/shared/OSCSender.hpp b/src/libs/shared/OSCSender.hpp new file mode 100644 index 00000000..16b6dd22 --- /dev/null +++ b/src/libs/shared/OSCSender.hpp @@ -0,0 +1,59 @@ +/* This file is part of Ingen. + * Copyright (C) 2007 Dave Robillard <http://drobilla.net> + * + * Ingen is free software; you can redistribute it and/or modify it under the + * terms of the GNU General Public License as published by the Free Software + * Foundation; either version 2 of the License, or (at your option) any later + * version. + * + * Ingen is distributed in the hope that it will be useful, but WITHOUT ANY + * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS + * FOR A PARTICULAR PURPOSE. See the GNU General Public License for details. + * + * You should have received a copy of the GNU General Public License along + * with this program; if not, write to the Free Software Foundation, Inc., + * 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA + */ + +#ifndef OSCSENDER_H +#define OSCSENDER_H + +#include <inttypes.h> +#include <lo/lo.h> + +namespace Ingen { +namespace Shared { + +class OSCSender { +public: + OSCSender(); + ~OSCSender(); + + lo_address address() const { return _address; } + + // Message bundling + void bundle_begin(); + void bundle_end(); + + // Transfers (loose bundling) + void transfer_begin(); + void transfer_end(); + +protected: + int send(const char *path, const char *types, ...); + void send_message(const char* path, lo_message m); + + enum SendState { Immediate, SendingBundle, SendingTransfer }; + + SendState _send_state; + lo_bundle _transfer; + lo_address _address; + bool _enabled; +}; + + +} // namespace Shared +} // namespace Ingen + +#endif // OSCSENDER_H + |