6 files changed, 7 insertions, 103 deletions

diff --git a/src/main/extractor.c b/src/main/extractor.c
index 09a99e9..830eac8 100644
--- a/src/main/extractor.c
+++ b/src/main/extractor.c
@@ -35,7 +35,7 @@
 /**
  * Size used for the shared memory segment.
  */
-#define DEFAULT_SHM_SIZE (160 * 1024)
+#define DEFAULT_SHM_SIZE (16 * 1024)
 
 
 /**
@@ -382,8 +382,6 @@ do_extract (struct EXTRACTOR_PluginList *plugins,
   ssize_t ready;
   int done;
   int have_in_memory;
-  
-  LOG ("Stating !\n");
 
   plugin_count = 0;
   for (pos = plugins; NULL != pos; pos = pos->next)
@@ -403,7 +401,6 @@ do_extract (struct EXTRACTOR_PluginList *plugins,
   start.reserved2 = 0;
   start.shm_ready_bytes = (uint32_t) ready;
   start.file_size = EXTRACTOR_datasource_get_size_ (ds, 0);
-  LOG ("Have  %d\ !\n",plugin_count);
   for (pos = plugins; NULL != pos; pos = pos->next)
     {
       if (EXTRACTOR_OPTION_IN_PROCESS == pos->flags)
@@ -427,7 +424,6 @@ do_extract (struct EXTRACTOR_PluginList *plugins,
     done = 0;
   while (! done)
     {
-        //LOG ("In !done while\n");
       struct EXTRACTOR_Channel *channels[plugin_count];
 
       /* calculate current 'channels' array */
@@ -437,18 +433,15 @@ do_extract (struct EXTRACTOR_PluginList *plugins,
           if (-1 == pos->seek_request)
             {
               /* channel is not seeking, must be running or done */
-                  //LOG ("No seeking, done\n");
               channels[plugin_off] = pos->channel;
             }
           else
             {
               /* not running this round, seeking! */
-                  //LOG ("Nor running, seeking\n");
               channels[plugin_off] = NULL; 
             }
           plugin_off++;
         }
-                //LOG ("Will call EXTRACTOR_IPC_channel_recv_\n");
       /* give plugins chance to send us meta data, seek or finished messages */
       if (-1 == 
           EXTRACTOR_IPC_channel_recv_ (channels,
@@ -457,7 +450,7 @@ do_extract (struct EXTRACTOR_PluginList *plugins,
                                        &prp))
         {
           /* serious problem in IPC; reset *all* channels */
-          //LOG ("Failed to receive message from channels; full reset\n");
+          LOG ("Failed to receive message from channels; full reset\n");
           abort_all_channels (plugins);
           break;
         }
@@ -470,14 +463,10 @@ do_extract (struct EXTRACTOR_PluginList *plugins,
         {
           plugin_off++;
           if ( (1 == pos->round_finished) ||
-               (NULL == pos->channel) ){
-                   //LOG ("Inative plugin\n"); 
+               (NULL == pos->channel) )
             continue; /* inactive plugin */
-                
-                }
           if (-1 == pos->seek_request)
             {
-                 //LOG ("pos->seek_request\n"); 
               /* possibly more meta data at current position, at least 
                  this plugin is still working on it... */
               done = 0; 
diff --git a/src/main/extractor_ipc_gnu.c b/src/main/extractor_ipc_gnu.c
index c39e08b..313120f 100644
--- a/src/main/extractor_ipc_gnu.c
+++ b/src/main/extractor_ipc_gnu.c
@@ -464,7 +464,7 @@ EXTRACTOR_IPC_channel_recv_ (struct EXTRACTOR_Channel **channels,
       return 1; /* nothing left to do! */
     }
   tv.tv_sec = 0;
-  tv.tv_usec = 5000000; /* 500 ms */
+  tv.tv_usec = 500000; /* 500 ms */
   if (0 >= select (max + 1, &to_check, NULL, NULL, &tv))
     {
       /* an error or timeout -> something's wrong or all plugins hung up */
diff --git a/src/main/extractor_ipc_w32.c b/src/main/extractor_ipc_w32.c
index 600dbdd..c4b8284 100644
--- a/src/main/extractor_ipc_w32.c
+++ b/src/main/extractor_ipc_w32.c
@@ -725,17 +725,12 @@ EXTRACTOR_IPC_channel_recv_ (struct EXTRACTOR_Channel **channels,
   if (c == 0)
     return 1; /* nothing left to do! */
 
-  ms = 1000000;
+  ms = 10000;
   first_ready = WaitForMultipleObjects (c, events, FALSE, ms);
   if (first_ready == WAIT_TIMEOUT || first_ready == WAIT_FAILED)
   {
     /* an error or timeout -> something's wrong or all plugins hung up */
     LOG_STRERROR ("WaitForMultipleObjects");
-                                                                FILE *f;
-        f = fopen("debug.txt", "a+");
-    fprintf(f, "WaitForMultipleObjects \n");
-        fclose(f);
-        
     return -1;
   }
 
@@ -754,10 +749,6 @@ EXTRACTOR_IPC_channel_recv_ (struct EXTRACTOR_Channel **channels,
           if (MAX_META_DATA == channels[i]->mdata_size)
             {
               LOG ("Inbound message from channel too large, aborting\n");
-                                                                                FILE *f;
-        f = fopen("debug.txt", "a+");
-    fprintf(f, "Inbound message from channel too large, aborting \n");
-        fclose(f);
               EXTRACTOR_IPC_channel_destroy_ (channels[i]);
               channels[i] = NULL;
             }
@@ -770,11 +761,6 @@ EXTRACTOR_IPC_channel_recv_ (struct EXTRACTOR_Channel **channels,
               LOG_STRERROR ("realloc");
               EXTRACTOR_IPC_channel_destroy_ (channels[i]);
               channels[i] = NULL;
-                  
-                                                                                                FILE *f;
-        f = fopen("debug.txt", "a+");
-    fprintf(f, "Realloc \n");
-        fclose(f);
             }
           channels[i]->mdata = ndata;
         }
diff --git a/src/main/extractor_logging.h b/src/main/extractor_logging.h
index 54a6564..bf7a964 100644
--- a/src/main/extractor_logging.h
+++ b/src/main/extractor_logging.h
@@ -25,7 +25,7 @@
 #ifndef EXTRACTOR_LOGGING_H
 #define EXTRACTOR_LOGGING_H
 
-#define DEBUG 1
+#define DEBUG 0
 
 #if DEBUG
 
diff --git a/src/main/extractor_plugin_main.c b/src/main/extractor_plugin_main.c
index 4f6c77c..c56dfab 100644
--- a/src/main/extractor_plugin_main.c
+++ b/src/main/extractor_plugin_main.c
@@ -460,7 +460,6 @@ handle_start_message (struct ProcessingContext *pc)
       LOG ("Failed to read 'start' message\n");
       return -1;
     }
-         fprintf (stderr,            "Got start msg\n");
   pc->shm_ready_bytes = start.shm_ready_bytes;
   pc->file_size = start.file_size;
   pc->read_position = 0;
@@ -476,10 +475,6 @@ handle_start_message (struct ProcessingContext *pc)
   if (-1 == EXTRACTOR_write_all_ (pc->out, &done, sizeof (done)))
     {
       LOG ("Failed to write 'done' message\n");
-                        FILE *f;
-        f = fopen("debug.txt", "a+");
-    fprintf(f, "Failed to write 'done' message' \n");
-        fclose(f);
       return -1;
     }
   if ( (NULL != pc->plugin->specials) &&
@@ -529,33 +524,18 @@ process_requests (struct ProcessingContext *pc)
           if (0 != handle_start_message (pc))
             {
               LOG ("Failure to handle START\n");
-                                        FILE *f;
-        f = fopen("debug.txt", "a+");
-    fprintf(f, "Failure to handle START' \n");
-        fclose(f);
               return;
             }
           break;
-        case MESSAGE_UPDATED_SHM:{
+        case MESSAGE_UPDATED_SHM:
           LOG ("Illegal message\n");
           /* not allowed here, we're not waiting for SHM to move! */
-                                                FILE *f;
-        f = fopen("debug.txt", "a+");
-    fprintf(f, "Illegal message' \n");
-        fclose(f);
-        
           return;
-          }
         case MESSAGE_DISCARD_STATE:
           /* odd, we're already in the start state... */
           continue;
         default:
           LOG ("Received invalid messag %d\n", (int) code);
-                                                        FILE *f;
-        f = fopen("debug.txt", "a+");
-    fprintf(f, "Received invalid messag' \n");
-        fclose(f);
-        
           /* error, unexpected message */
           return;
         }
@@ -645,14 +625,6 @@ EXTRACTOR_plugin_main_ (struct EXTRACTOR_PluginList *plugin,
   process_requests (&pc);
   LOG ("IPC error; plugin `%s' terminates!\n",
        plugin->short_libname);
-           
-
-                        FILE *f;
-        f = fopen("debug.txt", "a+");
-    fprintf(f, "IPC error; plugin `%s' terminates!\n",
-       plugin->short_libname);
-        fclose(f);
-        
 #if WINDOWS
   if (NULL != pc.shm)
     UnmapViewOfFile (pc.shm);
diff --git a/src/main/extractor_plugins.c b/src/main/extractor_plugins.c
index 444c051..290d511 100644
--- a/src/main/extractor_plugins.c
+++ b/src/main/extractor_plugins.c
@@ -120,14 +120,6 @@ get_symbol_with_prefix (void *lib_handle,
 int
 EXTRACTOR_plugin_load_ (struct EXTRACTOR_PluginList *plugin)
 {
-
-LOG ("In EXTRACTOR_plugin_load_");
-
-        FILE *f;
-        f = fopen("debug.txt", "a+");
-    fprintf(f, "EXTRACTOR_plugin_load_\n");
-        fclose(f);
-
 #if WINDOWS
   wchar_t wlibname[4097];
   char llibname[4097];
@@ -145,11 +137,6 @@ LOG ("In EXTRACTOR_plugin_load_");
       plugin->flags = EXTRACTOR_OPTION_DISABLED;
       return -1;
     }
-        
-        LOG ("Loading plugin `%s' \n",  plugin->short_libname);
-      lt_dlclose (plugin->libraryHandle);
-          
-          
   lt_dladvise_init (&advise);
   lt_dladvise_ext (&advise);
   lt_dladvise_local (&advise);
@@ -164,11 +151,6 @@ LOG ("In EXTRACTOR_plugin_load_");
       LOG ("Loading `%s' plugin failed: %s\n",
            plugin->short_libname,
            "can't convert plugin name to local encoding");
-                                FILE *f;
-        f = fopen("debug.txt", "a+");
-    fprintf(f, "Loading `%s' plugin failed!\n",
-       plugin->short_libname);
-        fclose(f);
       free (plugin->libname);
       plugin->libname = NULL;
       plugin->flags = EXTRACTOR_OPTION_DISABLED;
@@ -207,15 +189,6 @@ LOG ("In EXTRACTOR_plugin_load_");
       plugin->flags = EXTRACTOR_OPTION_DISABLED;
       return -1;
     }
-        
-        LOG ("Loaded plugin `%s' \n",  plugin->short_libname);
-        
-
-        f = fopen("debug.txt", "a+");
-    fprintf(f, "Loaded plugin `%s' \n",  plugin->short_libname);
-        fclose(f);
-
-        
   return 0;
 }
 
@@ -238,12 +211,6 @@ EXTRACTOR_plugin_add (struct EXTRACTOR_PluginList *prev,
   struct EXTRACTOR_PluginList *plugin;
   struct EXTRACTOR_PluginList *pos;
   char *libname;
-  
-        FILE *f;
-        f = fopen("debug.txt", "a+");
-    fprintf(f, "EXTRACTOR_plugin_add\n");
-        fclose(f);
-        
 
   for (pos = prev; NULL != pos; pos = pos->next)
     if (0 == strcmp (pos->short_libname, library))
@@ -377,9 +344,6 @@ EXTRACTOR_plugin_remove (struct EXTRACTOR_PluginList *prev,
   struct EXTRACTOR_PluginList *pos;
   struct EXTRACTOR_PluginList *first;
 
-
-        
-        
   pos = prev;
   first = prev;
   while ( (NULL != pos) && 
@@ -394,13 +358,6 @@ EXTRACTOR_plugin_remove (struct EXTRACTOR_PluginList *prev,
            library);
       return first;
     }
-        
-                FILE *f;
-        f = fopen("debug.txt", "a+");
-    fprintf(f, "Closoing %s\n",pos->short_libname);
-        fclose(f);
-        
-        
   /* found, close library */
   if (first == pos)
     first = pos->next;