diff options
Diffstat (limited to 'src/main/extractor.c')
-rw-r--r-- | src/main/extractor.c | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/src/main/extractor.c b/src/main/extractor.c index bbe661c..2c69f3f 100644 --- a/src/main/extractor.c +++ b/src/main/extractor.c | |||
@@ -27,6 +27,7 @@ | |||
27 | #include <ltdl.h> | 27 | #include <ltdl.h> |
28 | #include "extractor_datasource.h" | 28 | #include "extractor_datasource.h" |
29 | #include "extractor_ipc.h" | 29 | #include "extractor_ipc.h" |
30 | #include "extractor_logging.h" | ||
30 | #include "extractor_plugpath.h" | 31 | #include "extractor_plugpath.h" |
31 | #include "extractor_plugins.h" | 32 | #include "extractor_plugins.h" |
32 | 33 | ||
@@ -87,6 +88,7 @@ send_update_message (struct EXTRACTOR_PluginList *plugin, | |||
87 | &um, | 88 | &um, |
88 | sizeof (um)) ) | 89 | sizeof (um)) ) |
89 | { | 90 | { |
91 | LOG ("Failed to send UPDATED_SHM message to plugin\n"); | ||
90 | EXTRACTOR_IPC_channel_destroy_ (plugin->channel); | 92 | EXTRACTOR_IPC_channel_destroy_ (plugin->channel); |
91 | plugin->channel = NULL; | 93 | plugin->channel = NULL; |
92 | plugin->round_finished = 1; | 94 | plugin->round_finished = 1; |
@@ -110,6 +112,7 @@ send_discard_message (struct EXTRACTOR_PluginList *plugin) | |||
110 | &disc_msg, | 112 | &disc_msg, |
111 | sizeof (disc_msg)) ) | 113 | sizeof (disc_msg)) ) |
112 | { | 114 | { |
115 | LOG ("Failed to send DISCARD_STATE message to plugin\n"); | ||
113 | EXTRACTOR_IPC_channel_destroy_ (plugin->channel); | 116 | EXTRACTOR_IPC_channel_destroy_ (plugin->channel); |
114 | plugin->channel = NULL; | 117 | plugin->channel = NULL; |
115 | plugin->round_finished = 1; | 118 | plugin->round_finished = 1; |
@@ -182,6 +185,7 @@ process_plugin_reply (void *cls, | |||
182 | &cont_msg, | 185 | &cont_msg, |
183 | sizeof (cont_msg)) ) | 186 | sizeof (cont_msg)) ) |
184 | { | 187 | { |
188 | LOG ("Failed to send CONTINUE_EXTRACTING message to plugin\n"); | ||
185 | EXTRACTOR_IPC_channel_destroy_ (plugin->channel); | 189 | EXTRACTOR_IPC_channel_destroy_ (plugin->channel); |
186 | plugin->channel = NULL; | 190 | plugin->channel = NULL; |
187 | plugin->round_finished = 1; | 191 | plugin->round_finished = 1; |
@@ -240,6 +244,7 @@ do_extract (struct EXTRACTOR_PluginList *plugins, | |||
240 | &start, | 244 | &start, |
241 | sizeof (start)) ) ) | 245 | sizeof (start)) ) ) |
242 | { | 246 | { |
247 | LOG ("Failed to send EXTRACT_START message to plugin\n"); | ||
243 | EXTRACTOR_IPC_channel_destroy_ (pos->channel); | 248 | EXTRACTOR_IPC_channel_destroy_ (pos->channel); |
244 | pos->channel = NULL; | 249 | pos->channel = NULL; |
245 | } | 250 | } |
@@ -265,6 +270,7 @@ do_extract (struct EXTRACTOR_PluginList *plugins, | |||
265 | &prp)) | 270 | &prp)) |
266 | { | 271 | { |
267 | /* serious problem in IPC; reset *all* channels */ | 272 | /* serious problem in IPC; reset *all* channels */ |
273 | LOG ("Failed to receive message from channels; full reset\n"); | ||
268 | abort_all_channels (plugins); | 274 | abort_all_channels (plugins); |
269 | break; | 275 | break; |
270 | } | 276 | } |
@@ -298,6 +304,7 @@ do_extract (struct EXTRACTOR_PluginList *plugins, | |||
298 | min_seek, | 304 | min_seek, |
299 | DEFAULT_SHM_SIZE))) | 305 | DEFAULT_SHM_SIZE))) |
300 | { | 306 | { |
307 | LOG ("Failed to seek; full reset\n"); | ||
301 | abort_all_channels (plugins); | 308 | abort_all_channels (plugins); |
302 | break; | 309 | break; |
303 | } | 310 | } |
@@ -334,6 +341,7 @@ do_extract (struct EXTRACTOR_PluginList *plugins, | |||
334 | { | 341 | { |
335 | if (EXTRACTOR_OPTION_IN_PROCESS != pos->flags) | 342 | if (EXTRACTOR_OPTION_IN_PROCESS != pos->flags) |
336 | continue; | 343 | continue; |
344 | LOG ("In-process plugins not implemented\n"); | ||
337 | // FIXME: initialize read/seek context... | 345 | // FIXME: initialize read/seek context... |
338 | // pos->extract_method (FIXME); | 346 | // pos->extract_method (FIXME); |
339 | } | 347 | } |