From e2142f0c72d4d5d1db2ebfe55d42f334304ded72 Mon Sep 17 00:00:00 2001
From: Philippe PITTOLI <p.pittoli@unistra.fr>
Date: Thu, 26 May 2016 21:56:43 +0200
Subject: [PATCH] pas fini

---
 lib/communication.c | 75 ++++++++++++++++++++++++++++++---------------
 lib/communication.h |  1 +
 service-test.c      |  2 ++
 3 files changed, 53 insertions(+), 25 deletions(-)

diff --git a/lib/communication.c b/lib/communication.c
index 87cf5a3..a7a9d6e 100644
--- a/lib/communication.c
+++ b/lib/communication.c
@@ -45,47 +45,50 @@ int service_close (const char *fifopath)
     return 0;
 }
 
+// TODO only works for a single process
 void service_get_new_processes (struct process **proc, int *nproc, int sfifo)
 {
     char buf[BUFSIZ];
     bzero (buf, BUFSIZ);
     read (sfifo, buf, BUFSIZ);
 
-    // TODO
-#if 0
-    unsigned long long int val = strtoull(s, NULL, 10);
+    proc = malloc(sizeof(struct process*) * 1); // FIXME
+    proc[0] = malloc(sizeof(struct process) * 1); // FIXME
+
+    // unsigned long long int val = strtoul(s, NULL, 10);
 
     char *token, *saveptr;
     char *str;
-    int i, j;
+    int i;
 
-    // printf("%d fields :: ", f->nbfields);
-    // for( i = 0 ; i < f->nbfields ; i++) {
-    //     printf("%u, ", f->fields[i]);
-    // }
-    // printf("\n");
-
-    for (str = s, i = 1; ; str = NULL, i++) {
-        token = strtok_r(str, delim, &saveptr);
+    for (str = buf, i = 1; ; str = NULL, i++) {
+        token = strtok_r(str, " ", &saveptr);
         if (token == NULL)
             break;
 
-        // check if we need to print the current token humanized
-        int found = 0;
-
-        for (j = 0 ; j < f->nbfields && found == 0; j++ ) {
-            if( i == f->fields[j] ) {
-                print_token_to_human(token);
-                found = 1;
-            }
+        // do something
+        if (i == 1) {
+            // FIXME
+            proc[0]->pid = strtoul(token, NULL, 10);
+        }
+        else if (i == 2) {
+            // FIXME
+            proc[0]->version = strtoul(token, NULL, 10);
         }
 
-        // print the current token not humanized
-        if (found == 0) {
-            printf("%s ", token);
-        }
     }
-#endif
+}
+
+void struct_process_free (struct process * p)
+{
+    free (p);
+}
+
+void service_free_processes (struct process **procs, int nproc)
+{
+    while (--nproc != -1) {
+        struct_process_free (procs[nproc]);
+    }
 }
 
 void gen_process_structure (struct process *p
@@ -168,10 +171,32 @@ int process_close (struct process *proc)
 
 int process_read (struct process *proc, void * buf, size_t * msize)
 {
+    if ((*msize = read (proc->in, buf, *msize)))
+        return *msize;
+
     return 0;
 }
 
 int process_write (struct process *proc, void * buf, size_t msize)
 {
+    if ((msize = write (proc->out, buf, msize)))
+        return msize;
+
+    return 0;
+}
+
+int service_read (struct process *proc, void * buf, size_t * msize)
+{
+    if ((*msize = read (proc->out, buf, *msize)))
+        return *msize;
+
+    return 0;
+}
+
+int service_write (struct process *proc, void * buf, size_t msize)
+{
+    if ((msize = write (proc->in, buf, msize)))
+        return msize;
+
     return 0;
 }
diff --git a/lib/communication.h b/lib/communication.h
index aec6da6..491f044 100644
--- a/lib/communication.h
+++ b/lib/communication.h
@@ -43,6 +43,7 @@ int service_create (const char *sname);
 int service_close (const char *sname);
 
 void service_get_new_processes (struct process **, int *nproc, int sfifo);
+void service_free_processes (struct process **, int nproc);
 
 int process_create (struct process *, int index); // called by the application
 int process_destroy (struct process *); // called by the application
diff --git a/service-test.c b/service-test.c
index dca4865..28fe4e3 100644
--- a/service-test.c
+++ b/service-test.c
@@ -48,6 +48,8 @@ void main_loop (const char *spath)
                 exit (1);
             }
         }
+
+        service_free_processes (&proc, nproc);
     } while (0); // it's a test, we only do it once
 
     close (sfifo); // closes the service named pipe