Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(2845)

Unified Diff: dart/runtime/bin/eventhandler_macos.cc

Issue 896213002: Revert "Introduce optional 'bool shared' parameter to ServerSocket.bind() ..." (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge
Patch Set: Created 5 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « dart/runtime/bin/eventhandler_macos.h ('k') | dart/runtime/bin/eventhandler_win.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: dart/runtime/bin/eventhandler_macos.cc
diff --git a/dart/runtime/bin/eventhandler_macos.cc b/dart/runtime/bin/eventhandler_macos.cc
index f8c1dea8c4983fff4db80bb6f5d9799b3925cf9f..49ec2477e19b132b0033d078f664a68787d0c207 100644
--- a/dart/runtime/bin/eventhandler_macos.cc
+++ b/dart/runtime/bin/eventhandler_macos.cc
@@ -6,7 +6,6 @@
#if defined(TARGET_OS_MACOS)
#include "bin/eventhandler.h"
-#include "bin/eventhandler_macos.h"
#include <errno.h> // NOLINT
#include <pthread.h> // NOLINT
@@ -18,9 +17,7 @@
#include "bin/dartutils.h"
#include "bin/fdutils.h"
-#include "bin/lockers.h"
#include "bin/log.h"
-#include "bin/socket.h"
#include "bin/thread.h"
#include "bin/utils.h"
#include "platform/hashmap.h"
@@ -30,61 +27,66 @@
namespace dart {
namespace bin {
+static const int kInterruptMessageSize = sizeof(InterruptMessage);
+static const int kInfinityTimeout = -1;
+static const int kTimerId = -1;
+static const int kShutdownId = -2;
-bool DescriptorInfo::HasReadEvent() {
- return (Mask() & (1 << kInEvent)) != 0;
+
+bool SocketData::HasReadEvent() {
+ return (mask_ & (1 << kInEvent)) != 0;
}
-bool DescriptorInfo::HasWriteEvent() {
- return (Mask() & (1 << kOutEvent)) != 0;
+bool SocketData::HasWriteEvent() {
+ return (mask_ & (1 << kOutEvent)) != 0;
}
// Unregister the file descriptor for a SocketData structure with kqueue.
-static void RemoveFromKqueue(intptr_t kqueue_fd_, DescriptorInfo* di) {
- if (!di->tracked_by_kqueue()) return;
+static void RemoveFromKqueue(intptr_t kqueue_fd_, SocketData* sd) {
+ if (!sd->tracked_by_kqueue()) return;
static const intptr_t kMaxChanges = 2;
struct kevent events[kMaxChanges];
- EV_SET(events, di->fd(), EVFILT_READ, EV_DELETE, 0, 0, NULL);
+ EV_SET(events, sd->fd(), EVFILT_READ, EV_DELETE, 0, 0, NULL);
VOID_NO_RETRY_EXPECTED(kevent(kqueue_fd_, events, 1, NULL, 0, NULL));
- EV_SET(events, di->fd(), EVFILT_WRITE, EV_DELETE, 0, 0, NULL);
+ EV_SET(events, sd->fd(), EVFILT_WRITE, EV_DELETE, 0, 0, NULL);
VOID_NO_RETRY_EXPECTED(kevent(kqueue_fd_, events, 1, NULL, 0, NULL));
- di->set_tracked_by_kqueue(false);
+ sd->set_tracked_by_kqueue(false);
}
// Update the kqueue registration for SocketData structure to reflect
// the events currently of interest.
-static void AddToKqueue(intptr_t kqueue_fd_, DescriptorInfo* di) {
- ASSERT(!di->tracked_by_kqueue());
+static void AddToKqueue(intptr_t kqueue_fd_, SocketData* sd) {
+ ASSERT(!sd->tracked_by_kqueue());
static const intptr_t kMaxChanges = 2;
intptr_t changes = 0;
struct kevent events[kMaxChanges];
int flags = EV_ADD;
- if (!di->IsListeningSocket()) {
+ if (!sd->IsListeningSocket()) {
flags |= EV_CLEAR;
}
// Register or unregister READ filter if needed.
- if (di->HasReadEvent()) {
+ if (sd->HasReadEvent()) {
EV_SET(events + changes,
- di->fd(),
+ sd->fd(),
EVFILT_READ,
flags,
0,
0,
- di);
+ sd);
++changes;
}
// Register or unregister WRITE filter if needed.
- if (di->HasWriteEvent()) {
+ if (sd->HasWriteEvent()) {
EV_SET(events + changes,
- di->fd(),
+ sd->fd(),
EVFILT_WRITE,
flags,
0,
0,
- di);
+ sd);
++changes;
}
ASSERT(changes > 0);
@@ -92,16 +94,13 @@ static void AddToKqueue(intptr_t kqueue_fd_, DescriptorInfo* di) {
int status =
NO_RETRY_EXPECTED(kevent(kqueue_fd_, events, changes, NULL, 0, NULL));
if (status == -1) {
- // TODO(kustermann): Verify that the dart end is handling this correctly &
- // adapt this code to work for multiple listening sockets.
-
// kQueue does not accept the file descriptor. It could be due to
// already closed file descriptor, or unuspported devices, such
// as /dev/null. In such case, mark the file descriptor as closed,
// so dart will handle it accordingly.
- DartUtils::PostInt32(di->NextPort(), 1 << kCloseEvent);
+ DartUtils::PostInt32(sd->port(), 1 << kCloseEvent);
} else {
- di->set_tracked_by_kqueue(true);
+ sd->set_tracked_by_kqueue(true);
}
}
@@ -143,26 +142,20 @@ EventHandlerImplementation::~EventHandlerImplementation() {
}
-DescriptorInfo* EventHandlerImplementation::GetDescriptorInfo(
- intptr_t fd, bool is_listening) {
+SocketData* EventHandlerImplementation::GetSocketData(intptr_t fd) {
ASSERT(fd >= 0);
HashMap::Entry* entry = socket_map_.Lookup(
GetHashmapKeyFromFd(fd), GetHashmapHashFromFd(fd), true);
ASSERT(entry != NULL);
- DescriptorInfo* di =
- reinterpret_cast<DescriptorInfo*>(entry->value);
- if (di == NULL) {
+ SocketData* sd = reinterpret_cast<SocketData*>(entry->value);
+ if (sd == NULL) {
// If there is no data in the hash map for this file descriptor a
- // new DescriptorInfo for the file descriptor is inserted.
- if (is_listening) {
- di = new DescriptorInfoMultiple(fd);
- } else {
- di = new DescriptorInfoSingle(fd);
- }
- entry->value = di;
+ // new SocketData for the file descriptor is inserted.
+ sd = new SocketData(fd);
+ entry->value = sd;
}
- ASSERT(fd == di->fd());
- return di;
+ ASSERT(fd == sd->fd());
+ return sd;
}
@@ -198,64 +191,36 @@ void EventHandlerImplementation::HandleInterruptFd() {
} else if (msg[i].id == kShutdownId) {
shutdown_ = true;
} else {
- DescriptorInfo* di = GetDescriptorInfo(
- msg[i].id, (msg[i].data & (1 << kListeningSocket)) != 0);
+ SocketData* sd = GetSocketData(msg[i].id);
if (IS_COMMAND(msg[i].data, kShutdownReadCommand)) {
- ASSERT(!di->IsListeningSocket());
// Close the socket for reading.
- VOID_NO_RETRY_EXPECTED(shutdown(di->fd(), SHUT_RD));
+ shutdown(sd->fd(), SHUT_RD);
} else if (IS_COMMAND(msg[i].data, kShutdownWriteCommand)) {
- ASSERT(!di->IsListeningSocket());
// Close the socket for writing.
- VOID_NO_RETRY_EXPECTED(shutdown(di->fd(), SHUT_WR));
+ shutdown(sd->fd(), SHUT_WR);
} else if (IS_COMMAND(msg[i].data, kCloseCommand)) {
- // Close the socket and free system resources and move on to next
- // message.
- bool no_more_listeners = di->RemovePort(msg[i].dart_port);
- if (no_more_listeners) {
- RemoveFromKqueue(kqueue_fd_, di);
- }
-
- intptr_t fd = di->fd();
- if (di->IsListeningSocket()) {
- // We only close the socket file descriptor from the operating
- // system if there are no other dart socket objects which
- // are listening on the same (address, port) combination.
- {
- MutexLocker ml(globalTcpListeningSocketRegistry.mutex());
- if (globalTcpListeningSocketRegistry.CloseSafe(fd)) {
- socket_map_.Remove(
- GetHashmapKeyFromFd(fd), GetHashmapHashFromFd(fd));
- di->Close();
- delete di;
- }
- }
- } else {
- ASSERT(no_more_listeners);
- socket_map_.Remove(
- GetHashmapKeyFromFd(fd), GetHashmapHashFromFd(fd));
- di->Close();
- delete di;
- }
+ // Close the socket and free system resources.
+ RemoveFromKqueue(kqueue_fd_, sd);
+ intptr_t fd = sd->fd();
+ VOID_TEMP_FAILURE_RETRY(close(fd));
+ socket_map_.Remove(GetHashmapKeyFromFd(fd), GetHashmapHashFromFd(fd));
+ delete sd;
DartUtils::PostInt32(msg[i].dart_port, 1 << kDestroyedEvent);
} else if (IS_COMMAND(msg[i].data, kReturnTokenCommand)) {
int count = TOKEN_COUNT(msg[i].data);
- if (di->ReturnTokens(msg[i].dart_port, count)) {
- AddToKqueue(kqueue_fd_, di);
+ for (int i = 0; i < count; i++) {
+ if (sd->ReturnToken()) {
+ AddToKqueue(kqueue_fd_, sd);
+ }
}
} else {
ASSERT_NO_COMMAND(msg[i].data);
+ // Setup events to wait for.
ASSERT((msg[i].data > 0) && (msg[i].data < kIntptrMax));
- bool had_listeners = di->HasNextPort();
- di->SetPortAndMask(msg[i].dart_port, msg[i].data & EVENT_MASK);
- bool has_listeners = di->HasNextPort();
-
- // Add/Remove from epoll set depending on previous and current state.
- if (!had_listeners && has_listeners) {
- AddToKqueue(kqueue_fd_, di);
- } else if (had_listeners && !has_listeners) {
- RemoveFromKqueue(kqueue_fd_, di);
- }
+ ASSERT(sd->port() == 0);
+ sd->SetPortAndMask(msg[i].dart_port,
+ static_cast<intptr_t>(msg[i].data));
+ AddToKqueue(kqueue_fd_, sd);
}
}
}
@@ -283,12 +248,12 @@ static void PrintEventMask(intptr_t fd, struct kevent* event) {
intptr_t EventHandlerImplementation::GetEvents(struct kevent* event,
- DescriptorInfo* di) {
+ SocketData* sd) {
#ifdef DEBUG_KQUEUE
- PrintEventMask(di->fd(), event);
+ PrintEventMask(sd->fd(), event);
#endif
intptr_t event_mask = 0;
- if (di->IsListeningSocket()) {
+ if (sd->IsListeningSocket()) {
// On a listening socket the READ event means that there are
// connections ready to be accepted.
if (event->filter == EVFILT_READ) {
@@ -344,16 +309,15 @@ void EventHandlerImplementation::HandleEvents(struct kevent* events,
if (events[i].udata == NULL) {
interrupt_seen = true;
} else {
- DescriptorInfo* di =
- reinterpret_cast<DescriptorInfo*>(events[i].udata);
- intptr_t event_mask = GetEvents(events + i, di);
+ SocketData* sd = reinterpret_cast<SocketData*>(events[i].udata);
+ intptr_t event_mask = GetEvents(events + i, sd);
if (event_mask != 0) {
- Dart_Port port = di->NextPort();
- ASSERT(port != 0);
- if (di->TakeToken()) {
- // Took last token, remove from kqueue.
- RemoveFromKqueue(kqueue_fd_, di);
+ if (sd->TakeToken()) {
+ // Took last token, remove from epoll.
+ RemoveFromKqueue(kqueue_fd_, sd);
}
+ Dart_Port port = sd->port();
+ ASSERT(port != 0);
DartUtils::PostInt32(port, event_mask);
}
}
« no previous file with comments | « dart/runtime/bin/eventhandler_macos.h ('k') | dart/runtime/bin/eventhandler_win.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698