src/osctlserv.cpp

   1 /* Calf DSP Library
   2  * Open Sound Control UDP server support
   3  *
   4  * Copyright (C) 2007-2009 Krzysztof Foltman
   5  *
   6  * This program is free software; you can redistribute it and/or
   7  * modify it under the terms of the GNU Lesser General Public
   8  * License as published by the Free Software Foundation; either
   9  * version 2 of the License, or (at your option) any later version.
  10  *
  11  * This program is distributed in the hope that it will be useful,
  12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  14  * Lesser General Public License for more details.
  15  *
  16  * You should have received a copy of the GNU Lesser General
  17  * Public License along with this program; if not, write to the
  18  * Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
  19  * Boston, MA  02110-1301  USA
  20  */
  21
  22 #include <calf/osctl.h>
  23 #include <calf/osctlserv.h>
  24 #include <assert.h>
  25 #include <arpa/inet.h>
  26 #include <sys/socket.h>
  27 #include <stdlib.h>
  28 #include <sstream>
  29
  30 using namespace osctl;
  31 using namespace std;
  32
  33 void osc_server::parse_message(const char *buffer, int len)
  34 {
  35     osctl::string_buffer buf(string(buffer, len));
  36     osc_strstream str(buf);
  37     string address, type_tag;
  38     str >> address;
  39     str >> type_tag;
  40     // cout << "Address " << address << " type tag " << type_tag << endl << flush;
  41     if (!address.empty() && address[0] == '/'
  42       &&!type_tag.empty() && type_tag[0] == ',')
  43     {
  44         sink->receive_osc_message(address, type_tag.substr(1), str);
  45     }
  46 }
  47
  48 void osc_server::on_bind()
  49 {
  50     ioch = g_io_channel_unix_new(socket);
  51     srcid = g_io_add_watch(ioch, G_IO_IN, on_data, this);
  52 }
  53
  54 gboolean osc_server::on_data(GIOChannel *channel, GIOCondition cond, void *obj)
  55 {
  56     osc_server *self = (osc_server *)obj;
  57     char buf[16384];
  58     int len = recv(self->socket, buf, 16384, 0);
  59     if (len > 0)
  60     {
  61         if (buf[0] == '/')
  62         {
  63             self->parse_message(buf, len);
  64         }
  65         if (buf[0] == '#')
  66         {
  67             // XXXKF bundles are not supported yet
  68         }
  69     }
  70     return TRUE;
  71 }
  72
  73 osc_server::~osc_server()
  74 {
  75     if (ioch)
  76         g_source_remove(srcid);
  77 }