2 Copyright (C) 2012 Paul Davis
4 Using code from Rui Nuno Capela's qmidinet as inspiration.
6 This program is free software; you can redistribute it and/or modify
7 it under the terms of the GNU General Public License as published by
8 the Free Software Foundation; either version 2 of the License, or
9 (at your option) any later version.
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
14 GNU General Public License for more details.
16 You should have received a copy of the GNU General Public License
17 along with this program; if not, write to the Free Software
18 Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
20 $Id: port.cc 12065 2012-04-23 16:23:48Z paul $
32 #if defined(PLATFORM_WINDOWS)
39 #if defined(PLATFORM_WINDOWS)
40 typedef int socklen_t;
43 #include <sys/ioctl.h>
44 inline void closesocket(int s) { ::close(s); }
47 #include "pbd/xml++.h"
48 #include "pbd/error.h"
49 #include "pbd/failed_constructor.h"
50 #include "pbd/convert.h"
51 #include "pbd/compose.h"
53 #include "midi++/types.h"
54 #include "midi++/ipmidi_port.h"
55 #include "midi++/channel.h"
61 IPMIDIPort::IPMIDIPort (int base_port, const string& iface)
62 : Port (string_compose ("IPmidi@%1", base_port), Port::Flags (Port::IsInput|Port::IsOutput))
66 if (!open_sockets (base_port, iface)) {
67 throw (failed_constructor ());
71 IPMIDIPort::IPMIDIPort (const XMLNode& node)
74 /* base class does not class set_state() */
78 IPMIDIPort::~IPMIDIPort ()
84 IPMIDIPort::selectable () const
90 IPMIDIPort::get_state () const
92 return Port::get_state ();
96 IPMIDIPort::set_state (const XMLNode& node)
98 Port::set_state (node);
102 IPMIDIPort::close_sockets ()
105 ::closesocket (sockin);
110 ::closesocket (sockout);
115 #ifndef PLATFORM_WINDOWS
117 get_address (int sock, struct in_addr *inaddr, const string& ifname )
119 // Get interface address from supplied name.
122 ::strncpy(ifr.ifr_name, ifname.c_str(), sizeof(ifr.ifr_name));
124 if (::ioctl(sock, SIOCGIFFLAGS, (char *) &ifr)) {
125 ::perror("ioctl(SIOCGIFFLAGS)");
129 if ((ifr.ifr_flags & IFF_UP) == 0) {
130 error << string_compose ("interface %1 is down", ifname) << endmsg;
134 if (::ioctl(sock, SIOCGIFADDR, (char *) &ifr)) {
135 ::perror("ioctl(SIOCGIFADDR)");
139 struct sockaddr_in sa;
140 ::memcpy(&sa, &ifr.ifr_addr, sizeof(struct sockaddr_in));
141 inaddr->s_addr = sa.sin_addr.s_addr;
148 IPMIDIPort::open_sockets (int base_port, const string& ifname)
151 struct protoent *proto = ::getprotobyname("IP");
154 protonum = proto->p_proto;
157 sockin = ::socket (PF_INET, SOCK_DGRAM, protonum);
159 ::perror("socket(in)");
163 struct sockaddr_in addrin;
164 ::memset(&addrin, 0, sizeof(addrin));
165 addrin.sin_family = AF_INET;
166 addrin.sin_addr.s_addr = htonl(INADDR_ANY);
167 addrin.sin_port = htons(base_port);
169 if (::bind(sockin, (struct sockaddr *) (&addrin), sizeof(addrin)) < 0) {
175 // INADDR_ANY will bind to default interface,
176 // specify alternate interface nameon which to bind...
177 struct in_addr if_addr_in;
178 #ifndef PLATFORM_WINDOWS
179 if (!ifname.empty()) {
180 if (!get_address(sockin, &if_addr_in, ifname)) {
181 error << string_compose ("socket(in): could not find interface address for %1", ifname) << endmsg;
184 if (::setsockopt(sockin, IPPROTO_IP, IP_MULTICAST_IF,
185 (char *) &if_addr_in, sizeof(if_addr_in))) {
186 ::perror("setsockopt(IP_MULTICAST_IF)");
190 if_addr_in.s_addr = htonl (INADDR_ANY);
193 if_addr_in.s_addr = htonl (INADDR_ANY);
197 mreq.imr_multiaddr.s_addr = ::inet_addr("225.0.0.37"); /* ipMIDI group multicast address */
198 mreq.imr_interface.s_addr = if_addr_in.s_addr;
199 if(::setsockopt (sockin, IPPROTO_IP, IP_ADD_MEMBERSHIP, (char *) &mreq, sizeof(mreq)) < 0) {
200 ::perror("setsockopt(IP_ADD_MEMBERSHIP)");
201 fprintf(stderr, "socket(in): your kernel is probably missing multicast support.\n");
207 sockout = ::socket (AF_INET, SOCK_DGRAM, protonum);
210 ::perror("socket(out)");
214 // Will Hall, Oct 2007
215 #ifndef PLATFORM_WINDOWS
216 if (!ifname.empty()) {
217 struct in_addr if_addr_out;
218 if (!get_address(sockout, &if_addr_out, ifname)) {
219 error << string_compose ("socket(out): could not find interface address for %1", ifname) << endmsg;
222 if (::setsockopt(sockout, IPPROTO_IP, IP_MULTICAST_IF, (char *) &if_addr_out, sizeof(if_addr_out))) {
223 ::perror("setsockopt(IP_MULTICAST_IF)");
229 ::memset(&addrout, 0, sizeof(struct sockaddr_in));
230 addrout.sin_family = AF_INET;
231 addrout.sin_addr.s_addr = ::inet_addr("225.0.0.37");
232 addrout.sin_port = htons (base_port);
234 struct sockaddr_in any;
235 ::memset(&any, 0, sizeof(struct sockaddr_in));
236 addrout.sin_family = AF_INET;
237 addrout.sin_addr.s_addr = INADDR_ANY;
238 addrout.sin_port = htons (base_port);
240 if (::bind(sockout, (struct sockaddr *) (&any), sizeof(any)) < 0) {
242 cout << "ipmidi bind error\n";
246 #ifndef PLATFORM_WINDOWS
254 if (::getsockopt (sockout, IPPROTO_IP, IP_MULTICAST_LOOP, (char *) &loop, &size)) {
255 // ::perror ("getsockopt(IP_MULTICAST_LOOP)");
256 cout << "Cannot get loopback status\n";
258 cout << "********* 1. multicast loopback: " << loop << " size was " << size << endl;
261 // Turn off loopback...
263 if (::setsockopt(sockout, IPPROTO_IP, IP_MULTICAST_LOOP, (char *) &loop, sizeof (loop)) < 0) {
264 //::perror("setsockopt(IP_MULTICAST_LOOP)");
265 cout << "Cannot set loopback status\n";
269 if (::getsockopt (sockout, IPPROTO_IP, IP_MULTICAST_LOOP, (char *) &loop, &size)) {
270 // ::perror ("getsockopt(IP_MULTICAST_LOOP)");
271 cout << "Cannot Get loopback status 2\n";
273 cout << "********* 2. multicast loopback: " << loop << " size was " << size << endl;
276 #ifndef PLATFORM_WINDOWS
278 if (fcntl (sockin, F_SETFL, O_NONBLOCK)) {
279 error << "cannot set non-blocking mode for IP MIDI input socket (" << ::strerror (errno) << ')' << endmsg;
283 if (fcntl (sockout, F_SETFL, O_NONBLOCK)) {
284 error << "cannot set non-blocking mode for IP MIDI output socket (" << ::strerror (errno) << ')' << endmsg;
289 // If imode !=0, non-blocking mode is enabled.
291 if (ioctlsocket(sockin,FIONBIO,&mode)) {
292 error << "cannot set non-blocking mode for IP MIDI input socket (" << ::strerror (errno) << ')' << endmsg;
295 mode = 1; /* just in case it was modified in the previous call */
296 if (ioctlsocket(sockout,FIONBIO,&mode)) {
297 error << "cannot set non-blocking mode for IP MIDI output socket (" << ::strerror (errno) << ')' << endmsg;
301 cout << "ipmidi ports setup!!!!!!!\n";
306 IPMIDIPort::write (const MIDI::byte* msg, size_t msglen, timestamp_t /* ignored */) {
309 Glib::Threads::Mutex::Lock lm (write_lock);
310 if (::sendto (sockout, (const char *) msg, msglen, 0, (struct sockaddr *) &addrout, sizeof(struct sockaddr_in)) < 0) {
320 IPMIDIPort::read (MIDI::byte* /*buf*/, size_t /*bufsize*/)
322 /* nothing to do here - all handled by parse() */
327 IPMIDIPort::parse (framecnt_t timestamp)
329 /* input was detected on the socket, so go get it and hand it to the
330 * parser. This will emit appropriate signals that will be handled
331 * by anyone who cares.
334 unsigned char buf[1024];
335 struct sockaddr_in sender;
336 socklen_t slen = sizeof(sender);
337 int r = ::recvfrom (sockin, (char *) buf, sizeof(buf), 0, (struct sockaddr *) &sender, &slen);
341 _parser->set_timestamp (timestamp);
343 for (int i = 0; i < r; ++i) {
344 _parser->scanner (buf[i]);
347 ::perror ("failed to recv from socket");