diff options
Diffstat (limited to 'src/main/extractor_ipc_gnu.c')
-rw-r--r-- | src/main/extractor_ipc_gnu.c | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/src/main/extractor_ipc_gnu.c b/src/main/extractor_ipc_gnu.c index 6ef6013..34a9699 100644 --- a/src/main/extractor_ipc_gnu.c +++ b/src/main/extractor_ipc_gnu.c | |||
@@ -236,6 +236,7 @@ EXTRACTOR_IPC_shared_memory_set_ (struct EXTRACTOR_SharedMemory *shm, | |||
236 | size); | 236 | size); |
237 | } | 237 | } |
238 | 238 | ||
239 | |||
239 | /** | 240 | /** |
240 | * Query datasource for current position | 241 | * Query datasource for current position |
241 | * | 242 | * |
@@ -251,6 +252,7 @@ EXTRACTOR_datasource_get_pos_ (struct EXTRACTOR_Datasource *ds) | |||
251 | return pos; | 252 | return pos; |
252 | } | 253 | } |
253 | 254 | ||
255 | |||
254 | /** | 256 | /** |
255 | * Create a channel to communicate with a process wrapping | 257 | * Create a channel to communicate with a process wrapping |
256 | * the plugin of the given name. Starts the process as well. | 258 | * the plugin of the given name. Starts the process as well. |
@@ -440,7 +442,10 @@ EXTRACTOR_IPC_channel_recv_ (struct EXTRACTOR_Channel **channels, | |||
440 | max = channel->cpipe_out; | 442 | max = channel->cpipe_out; |
441 | } | 443 | } |
442 | if (-1 == max) | 444 | if (-1 == max) |
443 | return 1; /* nothing left to do! */ | 445 | { |
446 | LOG ("No channels to select on...\n"); | ||
447 | return 1; /* nothing left to do! */ | ||
448 | } | ||
444 | tv.tv_sec = 10; | 449 | tv.tv_sec = 10; |
445 | tv.tv_usec = 0; | 450 | tv.tv_usec = 0; |
446 | if (-1 == select (max + 1, &to_check, NULL, NULL, &tv)) | 451 | if (-1 == select (max + 1, &to_check, NULL, NULL, &tv)) |