One event handler for all isolates

runtime/bin/eventhandler.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_H_
 #define BIN_EVENTHANDLER_H_
 
 #include "bin/builtin.h"
 #include "bin/isolate_data.h"
 
 namespace dart {
 namespace bin {
 
 // Flags used to provide information and actions to the eventhandler
 // when sending a message about a file descriptor. These flags should
 // be kept in sync with the constants in socket_impl.dart. For more
 // information see the comments in socket_impl.dart
 enum MessageFlags {
   kInEvent = 0,
   kOutEvent = 1,
   kErrorEvent = 2,
   kCloseEvent = 3,
   kCloseCommand = 8,
   kShutdownReadCommand = 9,
   kShutdownWriteCommand = 10,
   kListeningSocket = 16,
   kPipe = 17,
 };
 
+
+class TimeoutQueue {
+ private:
+  class Timeout {
+   public:
+    Timeout(Dart_Port port, int64_t timeout, Timeout* next)
+        : port_(port), timeout_(timeout), next_(next) {}
+
+    Dart_Port port() const { return port_; }
+
+    int64_t timeout() const { return timeout_; }
+    void set_timeout(int64_t timeout) {
+      ASSERT(timeout >= 0);
+      timeout_ = timeout;
+    }
+
+    Timeout* next() const { return next_; }
+    void set_next(Timeout* next) {
+      next_ = next;
+    }
+
+   private:
+    Dart_Port port_;
+    int64_t timeout_;
+    Timeout* next_;
+  };
+
+ public:
+  TimeoutQueue() : next_timeout_(NULL), timeouts_(NULL) {}
+
+  ~TimeoutQueue() {
+    while (HasTimeout()) RemoveCurrent();
+  }
+
+  bool HasTimeout() const { return next_timeout_ != NULL; }
+
+  int64_t CurrentTimeout() const {
+    return next_timeout_->timeout();
+  }
+
+  Dart_Port CurrentPort() const {
+    return next_timeout_->port();
+  }
+
+  void RemoveCurrent() {
+    UpdateTimeout(CurrentPort(), -1);
+  }
+
+  void UpdateTimeout(Dart_Port port, int64_t timeout);
+
+ private:
+  Timeout* next_timeout_;
+  Timeout* timeouts_;
+};
+
 }  // namespace bin
 }  // namespace dart
 
 // The event handler delegation class is OS specific.
 #if defined(TARGET_OS_ANDROID)
 #include "bin/eventhandler_android.h"
 #elif defined(TARGET_OS_LINUX)
 #include "bin/eventhandler_linux.h"
 #elif defined(TARGET_OS_MACOS)
 #include "bin/eventhandler_macos.h"
@@ skipping 12 matching lines @@
     delegate_.SendData(id, dart_port, data);
   }
 
   void Shutdown() {
     delegate_.Shutdown();
   }
 
   static EventHandler* Start() {
     EventHandler* handler = new EventHandler();
     handler->delegate_.Start(handler);
-    IsolateData* isolate_data =
-        reinterpret_cast<IsolateData*>(Dart_CurrentIsolateData());
-    isolate_data->event_handler = handler;
     return handler;
   }
 
+  static void Stop();
+
  private:
   friend class EventHandlerImplementation;
   EventHandlerImplementation delegate_;
 };
 
 }  // namespace bin
 }  // namespace dart
 
 #endif  // BIN_EVENTHANDLER_H_