| Index: runtime/vm/message_handler_test.cc
|
| diff --git a/runtime/vm/message_handler_test.cc b/runtime/vm/message_handler_test.cc
|
| index 926344bfb01b86f2fe8a40473fd0c33a75b920e4..183453b55659115c7213fd17d63f40b390b3ed66 100644
|
| --- a/runtime/vm/message_handler_test.cc
|
| +++ b/runtime/vm/message_handler_test.cc
|
| @@ -29,7 +29,6 @@ class MessageHandlerTestPeer {
|
| DISALLOW_COPY_AND_ASSIGN(MessageHandlerTestPeer);
|
| };
|
|
|
| -
|
| class TestMessageHandler : public MessageHandler {
|
| public:
|
| TestMessageHandler()
|
| @@ -106,17 +105,14 @@ class TestMessageHandler : public MessageHandler {
|
| DISALLOW_COPY_AND_ASSIGN(TestMessageHandler);
|
| };
|
|
|
| -
|
| MessageHandler::MessageStatus TestStartFunction(uword data) {
|
| return (reinterpret_cast<TestMessageHandler*>(data))->Start();
|
| }
|
|
|
| -
|
| void TestEndFunction(uword data) {
|
| return (reinterpret_cast<TestMessageHandler*>(data))->End();
|
| }
|
|
|
| -
|
| VM_UNIT_TEST_CASE(MessageHandler_PostMessage) {
|
| TestMessageHandler handler;
|
| MessageHandlerTestPeer handler_peer(&handler);
|
| @@ -147,7 +143,6 @@ VM_UNIT_TEST_CASE(MessageHandler_PostMessage) {
|
| delete message;
|
| }
|
|
|
| -
|
| VM_UNIT_TEST_CASE(MessageHandler_HasOOBMessages) {
|
| TestMessageHandler handler;
|
| MessageHandlerTestPeer handler_peer(&handler);
|
| @@ -180,7 +175,6 @@ VM_UNIT_TEST_CASE(MessageHandler_HasOOBMessages) {
|
| handler_peer.CloseAllPorts();
|
| }
|
|
|
| -
|
| VM_UNIT_TEST_CASE(MessageHandler_ClosePort) {
|
| TestMessageHandler handler;
|
| MessageHandlerTestPeer handler_peer(&handler);
|
| @@ -198,7 +192,6 @@ VM_UNIT_TEST_CASE(MessageHandler_ClosePort) {
|
| delete message2;
|
| }
|
|
|
| -
|
| VM_UNIT_TEST_CASE(MessageHandler_CloseAllPorts) {
|
| TestMessageHandler handler;
|
| MessageHandlerTestPeer handler_peer(&handler);
|
| @@ -213,7 +206,6 @@ VM_UNIT_TEST_CASE(MessageHandler_CloseAllPorts) {
|
| EXPECT(NULL == handler_peer.queue()->Dequeue());
|
| }
|
|
|
| -
|
| VM_UNIT_TEST_CASE(MessageHandler_HandleNextMessage) {
|
| TestMessageHandler handler;
|
| MessageHandlerTestPeer handler_peer(&handler);
|
| @@ -239,7 +231,6 @@ VM_UNIT_TEST_CASE(MessageHandler_HandleNextMessage) {
|
| PortMap::ClosePorts(&handler);
|
| }
|
|
|
| -
|
| VM_UNIT_TEST_CASE(MessageHandler_HandleNextMessage_ProcessOOBAfterError) {
|
| TestMessageHandler handler;
|
| MessageHandler::MessageStatus results[] = {
|
| @@ -269,7 +260,6 @@ VM_UNIT_TEST_CASE(MessageHandler_HandleNextMessage_ProcessOOBAfterError) {
|
| handler_peer.CloseAllPorts();
|
| }
|
|
|
| -
|
| VM_UNIT_TEST_CASE(MessageHandler_HandleNextMessage_Shutdown) {
|
| TestMessageHandler handler;
|
| MessageHandler::MessageStatus results[] = {
|
| @@ -307,7 +297,6 @@ VM_UNIT_TEST_CASE(MessageHandler_HandleNextMessage_Shutdown) {
|
| handler_peer.CloseAllPorts();
|
| }
|
|
|
| -
|
| VM_UNIT_TEST_CASE(MessageHandler_HandleOOBMessages) {
|
| TestMessageHandler handler;
|
| MessageHandlerTestPeer handler_peer(&handler);
|
| @@ -333,14 +322,12 @@ VM_UNIT_TEST_CASE(MessageHandler_HandleOOBMessages) {
|
| handler_peer.CloseAllPorts();
|
| }
|
|
|
| -
|
| struct ThreadStartInfo {
|
| MessageHandler* handler;
|
| Dart_Port* ports;
|
| int count;
|
| };
|
|
|
| -
|
| static void SendMessages(uword param) {
|
| ThreadStartInfo* info = reinterpret_cast<ThreadStartInfo*>(param);
|
| MessageHandler* handler = info->handler;
|
| @@ -352,7 +339,6 @@ static void SendMessages(uword param) {
|
| }
|
| }
|
|
|
| -
|
| VM_UNIT_TEST_CASE(MessageHandler_Run) {
|
| ThreadPool pool;
|
| TestMessageHandler handler;
|
|
|