| OLD | NEW |
| (Empty) |
| 1 // Copyright (c) 2010 The Chromium Authors. All rights reserved. | |
| 2 // Use of this source code is governed by a BSD-style license that can be | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 #ifndef CHROME_COMMON_IPC_TEST_SINK_H_ | |
| 6 #define CHROME_COMMON_IPC_TEST_SINK_H_ | |
| 7 #pragma once | |
| 8 | |
| 9 #include <utility> | |
| 10 #include <vector> | |
| 11 | |
| 12 #include "base/basictypes.h" | |
| 13 #include "ipc/ipc_channel.h" | |
| 14 | |
| 15 namespace IPC { | |
| 16 | |
| 17 class Message; | |
| 18 | |
| 19 // This test sink provides a "sink" for IPC messages that are sent. It allows | |
| 20 // the caller to query messages received in various different ways. It is | |
| 21 // designed for tests for objects that use the IPC system. | |
| 22 // | |
| 23 // Typical usage: | |
| 24 // | |
| 25 // test_sink.ClearMessages(); | |
| 26 // do_something(); | |
| 27 // | |
| 28 // // We should have gotten exactly one update state message. | |
| 29 // EXPECT_TRUE(test_sink.GetUniqeMessageMatching(ViewHostMsg_Update::ID)); | |
| 30 // // ...and no start load messages. | |
| 31 // EXPECT_FALSE(test_sink.GetFirstMessageMatching(ViewHostMsg_Start::ID)); | |
| 32 // | |
| 33 // // Now inspect a message. This assumes a message that was declared like | |
| 34 // // this: IPC_MESSAGE_ROUTED2(ViewMsg_Foo, bool, int) | |
| 35 // IPC::Message* msg = test_sink.GetFirstMessageMatching(ViewMsg_Foo::ID)); | |
| 36 // ASSERT_TRUE(msg); | |
| 37 // bool first_param; | |
| 38 // int second_param; | |
| 39 // ViewMsg_Foo::Read(msg, &first_param, &second_param); | |
| 40 // | |
| 41 // // Go on to the next phase of the test. | |
| 42 // test_sink.ClearMessages(); | |
| 43 // | |
| 44 // To hook up the sink, all you need to do is call OnMessageReceived when a | |
| 45 // message is received. | |
| 46 class TestSink : public IPC::Channel { | |
| 47 public: | |
| 48 TestSink(); | |
| 49 ~TestSink(); | |
| 50 | |
| 51 // Interface in IPC::Channel. This copies the message to the sink and then | |
| 52 // deletes it. | |
| 53 virtual bool Send(IPC::Message* message); | |
| 54 | |
| 55 // Used by the source of the messages to send the message to the sink. This | |
| 56 // will make a copy of the message and store it in the list. | |
| 57 bool OnMessageReceived(const Message& msg); | |
| 58 | |
| 59 // Returns the number of messages in the queue. | |
| 60 size_t message_count() const { return messages_.size(); } | |
| 61 | |
| 62 // Clears the message queue of saved messages. | |
| 63 void ClearMessages(); | |
| 64 | |
| 65 // Returns the message at the given index in the queue. The index may be out | |
| 66 // of range, in which case the return value is NULL. The returned pointer will | |
| 67 // only be valid until another message is received or the list is cleared. | |
| 68 const Message* GetMessageAt(size_t index) const; | |
| 69 | |
| 70 // Returns the first message with the given ID in the queue. If there is no | |
| 71 // message with the given ID, returns NULL. The returned pointer will only be | |
| 72 // valid until another message is received or the list is cleared. | |
| 73 const Message* GetFirstMessageMatching(uint32 id) const; | |
| 74 | |
| 75 // Returns the message with the given ID in the queue. If there is no such | |
| 76 // message or there is more than one of that message, this will return NULL | |
| 77 // (with the expectation that you'll do an ASSERT_TRUE() on the result). | |
| 78 // The returned pointer will only be valid until another message is received | |
| 79 // or the list is cleared. | |
| 80 const Message* GetUniqueMessageMatching(uint32 id) const; | |
| 81 | |
| 82 private: | |
| 83 // The actual list of received messages. | |
| 84 std::vector<Message> messages_; | |
| 85 | |
| 86 DISALLOW_COPY_AND_ASSIGN(TestSink); | |
| 87 }; | |
| 88 | |
| 89 } // namespace IPC | |
| 90 | |
| 91 #endif // CHROME_COMMON_IPC_TEST_SINK_H_ | |
| OLD | NEW |