+++ /dev/null
-/*
-
- Copyright (C) 2011 Grame
-
- This library is free software; you can redistribute it and/or
- modify it under the terms of the GNU Lesser General Public
- License as published by the Free Software Foundation; either
- version 2.1 of the License, or (at your option) any later version.
-
- This library 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
- Lesser General Public License for more details.
-
- You should have received a copy of the GNU Lesser General Public
- License along with this library; if not, write to the Free Software
- Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
-
- Grame Research Laboratory, 9 rue du Garet, 69001 Lyon - France
- research@grame.fr
-
-*/
-
-#include <string>
-#include <sstream>
-
-#include "RootNode.h"
-#include "Message.h"
-#include "OSCStream.h"
-#include "OSCControler.h"
-#include "OSCIO.h"
-
-#ifdef WIN32
-# include "winsock2.h"
-#else
-# include "ip/NetworkingUtils.h"
-#endif
-
-using namespace std;
-
-namespace oscfaust
-{
-
-static const char * kHelloMsg = "hello";
-
-
-//--------------------------------------------------------------------------
-// ip address utility
-//--------------------------------------------------------------------------
-static string getHostName()
-{
- char name[512];
- int ret = gethostname(name, 512);
- if (ret == -1) return "";
- return name;
-}
-
-string getIP()
-{
- string name = getHostName();
- stringstream ipStr;
- if (name.size()) {
- unsigned long ip = GetHostByName(name.c_str());
- ipStr << ((ip >> 24) & 0xff) << '.'
- << ((ip >> 16) & 0xff) << '.'
- << ((ip >> 8) & 0xff) << '.'
- << (ip & 0xff);
- }
- return ipStr.str();
-}
-
-//--------------------------------------------------------------------------
-// signal data handler
-//--------------------------------------------------------------------------
-bool RootNode::acceptSignal( const Message* msg )
-{
- bool ret = true;
- int n = msg->size();
- if (n) {
- float val, * buff = new float[n];
- for (int i = 0; i < n ; i++) {
- if (msg->param(i, val)) // assumes that it receives float values only
- buff[i] = val;
- else { // in case not
- ret = false; // set return code to false
- break; // and stops reading data
- }
- }
- if (ret) fIO->receive (n, buff); // call the IO controler receive method with the float data
- delete buff;
- }
- else ret = false;
- return ret;
-}
-
-//--------------------------------------------------------------------------
-bool RootNode::accept( const Message* msg )
-{
- string val;
- // checks for the 'hello' message first
- if ((msg->size() == 1) && (msg->param(0, val)) && (val == kHelloMsg) ) {
- hello (msg->src());
- return true;
- }
- else if (MessageDriven::accept (msg)) // next checks for standard handlers ('get' for example)
- return true;
- else if (fIO) // when still not handled and if a IO controler is set
- return acceptSignal (msg); // try to read signal data
- return false;
-}
-
-//--------------------------------------------------------------------------
-void RootNode::setPorts (int* in, int* out, int* err)
-{
- fUPDIn = in;
- fUDPOut = out;
- fUDPErr = err;
-}
-
-//--------------------------------------------------------------------------
-void RootNode::hello (unsigned long ipdest ) const
-{
- if (fUPDIn && fUDPOut && fUDPErr) { // on 'hello' request
- unsigned long savedip = oscout.getAddress(); // saves the current dest IP
- oscout.setAddress(ipdest); // set the destination IP
- // and sends its address + the udp port numbers (in, out and err)
- oscout << OSCStart(getOSCAddress().c_str()) << getIP() << *fUPDIn << *fUDPOut << *fUDPErr << OSCEnd();
- oscout.setAddress(savedip); // and restores the dest IP
- }
-}
-
-} // end namespoace