aboutsummaryrefslogtreecommitdiff
path: root/broccoli/src/midbropasad.c
diff options
context:
space:
mode:
Diffstat (limited to 'broccoli/src/midbropasad.c')
-rw-r--r--broccoli/src/midbropasad.c12
1 files changed, 6 insertions, 6 deletions
diff --git a/broccoli/src/midbropasad.c b/broccoli/src/midbropasad.c
index cc93e7f..a745091 100644
--- a/broccoli/src/midbropasad.c
+++ b/broccoli/src/midbropasad.c
@@ -6,7 +6,7 @@
#include <broccoli.h>
#endif
-Fifo_q * q;
+Fifo_q * queue;
void
request_n_values(int number, int arrayOfValues[])
@@ -14,7 +14,7 @@ request_n_values(int number, int arrayOfValues[])
int i;
Sensor_t * sensor;
for(i=0; i<number; ++i){
- sensor = pop_from_queue(q);
+ sensor = pop_from_queue(queue);
arrayOfValues[i] = sensor->value;
free(sensor);
}
@@ -25,7 +25,7 @@ request_value()
{
int value;
Sensor_t * sensor;
- sensor = pop_from_queue(q);
+ sensor = pop_from_queue(queue);
value = sensor->value;
free(sensor);
printf("Release 1 sensor data value\n");
@@ -35,11 +35,11 @@ request_value()
void
start_data_capture()
{
-
- q = init_queue(50);
int res;
+ queue = init_queue(500000); /* Initiate queue with fixed size */
pthread_t event_listener;
- res = pthread_create(&event_listener, NULL, bro_event_listener, q);
+ /* Create producer thread that listen for bro events */
+ res = pthread_create(&event_listener, NULL, bro_event_listener, queue);
if(res){
perror("Unable to create thread");
exit(-1);