Broken comm stuff.

[tlb/tomd.git] / src / tomc / socket_read.c

/* 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;
}