1 files changed, 114 insertions, 0 deletions
diff --git a/mcop/unixconnection.cc b/mcop/unixconnection.cc
new file mode 100644
index 0000000..adda10d
--- /dev/null
+++ b/mcop/unixconnection.cc
@@ -0,0 +1,114 @@
+    /*
+
+    Copyright (C) 2000 Stefan Westerfeld
+                       [email protected]
+
+    This library is free software; you can redistribute it and/or
+    modify it under the terms of the GNU Library General Public
+    License as published by the Free Software Foundation; either
+    version 2 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
+    Library General Public License for more details.
+   
+    You should have received a copy of the GNU Library General Public License
+    along with this library; see the file COPYING.LIB.  If not, write to
+    the Free Software Foundation, Inc., 59 Temple Place - Suite 330,
+    Boston, MA 02111-1307, USA.
+
+    */
+
+#include "unixconnection.h"
+#include "dispatcher.h"
+#include "debug.h"
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <stdio.h>
+#include <sys/un.h>
+#include <errno.h>
+#include <stdlib.h>
+
+using namespace std;
+using namespace Arts;
+
+static struct sockaddr_un *parse_unix_url(const char *url)
+{
+	static struct sockaddr_un addr;
+
+	char *work = strdup(url);
+
+	char *type = strtok(work,":");
+	if(type == 0 || strcmp(type,"unix") != 0) {
+	    free(work);
+	    return 0;
+	}
+
+	char *path = strtok(NULL,":\n");
+	if(path == 0) {
+	    free(work);
+	    return 0;
+	}
+
+    int maxlen = sizeof(addr.sun_path);
+    memset((void *) &addr, '\0', sizeof(addr));
+    addr.sun_family = AF_UNIX;
+    strncpy(addr.sun_path,path,maxlen);
+	addr.sun_path[maxlen-1] = 0;
+	free(work);
+	return &addr;
+}
+
+static int unix_connect(const char *url)
+{
+	struct sockaddr_un *remote_addr = parse_unix_url(url);
+	if(remote_addr == 0)
+	{
+		arts_warning("unix_connect: couldn't parse url %s",url);
+		return -1;
+	}
+
+	int my_socket = socket(AF_UNIX,SOCK_STREAM,0);
+	if(my_socket < 0)
+	{
+		arts_warning("unix_connect: unable to open socket for read");
+		return -1;
+	}
+
+	struct linger lin;
+    lin.l_onoff=1;      /* block a closing socket for 1 second */
+    lin.l_linger=100;   /* if data is waiting to be sent */
+    if ( setsockopt( my_socket, SOL_SOCKET, SO_LINGER,
+                     (char*)&lin, sizeof(struct linger) ) < 0 )
+    {
+        arts_warning("unix_connect: unable to set socket linger value to %d",
+                lin.l_linger);
+		close(my_socket);
+        return -1;
+    }
+
+	int rc;
+	rc=connect(my_socket,(struct sockaddr *)remote_addr, sizeof(*remote_addr));
+	if(rc != 0)
+	{
+		arts_warning("unix_connect: can't connect to server (%s)",url);
+		close(my_socket);
+		return -1;
+	}
+
+	return my_socket;
+}
+
+UnixConnection::UnixConnection(const string& url)
+{
+	fd = unix_connect(url.c_str());
+	_broken = (fd == -1);
+
+	if(!_broken)
+	{
+		Dispatcher::the()->ioManager()->watchFD(fd,
+		  IOType::read|IOType::except|IOType::reentrant,this);
+		initReceive();
+	}
+}