diff options
author | Andreas Lindhé <andreas@lindhe.io> | 2017-10-31 08:33:46 +0100 |
---|---|---|
committer | Andreas Lindhé <andreas@lindhe.io> | 2017-10-31 08:41:40 +0100 |
commit | bc5ecd6da7f068a12b9ee5397178723481c7a3ea (patch) | |
tree | 6ac5bb33df7c3aacde8eb254c4aee1ce1df9dd29 /broccoli/src/midbro.c | |
parent | 2d5d5be5702867a7a719312a5a148489c3b68f31 (diff) | |
download | midbro-bc5ecd6da7f068a12b9ee5397178723481c7a3ea.tar.gz midbro-bc5ecd6da7f068a12b9ee5397178723481c7a3ea.tar.bz2 |
Move all files one level down
Diffstat (limited to 'broccoli/src/midbro.c')
-rw-r--r-- | broccoli/src/midbro.c | 74 |
1 files changed, 0 insertions, 74 deletions
diff --git a/broccoli/src/midbro.c b/broccoli/src/midbro.c deleted file mode 100644 index e2f9644..0000000 --- a/broccoli/src/midbro.c +++ /dev/null @@ -1,74 +0,0 @@ -#include <pthread.h> -#include <unistd.h> -#include <signal.h> -#include "fifoqueue.h" -#include "broevent.h" -#include "midbro.h" -#ifdef BROCCOLI -#include <broccoli.h> -#endif - -Fifo_q * queue; -pthread_t event_listener; -sigset_t signal_set; - - void -sigint_handler(int signal) -{ - printf("\nStatistics:\n" - "Total values received: %d\n" - "Total values dropped: %d\n" - "Total values released: %d\n" - "Maximum buffer utilization: %d\n" - "Buffer fixed size: %d\n" - "Buffer size upon termination: %d\n", - queue->valuesReceived, queue->droppedValues, - queue->valuesReleased, queue->largestBufferSize, - queue->maxSize, queue->currentSize); - exit(0); -} - void -request_n_values(int number, int arrayOfValues[]) -{ - int i; - Sensor_t * sensor; - for(i=0; i<number; ++i){ - sensor = pop_from_queue(queue); - arrayOfValues[i] = sensor->value; - free(sensor); - } - printf("Release %d sensor data values\n", number); -} - int -request_value() -{ - int value; - Sensor_t * sensor; - sensor = pop_from_queue(queue); - value = sensor->value; - free(sensor); - printf("Release 1 sensor data value\n"); - return value; -} - - void -start_data_capture() -{ - int res; - queue = init_queue(500); /* Initiate queue with fixed size */ - /* Create producer thread that listen for bro events */ - sigemptyset(&signal_set); - sigaddset(&signal_set, SIGINT); - res = pthread_sigmask(SIG_BLOCK, &signal_set, NULL); - if(res != 0) - perror("SIGINT block"); - res = pthread_create(&event_listener, NULL, bro_event_listener, queue); - if(res){ - perror("Unable to create thread"); - exit(-1); - } - res = pthread_sigmask(SIG_UNBLOCK, &signal_set, NULL); - if(res != 0) - perror("SIGINT unblock"); - signal(SIGINT, sigint_handler); -} |