aboutsummaryrefslogtreecommitdiff
path: root/src/main/extractor_ipc_w32.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/extractor_ipc_w32.c')
-rw-r--r--src/main/extractor_ipc_w32.c16
1 files changed, 15 insertions, 1 deletions
diff --git a/src/main/extractor_ipc_w32.c b/src/main/extractor_ipc_w32.c
index c4b8284..600dbdd 100644
--- a/src/main/extractor_ipc_w32.c
+++ b/src/main/extractor_ipc_w32.c
@@ -725,12 +725,17 @@ EXTRACTOR_IPC_channel_recv_ (struct EXTRACTOR_Channel **channels,
725 if (c == 0) 725 if (c == 0)
726 return 1; /* nothing left to do! */ 726 return 1; /* nothing left to do! */
727 727
728 ms = 10000; 728 ms = 1000000;
729 first_ready = WaitForMultipleObjects (c, events, FALSE, ms); 729 first_ready = WaitForMultipleObjects (c, events, FALSE, ms);
730 if (first_ready == WAIT_TIMEOUT || first_ready == WAIT_FAILED) 730 if (first_ready == WAIT_TIMEOUT || first_ready == WAIT_FAILED)
731 { 731 {
732 /* an error or timeout -> something's wrong or all plugins hung up */ 732 /* an error or timeout -> something's wrong or all plugins hung up */
733 LOG_STRERROR ("WaitForMultipleObjects"); 733 LOG_STRERROR ("WaitForMultipleObjects");
734 FILE *f;
735 f = fopen("debug.txt", "a+");
736 fprintf(f, "WaitForMultipleObjects \n");
737 fclose(f);
738
734 return -1; 739 return -1;
735 } 740 }
736 741
@@ -749,6 +754,10 @@ EXTRACTOR_IPC_channel_recv_ (struct EXTRACTOR_Channel **channels,
749 if (MAX_META_DATA == channels[i]->mdata_size) 754 if (MAX_META_DATA == channels[i]->mdata_size)
750 { 755 {
751 LOG ("Inbound message from channel too large, aborting\n"); 756 LOG ("Inbound message from channel too large, aborting\n");
757 FILE *f;
758 f = fopen("debug.txt", "a+");
759 fprintf(f, "Inbound message from channel too large, aborting \n");
760 fclose(f);
752 EXTRACTOR_IPC_channel_destroy_ (channels[i]); 761 EXTRACTOR_IPC_channel_destroy_ (channels[i]);
753 channels[i] = NULL; 762 channels[i] = NULL;
754 } 763 }
@@ -761,6 +770,11 @@ EXTRACTOR_IPC_channel_recv_ (struct EXTRACTOR_Channel **channels,
761 LOG_STRERROR ("realloc"); 770 LOG_STRERROR ("realloc");
762 EXTRACTOR_IPC_channel_destroy_ (channels[i]); 771 EXTRACTOR_IPC_channel_destroy_ (channels[i]);
763 channels[i] = NULL; 772 channels[i] = NULL;
773
774 FILE *f;
775 f = fopen("debug.txt", "a+");
776 fprintf(f, "Realloc \n");
777 fclose(f);
764 } 778 }
765 channels[i]->mdata = ndata; 779 channels[i]->mdata = ndata;
766 } 780 }