| Index: dart/runtime/bin/eventhandler_android.h
|
| diff --git a/dart/runtime/bin/eventhandler_android.h b/dart/runtime/bin/eventhandler_android.h
|
| index 2eee0af7997f89e108c956cde09c0bcc8547eb9a..51698da0d30de5bd75ed75bf925adc7c341e22bf 100644
|
| --- a/dart/runtime/bin/eventhandler_android.h
|
| +++ b/dart/runtime/bin/eventhandler_android.h
|
| @@ -22,60 +22,36 @@
|
| namespace dart {
|
| namespace bin {
|
|
|
| -class InterruptMessage {
|
| +class DescriptorInfo : public DescriptorInfoBase {
|
| public:
|
| - intptr_t id;
|
| - Dart_Port dart_port;
|
| - int64_t data;
|
| -};
|
| -
|
| + explicit DescriptorInfo(intptr_t fd) : DescriptorInfoBase(fd) { }
|
|
|
| -class SocketData {
|
| - public:
|
| - explicit SocketData(intptr_t fd)
|
| - : fd_(fd), port_(0), mask_(0), tokens_(16) {
|
| - ASSERT(fd_ != -1);
|
| - }
|
| + virtual ~DescriptorInfo() { }
|
|
|
| intptr_t GetPollEvents();
|
|
|
| - void Close() {
|
| - port_ = 0;
|
| - mask_ = 0;
|
| + virtual void Close() {
|
| VOID_TEMP_FAILURE_RETRY(close(fd_));
|
| fd_ = -1;
|
| }
|
| +};
|
|
|
| - void SetPortAndMask(Dart_Port port, intptr_t mask) {
|
| - ASSERT(fd_ != -1);
|
| - port_ = port;
|
| - mask_ = mask;
|
| - }
|
| -
|
| - intptr_t fd() { return fd_; }
|
| - Dart_Port port() { return port_; }
|
| -
|
| - bool IsListeningSocket() { return (mask_ & (1 << kListeningSocket)) != 0; }
|
|
|
| - // Returns true if the last token was taken.
|
| - bool TakeToken() {
|
| - ASSERT(tokens_ > 0);
|
| - tokens_--;
|
| - return tokens_ == 0;
|
| - }
|
| +class DescriptorInfoSingle
|
| + : public DescriptorInfoSingleMixin<DescriptorInfo> {
|
| + public:
|
| + explicit DescriptorInfoSingle(intptr_t fd)
|
| + : DescriptorInfoSingleMixin(fd) {}
|
| + virtual ~DescriptorInfoSingle() {}
|
| +};
|
|
|
| - // Returns true if the tokens was 0 before adding.
|
| - bool ReturnToken() {
|
| - ASSERT(tokens_ >= 0);
|
| - tokens_++;
|
| - return tokens_ == 1;
|
| - }
|
|
|
| - private:
|
| - intptr_t fd_;
|
| - Dart_Port port_;
|
| - intptr_t mask_;
|
| - int tokens_;
|
| +class DescriptorInfoMultiple
|
| + : public DescriptorInfoMultipleMixin<DescriptorInfo> {
|
| + public:
|
| + explicit DescriptorInfoMultiple(intptr_t fd)
|
| + : DescriptorInfoMultipleMixin(fd) {}
|
| + virtual ~DescriptorInfoMultiple() {}
|
| };
|
|
|
|
|
| @@ -86,8 +62,8 @@ class EventHandlerImplementation {
|
|
|
| // Gets the socket data structure for a given file
|
| // descriptor. Creates a new one if one is not found.
|
| - SocketData* GetSocketData(intptr_t fd);
|
| - void SendData(intptr_t id, Dart_Port dart_port, intptr_t data);
|
| + DescriptorInfo* GetDescriptorInfo(intptr_t fd, bool is_listening);
|
| + void SendData(intptr_t id, Dart_Port dart_port, int64_t data);
|
| void Start(EventHandler* handler);
|
| void Shutdown();
|
|
|
| @@ -99,7 +75,7 @@ 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);
|
| - intptr_t GetPollEvents(intptr_t events, SocketData* sd);
|
| + intptr_t GetPollEvents(intptr_t events, DescriptorInfo* sd);
|
| static void* GetHashmapKeyFromFd(intptr_t fd);
|
| static uint32_t GetHashmapHashFromFd(intptr_t fd);
|
|
|
|
|