aboutsummaryrefslogtreecommitdiff
path: root/src/main/extractor_ipc_gnu.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/extractor_ipc_gnu.c')
-rw-r--r--src/main/extractor_ipc_gnu.c7
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))