AFG/dump1090
3
0
Fork 0
Code Issues Pull requests Packages Projects Releases Wiki Activity

Oops, one unsaved file.

Browse source
This commit is contained in:
Oliver Jowett 2015-01-02 22:34:35 +00:00
parent 07bc762055
commit 85eee61358
1 changed files with 6 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
dump1090.c
View file

@ -331,8 +331,9 @@ void readDataFromFile(void) {
while(toread) { while(toread) {
nread = read(Modes.fd, p, toread); nread = read(Modes.fd, p, toread);
if (nread <= 0) { if (nread <= 0) {
// Done.
Modes.exit = 1; // Signal the other threads to exit. Modes.exit = 1; // Signal the other threads to exit.
break; goto OUT;
} }
p += nread; p += nread;
toread -= nread; toread -= nread;
@ -355,6 +356,9 @@ void readDataFromFile(void) {
// Signal to the other thread that new data is ready // Signal to the other thread that new data is ready
pthread_cond_signal(&Modes.data_cond); pthread_cond_signal(&Modes.data_cond);
} }
OUT:
pthread_mutex_unlock(&Modes.data_mutex);
} }
// //
//========================================================================= //=========================================================================
@ -388,7 +392,7 @@ void *readerThreadEntryPoint(void *arg) {
// Wake the main thread (if it's still waiting) // Wake the main thread (if it's still waiting)
pthread_mutex_lock(&Modes.data_mutex); pthread_mutex_lock(&Modes.data_mutex);
Modes.exit = 1; Modes.exit = 1; // just in case
pthread_cond_signal(&Modes.data_cond); pthread_cond_signal(&Modes.data_cond);
pthread_mutex_unlock(&Modes.data_mutex); pthread_mutex_unlock(&Modes.data_mutex);