ripped stuff from daemon and generalized it for libary usage

1 files changed, 73 insertions, 0 deletions

diff --git a/noncore/net/wellenreiter/libwellenreiter/source/sock.cc b/noncore/net/wellenreiter/libwellenreiter/source/sock.cc
new file mode 100644
index 0000000..2cc16eb
--- a/dev/null
+++ b/noncore/net/wellenreiter/libwellenreiter/source/sock.cc
@@ -0,0 +1,73 @@
+/*
+ * Socket operations for wellenreiter
+ *
+ * $Id$
+ */
+
+#include "sock.hh"
+#include "log.hh"
+
+/* Setup UDP Socket for incoming commands */
+int commsock(const char *host, int port)
+{
+  struct sockaddr_in saddr;
+  int sock;
+
+  if((sock=socket(AF_INET, SOCK_DGRAM, 0)) < 0)
+  {
+    wl_logerr("Cannot set up socket: %s", strerror(errno));
+    return -1;
+  }
+
+  memset(&saddr, 0, sizeof(saddr));
+  saddr.sin_family = PF_INET;
+  saddr.sin_port = htons(port);
+  saddr.sin_addr.s_addr = inet_addr(host);
+ 
+  if(bind(sock,(struct sockaddr *)&saddr, sizeof(saddr)) < 0)
+  {
+    wl_logerr("Cannot bind socket: %s", strerror(errno));
+    close(sock);
+    return -1;
+  }
+
+  return sock;
+}
+
+/* Send a string to commsock */
+int sendcomm(const char *host, int port, const char *string, ...) 
+{
+  int sock;
+  char buffer[4096];
+  struct sockaddr_in saddr;
+  va_list ap;
+
+  /* Generate string */
+  memset(buffer, 0, sizeof(buffer));
+  va_start(ap, string);
+  vsnprintf(buffer, sizeof(buffer)-1, string, ap);
+  va_end(ap);
+
+  /* Setup socket */
+  if((sock=socket(AF_INET, SOCK_DGRAM, 0)) < 0)
+  {
+    wl_logerr("Cannot set up socket: %s", strerror(errno));
+    return -1;
+  }
+
+  saddr.sin_family = AF_INET;
+  saddr.sin_port = htons(port);
+  saddr.sin_addr.s_addr = inet_addr(host);
+
+  if(sendto(sock, buffer, sizeof(buffer), 0, (struct sockaddr *)&saddr, sizeof(saddr)) < 0)
+  {
+    wl_logerr("Cannot write to socket: %s", strerror(errno));
+    close(sock);
+    return 0;
+  }
+
+  if(close(sock) < 0)
+    wl_logerr("Cannot close socket: %s", strerror(errno));
+
+  return 1;
+}