|
From: <ma...@us...> - 2008-01-28 09:03:53
|
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.
|