Implement verarbeitung

[FiratSusan]

Implement verarbeitung.c

This file shall implement function to process incoming data from the Datenerfasser and passes the proccesed data to the Datenversender (Look comment below for example sequence diagram)

Example code how it could look like:

while(1){
 if(!running && IG_QUEUE_isEmpty())
  break;
 checkForNewDataInQueue();
 if(newData!=null)
  applyRules();
 checkIntervalls();
}

checkIntervalls(){
 for(rules){
  if(nowToSend){
   encodeToJSON();
   appendToQueue();
  }
 }
}

Special Cases:
If you want to stop the entire system, first the Datenerfasser has to stop collecting data, after that the loop will still run until the last item in the queue is processed, then the loop will break.

Create an verarbeitung.h which defines the functions and structs like:

1. Struct to apply rules, specialy for each Input Typ, with the fields:

• Function type
• Output-ID
• Function pointer
• deadline for publish
• publish interval
• void* to store internal information

2. A struct which acts as a super struct for the Input rules, with the fields

• Input-ID
• Datatype
• List for the rules (structs)

Example:

typedef void (*inputFunction)(void*);

typedef struct{
 IG_STRING functiontype,
 IG_INT outputId,
 InputFunction function,
 /*...*/
} inputRule;

[FiratSusan]