deglobalized parser.cc locks

1 files changed, 15 insertions, 0 deletions

diff --git a/vowpalwabbit/parse_primitives.h b/vowpalwabbit/parse_primitives.h
index 3ca65db0..3054cc4e 100644
--- a/vowpalwabbit/parse_primitives.h
+++ b/vowpalwabbit/parse_primitives.h
@@ -13,6 +13,15 @@ license as described in the file LICENSE.
 #include "io.h"
 #include "example.h"
 
+#ifndef _WIN32
+typedef pthread_mutex_t MUTEX;
+typedef pthread_cond_t CV;
+#else
+#include <Windows.h>
+typedef CRITICAL_SECTION MUTEX;
+typedef CONDITION_VARIABLE CV;
+#endif
+
 struct substring {
   char *begin;
   char *end;
@@ -76,6 +85,12 @@ struct parser {
   uint64_t local_example_number; 
   example* examples;
   uint64_t used_index;
+  MUTEX examples_lock;
+  CV example_available;
+  CV example_unused;
+  MUTEX output_lock;
+  CV output_done;
+
   bool done;
   v_array<size_t> gram_mask;