| OLD | NEW |
| 1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file |
| 2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
| 3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
| 4 | 4 |
| 5 #ifndef BIN_EVENTHANDLER_WIN_H_ | 5 #ifndef BIN_EVENTHANDLER_WIN_H_ |
| 6 #define BIN_EVENTHANDLER_WIN_H_ | 6 #define BIN_EVENTHANDLER_WIN_H_ |
| 7 | 7 |
| 8 #if !defined(BIN_EVENTHANDLER_H_) | 8 #if !defined(BIN_EVENTHANDLER_H_) |
| 9 #error Do not include eventhandler_win.h directly; use eventhandler.h instead. | 9 #error Do not include eventhandler_win.h directly; use eventhandler.h instead. |
| 10 #endif | 10 #endif |
| (...skipping 328 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 339 ClientSocket* next_; | 339 ClientSocket* next_; |
| 340 }; | 340 }; |
| 341 | 341 |
| 342 | 342 |
| 343 // Event handler. | 343 // Event handler. |
| 344 class EventHandlerImplementation { | 344 class EventHandlerImplementation { |
| 345 public: | 345 public: |
| 346 EventHandlerImplementation(); | 346 EventHandlerImplementation(); |
| 347 virtual ~EventHandlerImplementation() {} | 347 virtual ~EventHandlerImplementation() {} |
| 348 | 348 |
| 349 void SendData(intptr_t id, Dart_Port dart_port, intptr_t data); | 349 void SendData(intptr_t id, Dart_Port dart_port, int64_t data); |
| 350 void Start(); | 350 void Start(); |
| 351 void Shutdown(); | 351 void Shutdown(); |
| 352 | 352 |
| 353 static void EventHandlerEntry(uword args); | 353 static void EventHandlerEntry(uword args); |
| 354 | 354 |
| 355 DWORD GetTimeout(); | 355 DWORD GetTimeout(); |
| 356 void HandleInterrupt(InterruptMessage* msg); | 356 void HandleInterrupt(InterruptMessage* msg); |
| 357 void HandleTimeout(); | 357 void HandleTimeout(); |
| 358 void HandleAccept(ListenSocket* listen_socket, IOBuffer* buffer); | 358 void HandleAccept(ListenSocket* listen_socket, IOBuffer* buffer); |
| 359 void HandleClosed(Handle* handle); | 359 void HandleClosed(Handle* handle); |
| 360 void HandleError(Handle* handle); | 360 void HandleError(Handle* handle); |
| 361 void HandleRead(Handle* handle, int bytes, IOBuffer* buffer); | 361 void HandleRead(Handle* handle, int bytes, IOBuffer* buffer); |
| 362 void HandleWrite(Handle* handle, int bytes, IOBuffer* buffer); | 362 void HandleWrite(Handle* handle, int bytes, IOBuffer* buffer); |
| 363 void HandleClose(ClientSocket* client_socket); | 363 void HandleClose(ClientSocket* client_socket); |
| 364 void HandleIOCompletion(DWORD bytes, ULONG_PTR key, OVERLAPPED* overlapped); | 364 void HandleIOCompletion(DWORD bytes, ULONG_PTR key, OVERLAPPED* overlapped); |
| 365 | 365 |
| 366 HANDLE completion_port() { return completion_port_; } | 366 HANDLE completion_port() { return completion_port_; } |
| 367 | 367 |
| 368 private: | 368 private: |
| 369 ClientSocket* client_sockets_head_; | 369 ClientSocket* client_sockets_head_; |
| 370 | 370 |
| 371 int64_t timeout_; // Time for next timeout. | 371 int64_t timeout_; // Time for next timeout. |
| 372 Dart_Port timeout_port_; | 372 Dart_Port timeout_port_; |
| 373 bool shutdown_; | 373 bool shutdown_; |
| 374 HANDLE completion_port_; | 374 HANDLE completion_port_; |
| 375 }; | 375 }; |
| 376 | 376 |
| 377 | 377 |
| 378 #endif // BIN_EVENTHANDLER_WIN_H_ | 378 #endif // BIN_EVENTHANDLER_WIN_H_ |
| OLD | NEW |