our current experimental Neutrino branch

git-svn-id: file:///home/bas/coolstream_public_svn/THIRDPARTY/applications/neutrino-experimental@27 e54a6e83-5905-42d5-8d5c-058d10e6a962


Origin commit data
------------------
Branch: ni/coolstream
Commit: bc5bd4154e
Author: mrcolor <mrcolor@e54a6e83-5905-42d5-8d5c-058d10e6a962>
Date: 2009-12-08 (Tue, 08 Dec 2009)



------------------
This commit was generated by Migit

lib/connection/basicserver.cpp

@@ -0,0 +1,172 @@
+/*
+ * $Header: /cvs/tuxbox/apps/misc/libs/libconnection/basicserver.cpp,v 1.11 2004/04/08 08:00:55 thegoodguy Exp $
+ *
+ * Basic Server Class Class - The Tuxbox Project
+ *
+ * (C) 2002 - 2003 by thegoodguy <thegoodguy@berlios.de>
+ *
+ * License: GPL
+ *
+ * This program 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.
+ *
+ * This program 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 more 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., 675 Mass Ave, Cambridge, MA 02139, USA.
+ *
+ */
+
+#include "basicserver.h"
+#include "basicsocket.h"
+
+#include <cstdio>
+#include <cstdlib>
+
+#include <inttypes.h>
+#include <sys/poll.h>
+#include <sys/socket.h>
+#include <sys/types.h>
+#include <sys/un.h>
+#include <unistd.h>
+
+#define RECEIVE_TIMEOUT_IN_SECONDS 60
+#define SEND_TIMEOUT_IN_SECONDS 60
+
+bool CBasicServer::receive_data(int fd, void * data, const size_t size)
+{
+        timeval timeout;
+        timeout.tv_sec  = RECEIVE_TIMEOUT_IN_SECONDS;
+        timeout.tv_usec = 0;
+        return ::receive_data(fd, data, size, timeout);
+}
+
+bool CBasicServer::send_data(int fd, const void * data, const size_t size)
+{
+        timeval timeout;
+        timeout.tv_sec  = SEND_TIMEOUT_IN_SECONDS;
+        timeout.tv_usec = 0;
+        return ::send_data(fd, data, size, timeout);
+}
+
+void CBasicServer::delete_string(char * data)
+{
+	free((void *)data);
+}
+
+char * CBasicServer::receive_string(int fd)
+{
+	uint8_t length;
+
+	if (receive_data(fd, &length, sizeof(length)))
+	{
+		char * data = (char *)malloc(((size_t)length) + 1);
+		if (receive_data(fd, data, length))
+		{
+			data[length] = 0; /* add terminating 0 */
+			return data;
+		}
+		else
+		{
+			delete_string(data);
+			return NULL;
+		}
+	}
+	return NULL;
+}
+
+bool CBasicServer::prepare(const char* socketname)
+{
+	struct sockaddr_un servaddr;
+	int clilen;
+
+	memset(&servaddr, 0, sizeof(struct sockaddr_un));
+	servaddr.sun_family = AF_UNIX;
+	strcpy(servaddr.sun_path, socketname);
+	clilen = sizeof(servaddr.sun_family) + strlen(servaddr.sun_path);
+
+	unlink(socketname);
+
+	if ((sock_fd = socket(AF_UNIX, SOCK_STREAM, 0)) < 0)
+	{
+		printf("[CBasicServer] socket failed.\n");
+		perror(socketname);
+		return false;
+	}
+	if (bind(sock_fd, (struct sockaddr*) &servaddr, clilen) < 0)
+	{
+		printf("[CBasicServer] bind failed.\n");
+		perror(socketname);
+		return false;
+	}
+
+#define N_connection_requests_queued 5
+
+	if (listen(sock_fd, N_connection_requests_queued) != 0)
+	{
+		printf("[CBasicServer] listen failed.\n");
+		perror(socketname);
+		return false;
+	}
+
+	name = socketname;
+
+	return true;
+}
+
+bool CBasicServer::parse(bool (parse_command)(CBasicMessage::Header &rmsg, int connfd), const CBasicMessage::t_version version)
+{
+	int conn_fd;
+	struct sockaddr_un servaddr;
+	int clilen = sizeof(servaddr);
+	bool parse_another_command = true;
+
+	CBasicMessage::Header rmsg;
+	conn_fd = accept(sock_fd, (struct sockaddr*) &servaddr, (socklen_t*) &clilen);
+	memset(&rmsg, 0, sizeof(rmsg));
+	read(conn_fd, &rmsg, sizeof(rmsg));
+
+	if (rmsg.version == version)
+		parse_another_command = parse_command(rmsg, conn_fd);
+	else
+		printf("[%s] Command ignored: cmd version %d received - server cmd version is %d\n", name.c_str(), rmsg.version, version);
+
+	close(conn_fd);
+
+	return parse_another_command;
+}
+
+bool CBasicServer::run(bool (parse_command)(CBasicMessage::Header &rmsg, int connfd), const CBasicMessage::t_version version, bool non_blocking)
+{
+	if (non_blocking) {
+		struct pollfd pfd;
+
+		pfd.fd = sock_fd;
+		pfd.events = (POLLIN | POLLPRI);
+
+		if (poll(&pfd, 1, 0) > 0)
+			return parse(parse_command, version);
+		else
+			return true;
+	}
+	else {
+		while(parse(parse_command, version));
+
+		stop();
+
+		return false;
+	}
+}
+
+void CBasicServer::stop(void)
+{
+	close(sock_fd);
+        unlink(name.c_str());
+}
+