| 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 #include "platform/globals.h" | 5 #include "platform/globals.h" |
| 6 #if defined(TARGET_OS_ANDROID) | 6 #if defined(TARGET_OS_ANDROID) |
| 7 | 7 |
| 8 #include <errno.h> // NOLINT | 8 #include <errno.h> // NOLINT |
| 9 #include <stdio.h> // NOLINT | 9 #include <stdio.h> // NOLINT |
| 10 #include <stdlib.h> // NOLINT | 10 #include <stdlib.h> // NOLINT |
| 11 #include <sys/epoll.h> // NOLINT | 11 #include <sys/epoll.h> // NOLINT |
| 12 | 12 |
| 13 #include "bin/dbg_connection.h" | 13 #include "bin/dbg_connection.h" |
| 14 #include "bin/fdutils.h" | 14 #include "bin/fdutils.h" |
| 15 #include "bin/log.h" | 15 #include "bin/log.h" |
| 16 #include "bin/socket.h" | 16 #include "bin/socket.h" |
| 17 | 17 |
| 18 #include "platform/signal_blocker.h" |
| 19 |
| 18 | 20 |
| 19 namespace dart { | 21 namespace dart { |
| 20 namespace bin { | 22 namespace bin { |
| 21 | 23 |
| 22 int DebuggerConnectionImpl::epoll_fd_ = -1; | 24 int DebuggerConnectionImpl::epoll_fd_ = -1; |
| 23 int DebuggerConnectionImpl::wakeup_fds_[2] = {-1, -1}; | 25 int DebuggerConnectionImpl::wakeup_fds_[2] = {-1, -1}; |
| 24 | 26 |
| 25 | 27 |
| 26 void DebuggerConnectionImpl::HandleEvent(struct epoll_event* event) { | 28 void DebuggerConnectionImpl::HandleEvent(struct epoll_event* event) { |
| 27 if (event->data.fd == DebuggerConnectionHandler::listener_fd_) { | 29 if (event->data.fd == DebuggerConnectionHandler::listener_fd_) { |
| (...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 62 ASSERT(result <= kMaxEvents); | 64 ASSERT(result <= kMaxEvents); |
| 63 for (int i = 0; i < result; i++) { | 65 for (int i = 0; i < result; i++) { |
| 64 HandleEvent(&events[i]); | 66 HandleEvent(&events[i]); |
| 65 } | 67 } |
| 66 } | 68 } |
| 67 } | 69 } |
| 68 } | 70 } |
| 69 | 71 |
| 70 | 72 |
| 71 void DebuggerConnectionImpl::SetupPollQueue() { | 73 void DebuggerConnectionImpl::SetupPollQueue() { |
| 72 int result = TEMP_FAILURE_RETRY(pipe(wakeup_fds_)); | 74 int result = NO_RETRY_EXPECTED(pipe(wakeup_fds_)); |
| 73 if (result != 0) { | 75 if (result != 0) { |
| 74 FATAL1("Pipe creation failed with error %d\n", result); | 76 FATAL1("Pipe creation failed with error %d\n", result); |
| 75 } | 77 } |
| 76 FDUtils::SetNonBlocking(wakeup_fds_[0]); | 78 FDUtils::SetNonBlocking(wakeup_fds_[0]); |
| 77 | 79 |
| 78 static const int kEpollInitialSize = 16; | 80 static const int kEpollInitialSize = 16; |
| 79 epoll_fd_ = TEMP_FAILURE_RETRY(epoll_create(kEpollInitialSize)); | 81 epoll_fd_ = NO_RETRY_EXPECTED(epoll_create(kEpollInitialSize)); |
| 80 if (epoll_fd_ == -1) { | 82 if (epoll_fd_ == -1) { |
| 81 FATAL("Failed creating epoll file descriptor"); | 83 FATAL("Failed creating epoll file descriptor"); |
| 82 } | 84 } |
| 83 | 85 |
| 84 // Register the wakeup _fd with the epoll instance. | 86 // Register the wakeup _fd with the epoll instance. |
| 85 struct epoll_event event; | 87 struct epoll_event event; |
| 86 event.events = EPOLLIN; | 88 event.events = EPOLLIN; |
| 87 event.data.fd = wakeup_fds_[0]; | 89 event.data.fd = wakeup_fds_[0]; |
| 88 int status = TEMP_FAILURE_RETRY(epoll_ctl( | 90 int status = NO_RETRY_EXPECTED(epoll_ctl( |
| 89 epoll_fd_, EPOLL_CTL_ADD, wakeup_fds_[0], &event)); | 91 epoll_fd_, EPOLL_CTL_ADD, wakeup_fds_[0], &event)); |
| 90 if (status == -1) { | 92 if (status == -1) { |
| 91 FATAL("Failed adding wakeup fd to epoll instance"); | 93 FATAL("Failed adding wakeup fd to epoll instance"); |
| 92 } | 94 } |
| 93 | 95 |
| 94 // Register the listener_fd with the epoll instance. | 96 // Register the listener_fd with the epoll instance. |
| 95 event.events = EPOLLIN; | 97 event.events = EPOLLIN; |
| 96 event.data.fd = DebuggerConnectionHandler::listener_fd_; | 98 event.data.fd = DebuggerConnectionHandler::listener_fd_; |
| 97 status = TEMP_FAILURE_RETRY(epoll_ctl(epoll_fd_, EPOLL_CTL_ADD, | 99 status = NO_RETRY_EXPECTED(epoll_ctl(epoll_fd_, EPOLL_CTL_ADD, |
| 98 DebuggerConnectionHandler::listener_fd_, &event)); | 100 DebuggerConnectionHandler::listener_fd_, &event)); |
| 99 if (status == -1) { | 101 if (status == -1) { |
| 100 FATAL("Failed adding listener fd to epoll instance"); | 102 FATAL("Failed adding listener fd to epoll instance"); |
| 101 } | 103 } |
| 102 } | 104 } |
| 103 | 105 |
| 104 | 106 |
| 105 void DebuggerConnectionImpl::StartHandler(int port_number) { | 107 void DebuggerConnectionImpl::StartHandler(int port_number) { |
| 106 ASSERT(DebuggerConnectionHandler::listener_fd_ != -1); | 108 ASSERT(DebuggerConnectionHandler::listener_fd_ != -1); |
| 107 SetupPollQueue(); | 109 SetupPollQueue(); |
| (...skipping 12 matching lines...) Expand all Loading... |
| 120 | 122 |
| 121 | 123 |
| 122 intptr_t DebuggerConnectionImpl::Receive(intptr_t socket, char* buf, int len) { | 124 intptr_t DebuggerConnectionImpl::Receive(intptr_t socket, char* buf, int len) { |
| 123 return TEMP_FAILURE_RETRY(read(socket, buf, len)); | 125 return TEMP_FAILURE_RETRY(read(socket, buf, len)); |
| 124 } | 126 } |
| 125 | 127 |
| 126 } // namespace bin | 128 } // namespace bin |
| 127 } // namespace dart | 129 } // namespace dart |
| 128 | 130 |
| 129 #endif // defined(TARGET_OS_ANDROID) | 131 #endif // defined(TARGET_OS_ANDROID) |
| OLD | NEW |