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 |