[Hblight-svn] SF.net SVN: hblight: [1] stream_server.c

[<ma...@us...>]

Revision: 1
          http://hblight.svn.sourceforge.net/hblight/?rev=1&view=rev
Author:   maci321
Date:     2008-01-28 01:03:48 -0800 (Mon, 28 Jan 2008)

Log Message:
-----------
initial import

Added Paths:
-----------
    stream_server.c

Added: stream_server.c
===================================================================
--- stream_server.c	                        (rev 0)
+++ stream_server.c	2008-01-28 09:03:48 UTC (rev 1)
@@ -0,0 +1,110 @@
+/*
+** stream_server.c --
+**
+** Serverside Socket Server for hblight
+** 
+** by Christian Hillen -- 2008-01-25
+*/
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <errno.h>
+#include <string.h>
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <netinet/in.h>
+#include <arpa/inet.h>
+#include <sys/wait.h>
+#include <signal.h>
+
+#define HBS_PORT 694 //We'll use UDP 694 to connect to hblight server <- ha-cluster-port
+#define PEN_CON 10 //size of queue
+#define MAXBUFLEN 255
+
+void sigchld_handler(int s) {
+	while(waitpid(-1, NULL, WNOHANG) > 0);
+}
+
+int main(void) {
+	int hbsocket, new_hbsocket; 
+	struct sockaddr_in my_addr; // This is our address
+	struct sockaddr_in their_addr; // This is connectors address
+	socklen_t sin_size;
+	socklen_t addr_len;
+	struct sigaction sa;
+	int yes=1;
+	int numbytes;
+	char buf[MAXBUFLEN];
+
+	if ((hbsocket = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
+		perror("setsockopt");
+		exit(1);
+	}
+	
+	if (setsockopt(hbsocket, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(int)) == -1) {
+		perror("setsockopt");
+		exit(1);
+	}
+
+	my_addr.sin_family = AF_INET;
+	my_addr.sin_port = htons(HBS_PORT);
+	my_addr.sin_addr.s_addr = INADDR_ANY;
+	memset(my_addr.sin_zero, '\0', sizeof my_addr.sin_zero);
+
+	if (bind(hbsocket, (struct sockaddr *)&my_addr, sizeof my_addr) == -1) {
+		perror("bind");
+		exit(1);
+	}
+
+	if(listen(hbsocket, PEN_CON) == -1) {
+		perror("listen");
+		exit(1);
+	}
+	
+	sa.sa_handler = sigchld_handler;
+	sigemptyset(&sa.sa_mask);
+	sa.sa_flags = SA_RESTART;
+	if (sigaction(SIGCHLD, &sa, NULL) == -1) {
+		perror("sigaction");
+		exit(1);
+	}
+
+
+	while(1) {
+		sin_size = sizeof their_addr;
+
+		if ((new_hbsocket = accept(hbsocket, (struct sockaddr *)&their_addr, &sin_size)) == -1) {
+			perror("accept");
+			continue;
+		}
+
+		addr_len = sizeof their_addr;
+		if ((numbytes = recvfrom(new_hbsocket, buf, MAXBUFLEN-1, 0, (struct sockaddr *)&their_addr, &addr_len)) == -1 ) {
+			perror("recvfrom");
+			exit(1);
+		}
+
+		printf("got connection from %s\n", inet_ntoa(their_addr.sin_addr));
+		printf("packet is %d bytes long\n", numbytes);
+		buf[numbytes] = '\0';
+		printf("packet contains: %s\n", buf);
+		if(numbytes != 11){
+			printf("packet is too small\n");
+		}
+
+		if(!fork()) {
+			close(hbsocket);
+			if (send(new_hbsocket, "Hello world!\n", 14, 0) == -1)
+				perror("send");
+			close(new_hbsocket);
+			exit(0);
+		}
+
+		close(new_hbsocket);
+
+	}
+	
+	return 0;
+
+}


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.