| Index: dart/runtime/bin/eventhandler_linux.cc
|
| diff --git a/dart/runtime/bin/eventhandler_linux.cc b/dart/runtime/bin/eventhandler_linux.cc
|
| index 0701810a55bbc135d5533b4239d11c2114dc8e93..805c641e74881c0e7dc1e6585a085ca241e22db6 100644
|
| --- a/dart/runtime/bin/eventhandler_linux.cc
|
| +++ b/dart/runtime/bin/eventhandler_linux.cc
|
| @@ -200,17 +200,17 @@ void EventHandlerImplementation::HandleInterruptFd() {
|
| SocketData* sd = GetSocketData(
|
| msg[i].id, (msg[i].data & (1 << kListeningSocket)) != 0);
|
| if ((msg[i].data & (1 << kShutdownReadCommand)) != 0) {
|
| - ASSERT(msg[i].data == (1 << kShutdownReadCommand));
|
| + ASSERT(COMMAND_MASK(msg[i].data) == (1 << kShutdownReadCommand));
|
| ASSERT(!sd->IsListeningSocket());
|
| // Close the socket for reading.
|
| VOID_NO_RETRY_EXPECTED(shutdown(sd->fd(), SHUT_RD));
|
| } else if ((msg[i].data & (1 << kShutdownWriteCommand)) != 0) {
|
| - ASSERT(msg[i].data == (1 << kShutdownWriteCommand));
|
| + ASSERT(COMMAND_MASK(msg[i].data) == (1 << kShutdownWriteCommand));
|
| ASSERT(!sd->IsListeningSocket());
|
| // Close the socket for writing.
|
| VOID_NO_RETRY_EXPECTED(shutdown(sd->fd(), SHUT_WR));
|
| } else if ((msg[i].data & (1 << kCloseCommand)) != 0) {
|
| - ASSERT(msg[i].data == (1 << kCloseCommand));
|
| + ASSERT(COMMAND_MASK(msg[i].data) == (1 << kCloseCommand));
|
| // Close the socket and free system resources and move on to
|
| // next message.
|
| if (sd->RemovePort(msg[i].dart_port)) {
|
|
|