| 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 #if !defined(DART_IO_DISABLED) | 5 #if !defined(DART_IO_DISABLED) |
| 6 | 6 |
| 7 #include "platform/globals.h" | 7 #include "platform/globals.h" |
| 8 #if defined(HOST_OS_LINUX) | 8 #if defined(HOST_OS_LINUX) |
| 9 | 9 |
| 10 #include "bin/eventhandler.h" | 10 #include "bin/eventhandler.h" |
| (...skipping 204 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 215 int64_t millis = timeout_queue_.CurrentTimeout(); | 215 int64_t millis = timeout_queue_.CurrentTimeout(); |
| 216 it.it_value.tv_sec = millis / 1000; | 216 it.it_value.tv_sec = millis / 1000; |
| 217 it.it_value.tv_nsec = (millis % 1000) * 1000000; | 217 it.it_value.tv_nsec = (millis % 1000) * 1000000; |
| 218 } | 218 } |
| 219 VOID_NO_RETRY_EXPECTED( | 219 VOID_NO_RETRY_EXPECTED( |
| 220 timerfd_settime(timer_fd_, TFD_TIMER_ABSTIME, &it, NULL)); | 220 timerfd_settime(timer_fd_, TFD_TIMER_ABSTIME, &it, NULL)); |
| 221 } else if (msg[i].id == kShutdownId) { | 221 } else if (msg[i].id == kShutdownId) { |
| 222 shutdown_ = true; | 222 shutdown_ = true; |
| 223 } else { | 223 } else { |
| 224 ASSERT((msg[i].data & COMMAND_MASK) != 0); | 224 ASSERT((msg[i].data & COMMAND_MASK) != 0); |
| 225 | 225 Socket* socket = reinterpret_cast<Socket*>(msg[i].id); |
| 226 RefCntReleaseScope<Socket> rs(socket); |
| 227 if (socket->fd() == -1) { |
| 228 continue; |
| 229 } |
| 226 DescriptorInfo* di = | 230 DescriptorInfo* di = |
| 227 GetDescriptorInfo(msg[i].id, IS_LISTENING_SOCKET(msg[i].data)); | 231 GetDescriptorInfo(socket->fd(), IS_LISTENING_SOCKET(msg[i].data)); |
| 228 if (IS_COMMAND(msg[i].data, kShutdownReadCommand)) { | 232 if (IS_COMMAND(msg[i].data, kShutdownReadCommand)) { |
| 229 ASSERT(!di->IsListeningSocket()); | 233 ASSERT(!di->IsListeningSocket()); |
| 230 // Close the socket for reading. | 234 // Close the socket for reading. |
| 231 VOID_NO_RETRY_EXPECTED(shutdown(di->fd(), SHUT_RD)); | 235 VOID_NO_RETRY_EXPECTED(shutdown(di->fd(), SHUT_RD)); |
| 232 } else if (IS_COMMAND(msg[i].data, kShutdownWriteCommand)) { | 236 } else if (IS_COMMAND(msg[i].data, kShutdownWriteCommand)) { |
| 233 ASSERT(!di->IsListeningSocket()); | 237 ASSERT(!di->IsListeningSocket()); |
| 234 // Close the socket for writing. | 238 // Close the socket for writing. |
| 235 VOID_NO_RETRY_EXPECTED(shutdown(di->fd(), SHUT_WR)); | 239 VOID_NO_RETRY_EXPECTED(shutdown(di->fd(), SHUT_WR)); |
| 236 } else if (IS_COMMAND(msg[i].data, kCloseCommand)) { | 240 } else if (IS_COMMAND(msg[i].data, kCloseCommand)) { |
| 237 // Close the socket and free system resources and move on to next | 241 // Close the socket and free system resources and move on to next |
| 238 // message. | 242 // message. |
| 239 intptr_t old_mask = di->Mask(); | 243 intptr_t old_mask = di->Mask(); |
| 240 Dart_Port port = msg[i].dart_port; | 244 Dart_Port port = msg[i].dart_port; |
| 241 di->RemovePort(port); | 245 di->RemovePort(port); |
| 242 intptr_t new_mask = di->Mask(); | 246 intptr_t new_mask = di->Mask(); |
| 243 UpdateEpollInstance(old_mask, di); | 247 UpdateEpollInstance(old_mask, di); |
| 244 | 248 |
| 245 intptr_t fd = di->fd(); | 249 intptr_t fd = di->fd(); |
| 246 if (di->IsListeningSocket()) { | 250 if (di->IsListeningSocket()) { |
| 247 // We only close the socket file descriptor from the operating | 251 // We only close the socket file descriptor from the operating |
| 248 // system if there are no other dart socket objects which | 252 // system if there are no other dart socket objects which |
| 249 // are listening on the same (address, port) combination. | 253 // are listening on the same (address, port) combination. |
| 250 ListeningSocketRegistry* registry = | 254 ListeningSocketRegistry* registry = |
| 251 ListeningSocketRegistry::Instance(); | 255 ListeningSocketRegistry::Instance(); |
| 252 | 256 |
| 253 MutexLocker locker(registry->mutex()); | 257 MutexLocker locker(registry->mutex()); |
| 254 | 258 |
| 255 if (registry->CloseSafe(fd)) { | 259 if (registry->CloseSafe(socket)) { |
| 256 ASSERT(new_mask == 0); | 260 ASSERT(new_mask == 0); |
| 257 socket_map_.Remove(GetHashmapKeyFromFd(fd), | 261 socket_map_.Remove(GetHashmapKeyFromFd(fd), |
| 258 GetHashmapHashFromFd(fd)); | 262 GetHashmapHashFromFd(fd)); |
| 259 di->Close(); | 263 di->Close(); |
| 260 delete di; | 264 delete di; |
| 265 socket->SetClosedFd(); |
| 261 } | 266 } |
| 262 } else { | 267 } else { |
| 263 ASSERT(new_mask == 0); | 268 ASSERT(new_mask == 0); |
| 264 socket_map_.Remove(GetHashmapKeyFromFd(fd), GetHashmapHashFromFd(fd)); | 269 socket_map_.Remove(GetHashmapKeyFromFd(fd), GetHashmapHashFromFd(fd)); |
| 265 di->Close(); | 270 di->Close(); |
| 266 delete di; | 271 delete di; |
| 272 socket->SetClosedFd(); |
| 267 } | 273 } |
| 268 | |
| 269 DartUtils::PostInt32(port, 1 << kDestroyedEvent); | 274 DartUtils::PostInt32(port, 1 << kDestroyedEvent); |
| 270 } else if (IS_COMMAND(msg[i].data, kReturnTokenCommand)) { | 275 } else if (IS_COMMAND(msg[i].data, kReturnTokenCommand)) { |
| 271 int count = TOKEN_COUNT(msg[i].data); | 276 int count = TOKEN_COUNT(msg[i].data); |
| 272 intptr_t old_mask = di->Mask(); | 277 intptr_t old_mask = di->Mask(); |
| 273 di->ReturnTokens(msg[i].dart_port, count); | 278 di->ReturnTokens(msg[i].dart_port, count); |
| 274 UpdateEpollInstance(old_mask, di); | 279 UpdateEpollInstance(old_mask, di); |
| 275 } else if (IS_COMMAND(msg[i].data, kSetEventMaskCommand)) { | 280 } else if (IS_COMMAND(msg[i].data, kSetEventMaskCommand)) { |
| 276 // `events` can only have kInEvent/kOutEvent flags set. | 281 // `events` can only have kInEvent/kOutEvent flags set. |
| 277 intptr_t events = msg[i].data & EVENT_MASK; | 282 intptr_t events = msg[i].data & EVENT_MASK; |
| 278 ASSERT(0 == (events & ~(1 << kInEvent | 1 << kOutEvent))); | 283 ASSERT(0 == (events & ~(1 << kInEvent | 1 << kOutEvent))); |
| (...skipping 116 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 395 epoll_wait(handler_impl->epoll_fd_, events, kMaxEvents, -1)); | 400 epoll_wait(handler_impl->epoll_fd_, events, kMaxEvents, -1)); |
| 396 ASSERT(EAGAIN == EWOULDBLOCK); | 401 ASSERT(EAGAIN == EWOULDBLOCK); |
| 397 if (result <= 0) { | 402 if (result <= 0) { |
| 398 if (errno != EWOULDBLOCK) { | 403 if (errno != EWOULDBLOCK) { |
| 399 perror("Poll failed"); | 404 perror("Poll failed"); |
| 400 } | 405 } |
| 401 } else { | 406 } else { |
| 402 handler_impl->HandleEvents(events, result); | 407 handler_impl->HandleEvents(events, result); |
| 403 } | 408 } |
| 404 } | 409 } |
| 410 DEBUG_ASSERT(ReferenceCounted<Socket>::instances() == 0); |
| 405 handler->NotifyShutdownDone(); | 411 handler->NotifyShutdownDone(); |
| 406 } | 412 } |
| 407 | 413 |
| 408 | 414 |
| 409 void EventHandlerImplementation::Start(EventHandler* handler) { | 415 void EventHandlerImplementation::Start(EventHandler* handler) { |
| 410 int result = Thread::Start(&EventHandlerImplementation::Poll, | 416 int result = Thread::Start(&EventHandlerImplementation::Poll, |
| 411 reinterpret_cast<uword>(handler)); | 417 reinterpret_cast<uword>(handler)); |
| 412 if (result != 0) { | 418 if (result != 0) { |
| 413 FATAL1("Failed to start event handler thread %d", result); | 419 FATAL1("Failed to start event handler thread %d", result); |
| 414 } | 420 } |
| (...skipping 22 matching lines...) Expand all Loading... |
| 437 // The hashmap does not support keys with value 0. | 443 // The hashmap does not support keys with value 0. |
| 438 return dart::Utils::WordHash(fd + 1); | 444 return dart::Utils::WordHash(fd + 1); |
| 439 } | 445 } |
| 440 | 446 |
| 441 } // namespace bin | 447 } // namespace bin |
| 442 } // namespace dart | 448 } // namespace dart |
| 443 | 449 |
| 444 #endif // defined(HOST_OS_LINUX) | 450 #endif // defined(HOST_OS_LINUX) |
| 445 | 451 |
| 446 #endif // !defined(DART_IO_DISABLED) | 452 #endif // !defined(DART_IO_DISABLED) |
| OLD | NEW |