X-Git-Url: https://git.hcoop.net/tlb/tomd.git/blobdiff_plain/812150806e9f20e1d43f1adda9257560b4751f5b..7bd7fa83730fd0270674860daa2c028f0d32effd:/src/tomc/socket_read.c

diff --git a/src/tomc/socket_read.c b/src/tomc/socket_read.c
new file mode 100644
index 0000000..cc165de
--- /dev/null
+++ b/src/tomc/socket_read.c
@@ -0,0 +1,132 @@
+/* Copyright (C) 2018 Thomas Balzer */
+
+/* This file is part of tomd. */
+
+/* tomd 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 3 of the License, or */
+/* (at your option) any later version. */
+
+/* tomd 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 tomd.  If not, see <http://www.gnu.org/licenses/>. */
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <unistd.h>
+#include <sys/un.h>
+#include <sys/socket.h>
+
+#define MAX_LEN 1024
+
+struct line{
+  char *buf;
+  struct line *next;
+};
+
+static struct{
+  char *buf;
+  int sfd;
+  struct line *lines;
+}options;
+
+void setup_socket(int sfd)
+{
+  options.sfd = sfd;
+  options.buf = malloc(sizeof(char) * MAX_LEN);
+}
+
+static struct line *find_lines(void)
+{
+  /* printf("entering find_lines\n"); */
+  struct line *lines = malloc(sizeof(struct line));
+  struct line *cur_line = lines;
+  struct line *old_line = lines;
+  char *ptr = options.buf;
+  lines->buf = options.buf;
+  lines->next = NULL;
+
+  /* printf("starting loop.\n"); */
+  while(1){
+    if(*ptr == '\n' || *ptr == '\0'){
+      /* printf("----\n"); */
+      /* printf("found a new line.\n"); */
+      /* printf("'%c' -> \\0\n", *ptr); */
+      /* printf("'next \%c': %c\n", *(ptr+1)); */
+      if(*ptr == '\0'){
+        /* end of buf */
+        /* printf("found the end. (1)\n"); */
+        return lines;
+      }
+
+      *ptr = '\0';
+      ptr++;
+
+      while(*ptr == '\n'){
+        /* empty, discard */
+        /* printf("empty\n"); */
+        *ptr = '\0';
+        ptr++;
+      }
+
+      if(*ptr == '\0'){
+        /* end of buf */
+        /* printf("found the end. (2)\n"); */
+        return lines;
+      }
+
+      /* printf("hallo there.\n"); */
+      cur_line = malloc(sizeof(struct line));
+      old_line->next = cur_line;
+      old_line = cur_line;
+      cur_line->buf = ptr;
+    }
+    printf("________|%c|\n", *ptr);
+    ptr++;
+  }      
+}
+
+void socket_read(void (*func)(char *line))
+{
+  if(options.lines != NULL){
+    printf("|||| already got some input. |||\n");
+    goto call_func;
+  }
+
+  int size;
+ do_read:
+  printf("||||| doing read. ||||\n");
+  size = read(options.sfd, options.buf, MAX_LEN);
+  printf("||||| got read. ||||\n");
+  if(size == 0){
+    printf("||||| reading again. ||||\n");
+    goto do_read;
+  }else{
+    printf("||||| done read. ||||\n");
+    options.lines = find_lines();
+
+    struct line *cur_line = options.lines;
+    
+    int count = 0;
+    while(1){
+      printf("[%d] '%s'\n", count++, cur_line->buf);
+      if(cur_line->next == NULL){
+        printf("found the end.\n");
+        break;
+      }
+      cur_line = cur_line->next;
+    }
+  }
+
+ call_func:
+  printf("calling function with %s\n", options.lines->buf);
+  func(options.lines->buf);
+  options.lines = options.lines->next;
+  return;
+}
+