modif on frequency in simulflux and fix average

Code-C/CMakeLists.txt

@@ -5,9 +5,12 @@ include(CTest)
 enable_testing()
 set(CMAKE_C_FLAGS "-std=c99 -g -Wall")
 
-add_executable(exect fileGestion.c getArray.c average.c growthRate.c power.c queue.c simulateFlux.c main.c)
+file(MAKE_DIRECTORY RawDataFiles)
+file(MAKE_DIRECTORY Executable)
 
+add_executable(exect fileGestion.c getArray.c average.c growthRate.c power.c queue.c simulateFlux.c main.c)
 # add_executable(exect main.c simulateFlux.c queue.c power.c growthRate.c average.c getArray.c fileGestion.c)
+
 find_package(Threads)
 target_link_libraries(exect ${CMAKE_THREAD_LIBS_INIT} m)
 
@@ -18,10 +21,19 @@ add_executable(ctest fileGestion.c getArray.c average.c growthRate.c queue.c sim
 target_link_libraries(ctest ${CMAKE_THREAD_LIBS_INIT} m)
 
 add_test(test_queueCreateEmpty ./ctest queueCreateEmpty)
-add_test(test_queueSetCharLen ./ctest queueSetCharLen)
+add_test(test_queueCreateE ./ctest queueCreateE)
+
+add_test(test_queueSetCharLen ./ctest queueSetCharLen)
+add_test(test_queueGetCharLen ./ctest queueGetCharLen)
+
+add_test(test_queueSetTabChar ./ctest queueSetTabChar)
+add_test(test_queueGetTabChar ./ctest queueGetTabChar)
 
-# add_test(test_queueGetTabChar ./ctest queueGetTabChar)
 add_test(test_queueSetNextE ./ctest queueSetNextE)
 add_test(test_queueGetNextE ./ctest queueGetNextE)
 
-add_test(test_queueGetCharLen ./ctest queueGetCharLen)
+add_test(test_queueAddLastQ ./ctest queueAddLastQ)
+add_test(test_queueRmLastE ./ctest queueRmLastE)
+add_test(test_queueRmFrstE ./ctest queueRmFrstE)
+add_test(test_queueNextDelFrst ./ctest queueNextDelFrst)
+

Code-C/average.c

@@ -9,15 +9,18 @@
  * @param p array with all the values that will be used for the calcul
  * @param averageArray array where results are stocked
  */
-void averageCalculation(long **p, double averageArray[]){
-    for(int i = 1; i < nCol; i++){
+void averageCalculation(long **p, double averageArray[])
+{
+    for (int i = 1; i < nCol; i++)
+    {
         int j = 0;
         averageArray[i] = 0;
-        while(j < nRowRawData){
-            averageArray[i] += p[i][j];
+        while (j < nRowRawData)
+        {
+            averageArray[i - 1] += p[i][j];
             j++;
         }
-        //printf("%f , %f\n", averageArray[i] , averageArray[i] / nRowRawData);
+        // printf("%f , %f\n", averageArray[i] , averageArray[i] / nRowRawData);
         averageArray[i] /= nRowRawData;
     }
 }
@@ -27,19 +30,25 @@ void averageCalculation(long **p, double averageArray[]){
  *
  * @param rawDataFileName name of the raw data file to use to realize the calcul
  */
-void averageFunction(char* rawDataFileName , double **aver){
+void averageFunction(char *rawDataFileName, double **aver)
+{
     long **p = getRawDataArray(rawDataFileName);
-    double averN[nCol -1];
-    if(p !=NULL){
-        if(p !=NULL){
-            if(aver == NULL){
-                averageCalculation(p,averN);
-                appendDataInFile("averageData.csv",averN,nCol-1);
-            }else{
-                averageCalculation(p,aver[1]);
-                appendDataInFile("averageData.csv",aver[1],nCol-1);
+    double averN[nCol - 1];
+    if (p != NULL)
+    {
+        if (p != NULL)
+        {
+            if (aver == NULL)
+            {
+                averageCalculation(p, averN);
+                appendDataInFile("averageData.csv", averN, nCol - 1);
             }
-        freeArray(p,nRowRawData);
-    }
+            else
+            {
+                averageCalculation(p, aver[1]);
+                appendDataInFile("averageData.csv", aver[1], nCol - 1);
+            }
+            freeArray(p, nRowRawData);
+        }
     }
 }

Code-C/ctest.c

@@ -24,7 +24,7 @@ int nbRowBinFile = 900011;
 int nbRowIgnore = 19;
 
 Pqueue firstRawDataQueue;
-// Captor                     1    2    3     4     5     6    7     8
+// Captor                     1      2     3      4      5      6     7      8
 bool selectionCaptors[] = {true, false, true, false, false, false, true, false};
 
 int cptData = 0;
@@ -48,6 +48,22 @@ bool test_queueCreateEmpty()
   return EXIT_SUCCESS;
 }
 
+bool test_queueCreateE()
+{
+  const char tabChar[12] = "PetitNavire\0";
+  Pqueue new = queueCreateE(12, tabChar);
+
+  const char *test = queueGetTabChar(new);
+
+  assert(queueGetCharLen(new) == 12);
+  assert(test != NULL);
+  assert(strcmp(test, tabChar) == 0);
+  assert(queueGetNextE(new) == NULL);
+
+  queueRmFrstE(new);
+  return EXIT_SUCCESS;
+}
+
 bool test_queueSetCharLen()
 {
   Pqueue new = queueCreateEmpty();
@@ -63,20 +79,38 @@ bool test_queueSetCharLen()
   return EXIT_SUCCESS;
 }
 
-bool test_queueGetTabChar()
-{ // Define later
+bool test_queueSetTabChar()
+{
+  // Set and Get tabChar are similar because use for same test
   Pqueue new = queueCreateEmpty();
 
-  // const char tabChar[12] = "PetitNavire\0"
-  queueSetTabChar(new, 13, NULL);
+  const char tabChar[12] = "PetitNavire\0";
+  queueSetTabChar(new, 12, tabChar);
+  const char *test = queueGetTabChar(new);
 
-  assert(queueGetCharLen(new) == 13);
-  assert(queueGetTabChar(new) == NULL);
+  assert(queueGetCharLen(new) == 12);
+  assert(test != NULL);
+  assert(strcmp(test, tabChar) == 0);
   assert(queueGetNextE(new) == NULL);
 
-  // queueDelAll(new);
   queueRmFrstE(new);
+  return EXIT_SUCCESS;
+}
 
+bool test_queueGetTabChar()
+{
+  Pqueue new = queueCreateEmpty();
+
+  const char tabChar[12] = "PetitNavire\0";
+  queueSetTabChar(new, 12, tabChar);
+  const char *test = queueGetTabChar(new);
+
+  assert(queueGetCharLen(new) == 12);
+  assert(test != NULL);
+  assert(strcmp(test, tabChar) == 0);
+  assert(queueGetNextE(new) == NULL);
+
+  queueRmFrstE(new);
   return EXIT_SUCCESS;
 }
 
@@ -120,6 +154,70 @@ bool test_queueGetCharLen()
   return EXIT_SUCCESS;
 }
 
+bool test_queueAddLastQ()
+{
+  Pqueue new = queueCreateEmpty(), next = NULL;
+  const char tabChar[12] = "PetitNavire\0";
+  queueAddLastQ(new, tabChar, 12);
+  next = queueGetNextE(new);
+
+  assert(next != NULL);
+  assert(queueGetCharLen(next) == 12);
+  assert(strcmp(queueGetTabChar(next), tabChar) == 0);
+  assert(queueGetNextE(next) == NULL);
+
+  queueDelAll(new);
+  return EXIT_SUCCESS;
+}
+bool test_queueRmLastE()
+{
+  Pqueue new = queueCreateEmpty();
+  const char tabChar[12] = "PetitNavire\0";
+  queueAddLastQ(new, tabChar, 12);
+  queueAddLastQ(new, tabChar, 12);
+
+  assert(queueGetNextE(new) != NULL && queueGetNextE(queueGetNextE(new)) != NULL && queueGetNextE(queueGetNextE(queueGetNextE(new))) == NULL);
+  queueRmLastE(new);
+  assert(queueGetNextE(new) != NULL && queueGetNextE(queueGetNextE(new)) == NULL);
+
+  queueDelAll(new);
+  return EXIT_SUCCESS;
+}
+
+bool test_queueRmFrstE()
+{
+  Pqueue new = queueCreateEmpty(), second;
+  const char tabChar[12] = "PetitNavire\0";
+  queueAddLastQ(new, tabChar, 12);
+  queueAddLastQ(new, tabChar, 12);
+  second = queueGetNextE(new);
+
+  assert(queueGetNextE(new) != NULL && queueGetNextE(queueGetNextE(new)) != NULL && queueGetNextE(queueGetNextE(queueGetNextE(new))) == NULL);
+  new = queueRmFrstE(new);
+  assert((new == second) && (queueGetNextE(new) != NULL) && (queueGetNextE(queueGetNextE(new)) == NULL));
+
+  queueDelAll(new);
+  return EXIT_SUCCESS;
+}
+
+bool test_queueNextDelFrst()
+{
+  Pqueue new = queueCreateEmpty(), second;
+  const char tabChar[12] = "PetitNavire\0";
+  queueAddLastQ(new, tabChar, 12);
+  queueAddLastQ(new, tabChar, 12);
+  second = queueGetNextE(new);
+
+  assert(queueGetNextE(new) != NULL && queueGetNextE(queueGetNextE(new)) != NULL && queueGetNextE(queueGetNextE(queueGetNextE(new))) == NULL);
+  new = queueNextDelFrst(new);
+  assert((new == second) && (queueGetNextE(new) != NULL) && (queueGetNextE(queueGetNextE(new)) == NULL));
+
+  queueDelAll(new);
+  return EXIT_SUCCESS;
+}
+
+/***************** Main test start *****************/
+
 void usage(int argc, char *argv[])
 {
   fprintf(stderr, "Usage: %s <testname> [<...>]\n", argv[0]);
@@ -135,7 +233,13 @@ int main(int argc, char *argv[])
   fprintf(stderr, "=> Start test \"%s\"\n", argv[1]);
   int ok = 1;
   if (strcmp("queueCreateEmpty", argv[1]) == 0)
+  {
     ok = test_queueCreateEmpty();
+  }
+  else if (strcmp("queueCreateE", argv[1]) == 0)
+  {
+    ok = test_queueCreateE();
+  }
   else if (strcmp("queueSetCharLen", argv[1]) == 0)
   {
     ok = test_queueSetCharLen();
@@ -159,8 +263,28 @@ int main(int argc, char *argv[])
   else if (strcmp("queueGetTabChar", argv[1]) == 0)
   {
     ok = test_queueGetTabChar();
-    // }else if(strcmp("update_flags",argv[1]) == 0){
-    //   ok = test_game_update_flags();
+  }
+  else if (strcmp("queueSetTabChar", argv[1]) == 0)
+  {
+    ok = test_queueSetTabChar();
+  }
+  else if (strcmp("queueAddLastQ", argv[1]) == 0)
+  {
+    ok = test_queueAddLastQ();
+  }
+  else if (strcmp("queueRmLastE", argv[1]) == 0)
+  {
+    ok = test_queueRmLastE();
+  }
+  else if (strcmp("queueRmFrstE", argv[1]) == 0)
+  {
+    ok = test_queueRmFrstE();
+  }
+  else if (strcmp("queueNextDelFrst", argv[1]) == 0)
+  {
+    ok = test_queueNextDelFrst();
+    // }else if(strcmp("default_solution",argv[1]) == 0){
+    //   ok = test_game_default_solution();
     // }else if(strcmp("default_solution",argv[1]) == 0){
     //   ok = test_game_default_solution();
   }

Code-C/main.c

@@ -49,6 +49,7 @@ void *threadCalculAverage(void *vargp)
 {
     Pqueue rawDataQueue = firstRawDataQueue;
     char *fileName;
+
     while (rawDataWriteFlag)
     {
         while (queueGetNextE(rawDataQueue) != NULL)
@@ -124,7 +125,7 @@ void *threadCalculGrowthRate(void *vargp)
                 growthRateFunction(dataLignPw, "growthRatePw.csv");
                 growthRateFunction(dataLignPw, "growthRateAv.csv");
             }
-            remove(fileName);
+            // remove(fileName);
         }
     }
     return NULL;
@@ -150,12 +151,23 @@ int main(int argc, char **argv)
     pthread_t rawData;
     if (pthread_create(&rawData, NULL, threadSimulateFlux, "threadSimulflux") != 0)
     {
-        perror("pthread_create() error");
+        perror("threadSimulflux() error");
         exit(1);
     }
 
-    pthread_t calcul;
-    pthread_create(&calcul, NULL, threadCalculGrowthRate, "threadCalcul");
+    // pthread_t calculAverage;
+    // if (pthread_create(&calculAverage, NULL, threadCalculAverage, "threadCalculAverage"))
+    // {
+    //     perror("threadCalculAverage() error");
+    //     exit(1);
+    // }
+
+    pthread_t calculGrowthRate;
+    if (pthread_create(&calculGrowthRate, NULL, threadCalculGrowthRate, "threadCalculGrowthRate"))
+    {
+        perror("threadcalculGrowthRate() error");
+        exit(1);
+    }
 
     pthread_exit(NULL);
 }

Code-C/power.c

@@ -37,7 +37,7 @@ void powerCalculation(long **p, double powerArray[])
 void powerFunction(char *rawDataFileName, double **pw)
 {
     long **p = getRawDataArray(rawDataFileName);
-    printArrayData(p, nRowRawData, nCol);
+    // printArrayData(p, nRowRawData, nCol);
     double pww[nCol - 1];
     if (p != NULL)
     {

Code-C/queue.c

@@ -2,6 +2,7 @@
 #include <stdio.h>
 #include <stdlib.h>
 #include <string.h>
+#include <stdbool.h>
 #include "queue.h"
 
 /**
@@ -144,15 +145,15 @@ Pqueue queueCreateE(int lenChar, const char *_tabChar)
 Pqueue queueRmLastE(Pqueue elem)
 {
     assert(elem);
-    Pqueue tmp = elem, previous = NULL;
-    while (elem->pNextE != NULL)
+    Pqueue tmp = elem, current = NULL;
+    while (tmp->pNextE != NULL)
     {
-        previous = tmp;
+        current = tmp;
         tmp = queueGetNextE(tmp);
     }
     free(tmp->tabChar);
     free(tmp);
-    previous->pNextE = NULL;
+    current->pNextE = NULL;
     return elem;
 }
 
@@ -160,15 +161,18 @@ Pqueue queueRmLastE(Pqueue elem)
  * @brief remove and free the first element of queue
  *
  * @param elem target to remove (the element need to be the first)
+ * @return next element of the queue
  */
-void queueRmFrstE(Pqueue elem)
+Pqueue queueRmFrstE(Pqueue elem)
 {
     assert(elem);
+    Pqueue next = queueGetNextE(elem);
     if (elem->tabChar != NULL)
     {
         free(elem->tabChar);
     }
     free(elem);
+    return next;
 }
 
 /**
@@ -195,16 +199,31 @@ Pqueue queueNextDelFrst(Pqueue elem)
 void queueAddLastQ(Pqueue elem, const char *str, int len)
 {
     assert(elem);
-    assert(str);
-    Pqueue next = elem, previous = NULL;
-    while (next->pNextE != NULL)
+    bool str1 = true;
+    if (len == 0)
     {
-        previous = next;
-        next = queueGetNextE(next);
+        str = false;
     }
-    previous = next;
-    next = queueCreateE(len, str);
-    queueSetNextE(previous, next);
+    else
+    {
+        assert(str);
+    }
+
+    Pqueue current = elem, next = NULL;
+    while (current->pNextE != NULL)
+    {
+        current = queueGetNextE(current);
+    }
+
+    if (str1 == true)
+    {
+        next = queueCreateE(len, str);
+    }
+    else
+    {
+        next = queueCreateEmpty();
+    }
+    queueSetNextE(current, next);
 }
 
 /**

Code-C/queue.h

@@ -91,8 +91,9 @@ Pqueue queueRmLastE(Pqueue elem);
  * @brief remove and free the first element of queue
  *
  * @param elem target to remove (the element need to be the first)
+ * @return the next element of elem
  */
-void queueRmFrstE(Pqueue elem);
+Pqueue queueRmFrstE(Pqueue elem); // same of queueNextDelFrst()
 
 /**
  * @brief delete the first value and return the next value
@@ -100,7 +101,7 @@ void queueRmFrstE(Pqueue elem);
  * @param elem
  * @return Pqueue
  */
-Pqueue queueNextDelFrst(Pqueue elem);
+Pqueue queueNextDelFrst(Pqueue elem); // same of queueRmFrstE()
 
 /************** print function **************/
 

Code-C/simulateFlux.c

@@ -1,9 +1,9 @@
 #include "simulateFlux.h"
 #include "initialParameters.h"
 #include "queue.h"
-//#include <linux/time.h>
 
-#include "time.h"
+#include <time.h>
+#include <errno.h>
 
 /**
  * @brief convert an interger N into a char*
@@ -46,7 +46,7 @@ char *convertIntegerToChar(int N)
  */
 char *createNewRawDataFileName()
 {
-    char *fileName = "../RawDataFiles/RawData";
+    char *fileName = "RawDataFiles/RawData";
     char *extension = ".csv\0";
     char *fileNumber = convertIntegerToChar(cptFile);
     // char *fileNumber;
@@ -94,7 +94,7 @@ int64_t millis()
 {
     struct timespec now;
     timespec_get(&now, TIME_UTC);
-    return ((int64_t)now.tv_sec) * 1000 + ((int64_t)now.tv_nsec) / 1000000;
+    return ((int64_t)((int64_t)now.tv_sec) * 1000 + ((int64_t)now.tv_nsec) / 1000000);
 }
 
 int lastIndexCaptor()
@@ -133,6 +133,7 @@ bool writeOneRawData(FILE *rawDataFile)
             fprintf(timeFile, "%ld\n", millis());
             fclose(timeFile);
             fprintf(rawDataFile, "%ld,", millis());
+
             if (strncmp(buff, "#################\n", (size_t)18) == 0)
             {
                 if (!(fread(&buff2, 18, 1, stdin)))
@@ -174,7 +175,12 @@ bool writeOneRawData(FILE *rawDataFile)
                 }
             }
             cptData++;
-            // sleep(0.004); //simul freq here
+
+            // simul freq here
+            // struct timespec ts;
+            // ts.tv_sec = 0;
+            // ts.tv_nsec = 4 * 1000000;
+            // nanosleep(&ts, &ts);
 
             cptValue++;
             return true;
@@ -195,6 +201,7 @@ void *threadSimulateFlux(void *vargp)
 
     while (writeOneRawData(rawDataFile))
     {
+
         if (cptData == nRowRawData)
         {
             fclose(rawDataFile);