Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(316)

Unified Diff: runtime/bin/eventhandler_macos.h

Issue 8431027: Some Linux and Mac OS event handler refactoring (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Created 9 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: runtime/bin/eventhandler_macos.h
diff --git a/runtime/bin/eventhandler_macos.h b/runtime/bin/eventhandler_macos.h
index c9ea78d875c93d047e6209ee1d63d247d1663e34..1430789ac0ea21fa022774a4b14d2bf300113bad 100644
--- a/runtime/bin/eventhandler_macos.h
+++ b/runtime/bin/eventhandler_macos.h
@@ -6,17 +6,29 @@
#define BIN_EVENTHANDLER_MACOS_H_
-typedef struct {
+class InterruptMessage {
+ public:
intptr_t id;
Dart_Port dart_port;
int64_t data;
-} InterruptMessage;
+};
-typedef struct {
- Dart_Port dart_port;
- intptr_t mask;
-} PortData;
+class SocketData {
+ public:
+ void FillPollEvents(struct pollfd* pollfds);
+ bool IsListeningSocket() { return (_mask & (1 << kListeningSocket)) != 0; }
+
+ Dart_Port port() { return _port; }
+ void set_port(Dart_Port port) { _port = port; }
+ intptr_t mask() { return _mask; }
+ void set_mask(intptr_t mask) { _mask = mask; }
+
+
+ private:
+ Dart_Port _port;
+ intptr_t _mask;
+};
class EventHandlerImplementation {
@@ -24,6 +36,7 @@ class EventHandlerImplementation {
EventHandlerImplementation();
~EventHandlerImplementation();
+ SocketData* GetSocketData(intptr_t fd);
void SendData(intptr_t id, Dart_Port dart_port, intptr_t data);
void StartEventHandler();
@@ -41,12 +54,9 @@ class EventHandlerImplementation {
void WakeupHandler(intptr_t id, Dart_Port dart_port, int64_t data);
void HandleInterruptFd();
void SetPort(intptr_t fd, Dart_Port dart_port, intptr_t mask);
- Dart_Port PortFor(intptr_t fd);
- bool IsListeningSocket(intptr_t fd);
intptr_t GetPollEvents(struct pollfd* pollfd);
- void SetPollEvents(struct pollfd* pollfds, intptr_t mask);
- PortData* port_map_;
+ SocketData* port_map_;
intptr_t port_map_entries_;
intptr_t port_map_size_;
int64_t timeout_; // Time for next timeout.

Powered by Google App Engine
This is Rietveld 408576698