Reapply "Fixes to eventhandler and HTTP""

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
@@ skipping 141 matching lines @@
   virtual bool IssueRead();
   virtual bool IssueWrite();
   bool HasPendingRead();
   bool HasPendingWrite();
   void ReadComplete(IOBuffer* buffer);
   void WriteComplete(IOBuffer* buffer);
 
   bool IsClosing() { return (flags_ & (1 << kClosing)) != 0; }
   bool IsClosedRead() { return (flags_ & (1 << kCloseRead)) != 0; }
   bool IsClosedWrite() { return (flags_ & (1 << kCloseWrite)) != 0; }
+  bool IsError() { return (flags_ & (1 << kError)) != 0; }
   void MarkClosing() { flags_ |= (1 << kClosing); }
   void MarkClosedRead() { flags_ |= (1 << kCloseRead); }
   void MarkClosedWrite() { flags_ |= (1 << kCloseWrite); }
+  void MarkError() { flags_ |= (1 << kError); }
 
   virtual void EnsureInitialized(
     EventHandlerImplementation* event_handler) = 0;
 
   HANDLE handle() { return handle_; }
   Dart_Port port() { return port_; }
   EventHandlerImplementation* event_handler() { return event_handler_; }
 
   void Lock();
   void Unlock();
 
   bool CreateCompletionPort(HANDLE completion_port);
 
   void close();
   virtual bool IsClosed() = 0;
 
   void SetPortAndMask(Dart_Port port, intptr_t mask) {
     port_ = port;
     mask_ = mask;
   }
   Type type() { return type_; }
   bool is_file() { return type_ == kFile; }
   bool is_socket() { return type_ == kListenSocket || type_ == kClientSocket; }
   bool is_listen_socket() { return type_ == kListenSocket; }
   bool is_client_socket() { return type_ == kClientSocket; }
+  void set_mask(intptr_t mask) { mask_ = mask; }
   intptr_t mask() { return mask_; }
 
   void MarkDoesNotSupportOverlappedIO() {
     flags_ |= (1 << kDoesNotSupportOverlappedIO);
   }
   bool SupportsOverlappedIO() {
     return (flags_ & (1 << kDoesNotSupportOverlappedIO)) == 0;
   }
 
   void ReadSyncCompleteAsync();
 
   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
+    kDoesNotSupportOverlappedIO = 3,
+    kError = 4
   };
 
   explicit Handle(HANDLE handle);
   Handle(HANDLE handle, Dart_Port port);
 
   virtual void AfterClose() = 0;
 
   Type type_;
   HANDLE handle_;
   Dart_Port port_;  // Dart port to communicate events for this socket.
@@ skipping 149 matching lines @@
   ClientSocket* client_sockets_head_;
 
   int64_t timeout_;  // Time for next timeout.
   Dart_Port timeout_port_;
   bool shutdown_;
   HANDLE completion_port_;
 };
 
 
 #endif  // BIN_EVENTHANDLER_WIN_H_