Reuse thread when writing stdout/stderr on Windows.

runtime/bin/eventhandler_win.h

 // Copyright (c) 2012, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 #ifndef BIN_EVENTHANDLER_WIN_H_
 #define BIN_EVENTHANDLER_WIN_H_
 
 #if !defined(BIN_EVENTHANDLER_H_)
 #error Do not include eventhandler_win.h directly; use eventhandler.h instead.
 #endif
 
 #include <winsock2.h>
 #include <mswsock.h>
 
 #include "bin/builtin.h"
+#include "platform/thread.h"
 
 
 namespace dart {
 namespace bin {
 
 // Forward declarations.
 class EventHandlerImplementation;
 class Handle;
 class FileHandle;
 class SocketHandle;
@@ skipping 99 matching lines @@
   uint8_t buffer_data_[1];
 };
 
 
 // Abstract super class for holding information on listen and connected
 // sockets.
 class Handle {
  public:
   enum Type {
     kFile,
+    kStd,
     kDirectoryWatch,
     kClientSocket,
     kListenSocket
   };
 
   class ScopedLock {
    public:
     explicit ScopedLock(Handle* handle)
         : handle_(handle) {
       handle_->Lock();
     }
     ~ScopedLock() {
       handle_->Unlock();
     }
 
    private:
     Handle* handle_;
   };
 
   virtual ~Handle();
 
   // Socket interface exposing normal socket operations.
   int Available();
   int Read(void* buffer, int num_bytes);
-  int Write(const void* buffer, int num_bytes);
+  virtual int Write(const void* buffer, int num_bytes);
 
   // Internal interface used by the event handler.
   virtual bool IssueRead();
   virtual bool IssueWrite();
   bool HasPendingRead();
   bool HasPendingWrite();
   void ReadComplete(OverlappedBuffer* buffer);
   void WriteComplete(OverlappedBuffer* buffer);
 
   bool IsClosing() { return (flags_ & (1 << kClosing)) != 0; }
@@ skipping 34 matching lines @@
   intptr_t mask() { return mask_; }
 
   void MarkDoesNotSupportOverlappedIO() {
     flags_ |= (1 << kDoesNotSupportOverlappedIO);
   }
   bool SupportsOverlappedIO() {
     return (flags_ & (1 << kDoesNotSupportOverlappedIO)) == 0;
   }
 
   void ReadSyncCompleteAsync();
-  void WriteSyncCompleteAsync();
 
   DWORD last_error() { return last_error_; }
   void set_last_error(DWORD last_error) { last_error_ = last_error; }
 
  protected:
   enum Flags {
     kClosing = 0,
     kCloseRead = 1,
     kCloseWrite = 2,
     kDoesNotSupportOverlappedIO = 3,
@@ skipping 10 matching lines @@
   Dart_Port port_;  // Dart port to communicate events for this socket.
   intptr_t mask_;  // Mask of events to report through the port.
   HANDLE completion_port_;
   EventHandlerImplementation* event_handler_;
 
   OverlappedBuffer* data_ready_;  // Buffer for data ready to be read.
   OverlappedBuffer* pending_read_;  // Buffer for pending read.
   OverlappedBuffer* pending_write_;  // Buffer for pending write
 
   DWORD last_error_;
-  DWORD thread_wrote_;
 
  private:
   int flags_;
   CRITICAL_SECTION cs_;  // Critical section protecting this object.
 };
 
 
 class FileHandle : public Handle {
  public:
   explicit FileHandle(HANDLE handle)
       : Handle(handle) { type_ = kFile; }
   FileHandle(HANDLE handle, Dart_Port port)
       : Handle(handle, port) { type_ = kFile; }
 
   virtual void EnsureInitialized(EventHandlerImplementation* event_handler);
   virtual bool IsClosed();
-  virtual void DoClose();
 };
 
 
+class StdHandle : public FileHandle {
+ public:
+  explicit StdHandle(HANDLE handle)
+      : FileHandle(handle),
+        thread_wrote_(0),
+        write_thread_exists_(false),
+        write_thread_running_(false),
+        write_monitor_(new Monitor()) {
+    type_ = kStd;
+  }
+
+  ~StdHandle() {
+    delete write_monitor_;
+  }
+
+  virtual void DoClose();
+  virtual int Write(const void* buffer, int num_bytes);
+
+  void WriteSyncCompleteAsync();
+  void RunWriteLoop();
+
+ private:
+  DWORD thread_wrote_;
+  bool write_thread_exists_;
+  bool write_thread_running_;
+  dart::Monitor* write_monitor_;
+};
+
+
 class DirectoryWatchHandle : public Handle {
  public:
   DirectoryWatchHandle(HANDLE handle, int events, bool recursive)
       : Handle(handle),
         events_(events),
         recursive_(recursive) {
     type_ = kDirectoryWatch;
   }
 
   virtual void EnsureInitialized(EventHandlerImplementation* event_handler);
@@ skipping 144 matching lines @@
 
   TimeoutQueue timeout_queue_;  // Time for next timeout.
   bool shutdown_;
   HANDLE completion_port_;
 };
 
 }  // namespace bin
 }  // namespace dart
 
 #endif  // BIN_EVENTHANDLER_WIN_H_