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)) { |