Change the handling of closing sockets

runtime/bin/eventhandler_win.h

 // Copyright (c) 2011, 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_
 
 #include <winsock2.h>
 #include <mswsock.h>
 
@@ skipping 257 matching lines @@
   ClientSocket* accepted_head_;
   ClientSocket* accepted_tail_;
 };
 
 
 // Information on connected sockets.
 class ClientSocket : public SocketHandle {
  public:
   explicit ClientSocket(SOCKET s)
       : SocketHandle(s),
-        next_(NULL) { type_ = kClientSocket; }
+        next_(NULL),
+        flags_(0) { type_ = kClientSocket; }
 
   ClientSocket(SOCKET s, Dart_Port port)
       : SocketHandle(s, port),
-        next_(NULL) { type_ = kClientSocket; }
+        next_(NULL),
+        flags_(0) { type_ = kClientSocket; }
 
   virtual ~ClientSocket() {
     // Don't delete this object until all pending requests have been handled.
     ASSERT(!HasPendingRead());
     ASSERT(!HasPendingWrite());
     ASSERT(next_ == NULL);
   };
 
+  void Shutdown(int how);
+  bool IsClosedRead() { return (flags_ & (1 << kCloseRead)) != 0; }
+  bool IsClosedWrite() { return (flags_ & (1 << kCloseWrite)) != 0; }
+
+  void MarkClosedRead() { flags_ |= (1 << kCloseRead); }
+  void MarkClosedWrite() { flags_ |= (1 << kCloseWrite); }
+
   // Internal interface used by the event handler.
   virtual bool IssueRead();
   virtual bool IssueWrite();
 
   virtual void EnsureInitialized(
     EventHandlerImplementation* event_handler);
   virtual bool IsClosed();
 
   ClientSocket* next() { return next_; }
   void set_next(ClientSocket* next) { next_ = next; }
 
  private:
+  enum Flags {
+    kCloseRead = 0,
+    kCloseWrite = 1
+  };
+
   virtual void AfterClose();
 
   ClientSocket* next_;
+  int flags_;
 };
 
 
 // Event handler.
 class EventHandlerImplementation {
  public:
   EventHandlerImplementation();
   virtual ~EventHandlerImplementation() {}
 
   void SendData(intptr_t id, Dart_Port dart_port, intptr_t data);
@@ skipping 14 matching lines @@
  private:
   ClientSocket* client_sockets_head_;
 
   int64_t timeout_;  // Time for next timeout.
   Dart_Port timeout_port_;
   HANDLE completion_port_;
 };
 
 
 #endif  // BIN_EVENTHANDLER_WIN_H_