diff options
author | Robert Gustafsson <robg@student.chalmers.se> | 2017-10-14 10:29:44 +0200 |
---|---|---|
committer | Robert Gustafsson <robg@student.chalmers.se> | 2017-10-14 10:29:44 +0200 |
commit | 89d12d836a0e34d7d2c55a1f96d947de48933813 (patch) | |
tree | 791502a89410c96732c793acb9fe2274a61cad2d /broccoli/src/midbropasad.c | |
parent | 9dcd19548b57e80726d53ec4f9253f1809a2d04a (diff) | |
download | midbro-89d12d836a0e34d7d2c55a1f96d947de48933813.tar.gz midbro-89d12d836a0e34d7d2c55a1f96d947de48933813.tar.bz2 |
Add define to use policy drop first element
Diffstat (limited to 'broccoli/src/midbropasad.c')
-rw-r--r-- | broccoli/src/midbropasad.c | 12 |
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); |