Keep track of when a socket has been destroyed

runtime/bin/eventhandler_win.cc

 // 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.
 
 #include "platform/globals.h"
 #if defined(TARGET_OS_WINDOWS)
 
 #include "bin/eventhandler.h"
 
 #include <process.h>  // NOLINT
@@ skipping 614 matching lines @@
 }
 
 
 void ClientSocket::DisconnectComplete(IOBuffer* buffer) {
   IOBuffer::DisposeBuffer(buffer);
   closesocket(socket());
   if (data_ready_ != NULL) {
     IOBuffer::DisposeBuffer(data_ready_);
   }
   // When disconnect is complete get rid of the object.
+  Dart_Port port = port();
   delete this;
+  DartUtils::PostInt32(port, 1 << kDestroyedEvent);
 }
 
 
 void ClientSocket::EnsureInitialized(
     EventHandlerImplementation* event_handler) {
   ScopedLock lock(this);
   if (completion_port_ == INVALID_HANDLE_VALUE) {
     ASSERT(event_handler_ == NULL);
     event_handler_ = event_handler;
     CreateCompletionPort(event_handler_->completion_port());
@@ skipping 97 matching lines @@
       }
 
       if ((msg->data & (1 << kCloseCommand)) != 0) {
         handle->Close();
         if (handle->IsClosed()) {
           delete_handle = true;
         }
       }
     }
     if (delete_handle) {
+      Dart_Port port = handle->port();
       delete handle;
+      DartUtils::PostInt32(port, 1 << kDestroyedEvent);
     }
   }
 }
 
 
 void EventHandlerImplementation::HandleAccept(ListenSocket* listen_socket,
                                               IOBuffer* buffer) {
   listen_socket->AcceptComplete(buffer, completion_port_);
 
   if (!listen_socket->IsClosing()) {
     int event_mask = 1 << kInEvent;
     if ((listen_socket->mask() & event_mask) != 0) {
       DartUtils::PostInt32(listen_socket->port(), event_mask);
     }
   }
 
   if (listen_socket->IsClosed()) {
+    Dart_Port port = listen_socket->port();
     delete listen_socket;
+    DartUtils::PostInt32(port, 1 << kDestroyedEvent);
   }
 }
 
 
 void EventHandlerImplementation::HandleClosed(Handle* handle) {
   if (!handle->IsClosing()) {
     int event_mask = 1 << kCloseEvent;
     DartUtils::PostInt32(handle->port(), event_mask);
   }
 }
@@ skipping 24 matching lines @@
   } else {
     handle->MarkClosedRead();
     if (bytes == 0) {
       HandleClosed(handle);
     } else {
       HandleError(handle);
     }
   }
 
   if (handle->IsClosed()) {
+    Dart_Port port = handle->port();
     delete handle;
+    DartUtils::PostInt32(port, 1 << kDestroyedEvent);
   }
 }
 
 
 void EventHandlerImplementation::HandleWrite(Handle* handle,
                                              int bytes,
                                              IOBuffer* buffer) {
   handle->WriteComplete(buffer);
 
   if (bytes > 0) {
     if (!handle->IsError() && !handle->IsClosing()) {
       int event_mask = 1 << kOutEvent;
       if ((handle->mask() & event_mask) != 0) {
         DartUtils::PostInt32(handle->port(), event_mask);
       }
     }
   } else if (bytes == 0) {
     HandleClosed(handle);
   } else {
     HandleError(handle);
   }
 
   if (handle->IsClosed()) {
+    Dart_Port port = handle->port();
     delete handle;
+    DartUtils::PostInt32(port, 1 << kDestroyedEvent);
   }
 }
 
 
 void EventHandlerImplementation::HandleDisconnect(
     ClientSocket* client_socket,
     int bytes,
     IOBuffer* buffer) {
   client_socket->DisconnectComplete(buffer);
 }
@@ skipping 147 matching lines @@
 
 
 void EventHandlerImplementation::Shutdown() {
   SendData(kShutdownId, 0, 0);
 }
 
 }  // namespace bin
 }  // namespace dart
 
 #endif  // defined(TARGET_OS_WINDOWS)