diff options
author | rsleevi@chromium.org <rsleevi@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2013-02-06 10:08:55 +0000 |
---|---|---|
committer | rsleevi@chromium.org <rsleevi@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2013-02-06 10:08:55 +0000 |
commit | bbe1169c32700c8de2e777bededa7b2fe83ee7a1 (patch) | |
tree | d2cbaf3fe34b498ce8662307d086fe203d173a6f | |
parent | f8560ac4123f17bb781528321090121e74d0c90a (diff) | |
download | chromium_src-bbe1169c32700c8de2e777bededa7b2fe83ee7a1.zip chromium_src-bbe1169c32700c8de2e777bededa7b2fe83ee7a1.tar.gz chromium_src-bbe1169c32700c8de2e777bededa7b2fe83ee7a1.tar.bz2 |
Linux/ChromeOS Chromium style checker cleanup, ipc/ edition.
Automated clean up of style checker errors that were missed due to the plugin
not being executed on implementation files.
BUG=115047
Review URL: https://chromiumcodereview.appspot.com/12220032
git-svn-id: svn://svn.chromium.org/chrome/trunk/src@180954 0039d316-1c4b-4281-b951-d872f2087c98
-rw-r--r-- | ipc/ipc_fuzzing_tests.cc | 4 | ||||
-rw-r--r-- | ipc/ipc_perftests.cc | 8 | ||||
-rw-r--r-- | ipc/ipc_send_fds_test.cc | 4 | ||||
-rw-r--r-- | ipc/ipc_sync_channel_unittest.cc | 100 | ||||
-rw-r--r-- | ipc/sync_socket_unittest.cc | 4 |
5 files changed, 60 insertions, 60 deletions
diff --git a/ipc/ipc_fuzzing_tests.cc b/ipc/ipc_fuzzing_tests.cc index 030709e..1b06b7e2 100644 --- a/ipc/ipc_fuzzing_tests.cc +++ b/ipc/ipc_fuzzing_tests.cc @@ -135,7 +135,7 @@ class FuzzerServerListener : public SimpleListener { public: FuzzerServerListener() : message_count_(2), pending_messages_(0) { } - virtual bool OnMessageReceived(const IPC::Message& msg) { + virtual bool OnMessageReceived(const IPC::Message& msg) OVERRIDE { if (msg.routing_id() == MSG_ROUTING_CONTROL) { ++pending_messages_; IPC_BEGIN_MESSAGE_MAP(FuzzerServerListener, msg) @@ -199,7 +199,7 @@ class FuzzerClientListener : public SimpleListener { FuzzerClientListener() : last_msg_(NULL) { } - virtual bool OnMessageReceived(const IPC::Message& msg) { + virtual bool OnMessageReceived(const IPC::Message& msg) OVERRIDE { last_msg_ = new IPC::Message(msg); MessageLoop::current()->Quit(); return true; diff --git a/ipc/ipc_perftests.cc b/ipc/ipc_perftests.cc index a24c47d..cc222be 100644 --- a/ipc/ipc_perftests.cc +++ b/ipc/ipc_perftests.cc @@ -86,7 +86,7 @@ class ChannelReflectorListener : public IPC::Listener { VLOG(1) << "Client listener up"; } - ~ChannelReflectorListener() { + virtual ~ChannelReflectorListener() { VLOG(1) << "Client listener down"; latency_tracker_.ShowResults(); } @@ -96,7 +96,7 @@ class ChannelReflectorListener : public IPC::Listener { channel_ = channel; } - virtual bool OnMessageReceived(const IPC::Message& message) { + virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE { CHECK(channel_); PickleIterator iter(message); @@ -146,7 +146,7 @@ class PerformanceChannelListener : public IPC::Listener { VLOG(1) << "Server listener up"; } - ~PerformanceChannelListener() { + virtual ~PerformanceChannelListener() { VLOG(1) << "Server listener down"; } @@ -164,7 +164,7 @@ class PerformanceChannelListener : public IPC::Listener { payload_ = std::string(msg_size_, 'a'); } - virtual bool OnMessageReceived(const IPC::Message& message) { + virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE { CHECK(channel_); PickleIterator iter(message); diff --git a/ipc/ipc_send_fds_test.cc b/ipc/ipc_send_fds_test.cc index 5699e6d..75d1629 100644 --- a/ipc/ipc_send_fds_test.cc +++ b/ipc/ipc_send_fds_test.cc @@ -49,7 +49,7 @@ class MyChannelDescriptorListener : public IPC::Listener { : expected_inode_num_(expected_inode_num), num_fds_received_(0) {} - virtual bool OnMessageReceived(const IPC::Message& message) { + virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE { PickleIterator iter(message); ++num_fds_received_; @@ -64,7 +64,7 @@ class MyChannelDescriptorListener : public IPC::Listener { return true; } - virtual void OnChannelError() { + virtual void OnChannelError() OVERRIDE { MessageLoop::current()->Quit(); } diff --git a/ipc/ipc_sync_channel_unittest.cc b/ipc/ipc_sync_channel_unittest.cc index c98d691..66f369e 100644 --- a/ipc/ipc_sync_channel_unittest.cc +++ b/ipc/ipc_sync_channel_unittest.cc @@ -65,7 +65,7 @@ class Worker : public Listener, public Sender { } void AddRef() { } void Release() { } - bool Send(Message* msg) { return channel_->Send(msg); } + virtual bool Send(Message* msg) OVERRIDE { return channel_->Send(msg); } bool SendWithTimeout(Message* msg, int timeout_ms) { return channel_->SendWithTimeout(msg, timeout_ms); } @@ -203,7 +203,7 @@ class Worker : public Listener, public Sender { listener_event->Signal(); } - bool OnMessageReceived(const Message& message) { + virtual bool OnMessageReceived(const Message& message) OVERRIDE { IPC_BEGIN_MESSAGE_MAP(Worker, message) IPC_MESSAGE_HANDLER_DELAY_REPLY(SyncChannelTestMsg_Double, OnDoubleDelay) IPC_MESSAGE_HANDLER_DELAY_REPLY(SyncChannelTestMsg_AnswerToLife, @@ -277,7 +277,7 @@ class SimpleServer : public Worker { explicit SimpleServer(bool pump_during_send) : Worker(Channel::MODE_SERVER, "simpler_server"), pump_during_send_(pump_during_send) { } - void Run() { + virtual void Run() OVERRIDE { SendAnswerToLife(pump_during_send_, base::kNoTimeout, true); Done(); } @@ -289,7 +289,7 @@ class SimpleClient : public Worker { public: SimpleClient() : Worker(Channel::MODE_CLIENT, "simple_client") { } - void OnAnswer(int* answer) { + virtual void OnAnswer(int* answer) OVERRIDE { *answer = 42; Done(); } @@ -319,12 +319,12 @@ class TwoStepServer : public Worker { : Worker(Channel::MODE_SERVER, "simpler_server"), create_pipe_now_(create_pipe_now) { } - void Run() { + virtual void Run() OVERRIDE { SendAnswerToLife(false, base::kNoTimeout, true); Done(); } - virtual SyncChannel* CreateChannel() { + virtual SyncChannel* CreateChannel() OVERRIDE { SyncChannel* channel = new SyncChannel( this, ipc_thread().message_loop_proxy(), shutdown_event()); channel->Init(channel_name(), mode(), create_pipe_now_); @@ -340,12 +340,12 @@ class TwoStepClient : public Worker { : Worker(Channel::MODE_CLIENT, "simple_client"), create_pipe_now_(create_pipe_now) { } - void OnAnswer(int* answer) { + virtual void OnAnswer(int* answer) OVERRIDE { *answer = 42; Done(); } - virtual SyncChannel* CreateChannel() { + virtual SyncChannel* CreateChannel() OVERRIDE { SyncChannel* channel = new SyncChannel( this, ipc_thread().message_loop_proxy(), shutdown_event()); channel->Init(channel_name(), mode(), create_pipe_now_); @@ -377,7 +377,7 @@ class DelayClient : public Worker { public: DelayClient() : Worker(Channel::MODE_CLIENT, "delay_client") { } - void OnAnswerDelay(Message* reply_msg) { + virtual void OnAnswerDelay(Message* reply_msg) OVERRIDE { SyncChannelTestMsg_AnswerToLife::WriteReplyParams(reply_msg, 42); Send(reply_msg); Done(); @@ -405,7 +405,7 @@ class NoHangServer : public Worker { : Worker(Channel::MODE_SERVER, "no_hang_server"), got_first_reply_(got_first_reply), pump_during_send_(pump_during_send) { } - void Run() { + virtual void Run() OVERRIDE { SendAnswerToLife(pump_during_send_, base::kNoTimeout, true); got_first_reply_->Signal(); @@ -423,7 +423,7 @@ class NoHangClient : public Worker { : Worker(Channel::MODE_CLIENT, "no_hang_client"), got_first_reply_(got_first_reply) { } - virtual void OnAnswerDelay(Message* reply_msg) { + virtual void OnAnswerDelay(Message* reply_msg) OVERRIDE { // Use the DELAY_REPLY macro so that we can force the reply to be sent // before this function returns (when the channel will be reset). SyncChannelTestMsg_AnswerToLife::WriteReplyParams(reply_msg, 42); @@ -458,7 +458,7 @@ class UnblockServer : public Worker { : Worker(Channel::MODE_SERVER, "unblock_server"), pump_during_send_(pump_during_send), delete_during_send_(delete_during_send) { } - void Run() { + virtual void Run() OVERRIDE { if (delete_during_send_) { // Use custom code since race conditions mean the answer may or may not be // available. @@ -473,7 +473,7 @@ class UnblockServer : public Worker { Done(); } - void OnDoubleDelay(int in, Message* reply_msg) { + virtual void OnDoubleDelay(int in, Message* reply_msg) OVERRIDE { SyncChannelTestMsg_Double::WriteReplyParams(reply_msg, in * 2); Send(reply_msg); if (delete_during_send_) @@ -490,7 +490,7 @@ class UnblockClient : public Worker { : Worker(Channel::MODE_CLIENT, "unblock_client"), pump_during_send_(pump_during_send) { } - void OnAnswer(int* answer) { + virtual void OnAnswer(int* answer) OVERRIDE { SendDouble(pump_during_send_, true); *answer = 42; Done(); @@ -532,12 +532,12 @@ class RecursiveServer : public Worker { : Worker(Channel::MODE_SERVER, "recursive_server"), expected_send_result_(expected_send_result), pump_first_(pump_first), pump_second_(pump_second) {} - void Run() { + virtual void Run() OVERRIDE { SendDouble(pump_first_, expected_send_result_); Done(); } - void OnDouble(int in, int* out) { + virtual void OnDouble(int in, int* out) OVERRIDE { *out = in * 2; SendAnswerToLife(pump_second_, base::kNoTimeout, expected_send_result_); } @@ -551,7 +551,7 @@ class RecursiveClient : public Worker { : Worker(Channel::MODE_CLIENT, "recursive_client"), pump_during_send_(pump_during_send), close_channel_(close_channel) {} - void OnDoubleDelay(int in, Message* reply_msg) { + virtual void OnDoubleDelay(int in, Message* reply_msg) OVERRIDE { SendDouble(pump_during_send_, !close_channel_); if (close_channel_) { delete reply_msg; @@ -562,7 +562,7 @@ class RecursiveClient : public Worker { Done(); } - void OnAnswerDelay(Message* reply_msg) { + virtual void OnAnswerDelay(Message* reply_msg) OVERRIDE { if (close_channel_) { delete reply_msg; CloseChannel(); @@ -628,7 +628,7 @@ class MultipleServer1 : public Worker { : Worker("test_channel1", Channel::MODE_SERVER), pump_during_send_(pump_during_send) { } - void Run() { + virtual void Run() OVERRIDE { SendDouble(pump_during_send_, true); Done(); } @@ -644,7 +644,7 @@ class MultipleClient1 : public Worker { client1_msg_received_(client1_msg_received), client1_can_reply_(client1_can_reply) { } - void OnDouble(int in, int* out) { + virtual void OnDouble(int in, int* out) OVERRIDE { client1_msg_received_->Signal(); *out = in * 2; client1_can_reply_->Wait(); @@ -659,7 +659,7 @@ class MultipleServer2 : public Worker { public: MultipleServer2() : Worker("test_channel2", Channel::MODE_SERVER) { } - void OnAnswer(int* result) { + virtual void OnAnswer(int* result) OVERRIDE { *result = 42; Done(); } @@ -675,7 +675,7 @@ class MultipleClient2 : public Worker { client1_can_reply_(client1_can_reply), pump_during_send_(pump_during_send) { } - void Run() { + virtual void Run() OVERRIDE { client1_msg_received_->Wait(); SendAnswerToLife(pump_during_send_, base::kNoTimeout, true); client1_can_reply_->Signal(); @@ -745,7 +745,7 @@ class QueuedReplyServer : public Worker { Worker::OverrideThread(listener_thread); } - virtual void OnNestedTestMsg(Message* reply_msg) { + virtual void OnNestedTestMsg(Message* reply_msg) OVERRIDE { VLOG(1) << __FUNCTION__ << " Sending reply: " << reply_text_; SyncChannelNestedTestMsg_String::WriteReplyParams(reply_msg, reply_text_); Send(reply_msg); @@ -774,7 +774,7 @@ class QueuedReplyClient : public Worker { Worker::OverrideThread(listener_thread); } - virtual void Run() { + virtual void Run() OVERRIDE { std::string response; SyncMessage* msg = new SyncChannelNestedTestMsg_String(&response); if (pump_during_send_) @@ -847,7 +847,7 @@ class ChattyClient : public Worker { ChattyClient() : Worker(Channel::MODE_CLIENT, "chatty_client") { } - void OnAnswer(int* answer) { + virtual void OnAnswer(int* answer) OVERRIDE { // The PostMessage limit is 10k. Send 20% more than that. const int kMessageLimit = 10000; const int kMessagesToSend = kMessageLimit * 120 / 100; @@ -888,7 +888,7 @@ class TimeoutServer : public Worker { pump_during_send_(pump_during_send) { } - void Run() { + virtual void Run() OVERRIDE { for (std::vector<bool>::const_iterator iter = timeout_seq_.begin(); iter != timeout_seq_.end(); ++iter) { SendAnswerToLife(pump_during_send_, timeout_ms_, !*iter); @@ -909,7 +909,7 @@ class UnresponsiveClient : public Worker { timeout_seq_(timeout_seq) { } - void OnAnswerDelay(Message* reply_msg) { + virtual void OnAnswerDelay(Message* reply_msg) OVERRIDE { DCHECK(!timeout_seq_.empty()); if (!timeout_seq_[0]) { SyncChannelTestMsg_AnswerToLife::WriteReplyParams(reply_msg, 42); @@ -1001,7 +1001,7 @@ class DoneEventRaceServer : public Worker { DoneEventRaceServer() : Worker(Channel::MODE_SERVER, "done_event_race_server") { } - void Run() { + virtual void Run() OVERRIDE { MessageLoop::current()->PostTask(FROM_HERE, base::Bind(&NestedCallback, this)); MessageLoop::current()->PostDelayedTask( @@ -1040,7 +1040,7 @@ class TestSyncMessageFilter : public SyncMessageFilter { message_loop_(message_loop) { } - virtual void OnFilterAdded(Channel* channel) { + virtual void OnFilterAdded(Channel* channel) OVERRIDE { SyncMessageFilter::OnFilterAdded(channel); message_loop_->PostTask( FROM_HERE, @@ -1075,7 +1075,7 @@ class SyncMessageFilterServer : public Worker { thread_.message_loop_proxy()); } - void Run() { + virtual void Run() OVERRIDE { channel()->AddFilter(filter_.get()); } @@ -1104,12 +1104,12 @@ class ServerSendAfterClose : public Worker { } private: - virtual void Run() { + virtual void Run() OVERRIDE { CloseChannel(); Done(); } - bool Send(Message* msg) { + virtual bool Send(Message* msg) OVERRIDE { send_result_ = Worker::Send(msg); Done(); return send_result_; @@ -1171,7 +1171,7 @@ class RestrictedDispatchServer : public Worker { base::Thread* ListenerThread() { return Worker::ListenerThread(); } private: - bool OnMessageReceived(const Message& message) { + virtual bool OnMessageReceived(const Message& message) OVERRIDE { IPC_BEGIN_MESSAGE_MAP(RestrictedDispatchServer, message) IPC_MESSAGE_HANDLER(SyncChannelTestMsg_NoArgs, OnNoArgs) IPC_MESSAGE_HANDLER(SyncChannelTestMsg_PingTTL, OnPingTTL) @@ -1204,7 +1204,7 @@ class NonRestrictedDispatchServer : public Worker { } private: - bool OnMessageReceived(const Message& message) { + virtual bool OnMessageReceived(const Message& message) OVERRIDE { IPC_BEGIN_MESSAGE_MAP(NonRestrictedDispatchServer, message) IPC_MESSAGE_HANDLER(SyncChannelTestMsg_NoArgs, OnNoArgs) IPC_MESSAGE_HANDLER(SyncChannelTestMsg_Done, Done) @@ -1229,7 +1229,7 @@ class RestrictedDispatchClient : public Worker { success_(success), sent_ping_event_(sent_ping_event) {} - void Run() { + virtual void Run() OVERRIDE { // Incoming messages from our channel should only be dispatched when we // send a message on that same channel. channel()->SetRestrictDispatchChannelGroup(1); @@ -1289,7 +1289,7 @@ class RestrictedDispatchClient : public Worker { } private: - bool OnMessageReceived(const Message& message) { + virtual bool OnMessageReceived(const Message& message) OVERRIDE { IPC_BEGIN_MESSAGE_MAP(RestrictedDispatchClient, message) IPC_MESSAGE_HANDLER(SyncChannelTestMsg_Ping, OnPing) IPC_MESSAGE_HANDLER_DELAY_REPLY(SyncChannelTestMsg_PingTTL, OnPingTTL) @@ -1383,7 +1383,7 @@ class RestrictedDispatchDeadlockServer : public Worker { SendMessageToClient(); } - void Run() { + virtual void Run() OVERRIDE { channel()->SetRestrictDispatchChannelGroup(1); server_ready_event_->Signal(); } @@ -1391,7 +1391,7 @@ class RestrictedDispatchDeadlockServer : public Worker { base::Thread* ListenerThread() { return Worker::ListenerThread(); } private: - bool OnMessageReceived(const Message& message) { + virtual bool OnMessageReceived(const Message& message) OVERRIDE { IPC_BEGIN_MESSAGE_MAP(RestrictedDispatchDeadlockServer, message) IPC_MESSAGE_HANDLER(SyncChannelTestMsg_NoArgs, OnNoArgs) IPC_MESSAGE_HANDLER(SyncChannelTestMsg_Done, Done) @@ -1431,7 +1431,7 @@ class RestrictedDispatchDeadlockClient2 : public Worker { received_noarg_reply_(false), done_issued_(false) {} - void Run() { + virtual void Run() OVERRIDE { server_ready_event_->Wait(); } @@ -1449,7 +1449,7 @@ class RestrictedDispatchDeadlockClient2 : public Worker { base::Thread* ListenerThread() { return Worker::ListenerThread(); } private: - bool OnMessageReceived(const Message& message) { + virtual bool OnMessageReceived(const Message& message) OVERRIDE { IPC_BEGIN_MESSAGE_MAP(RestrictedDispatchDeadlockClient2, message) IPC_MESSAGE_HANDLER(SyncChannelTestMsg_NoArgs, OnNoArgs) IPC_END_MESSAGE_MAP() @@ -1492,7 +1492,7 @@ class RestrictedDispatchDeadlockClient1 : public Worker { received_noarg_reply_(false), done_issued_(false) {} - void Run() { + virtual void Run() OVERRIDE { server_ready_event_->Wait(); server_->ListenerThread()->message_loop()->PostTask( FROM_HERE, @@ -1513,7 +1513,7 @@ class RestrictedDispatchDeadlockClient1 : public Worker { base::Thread* ListenerThread() { return Worker::ListenerThread(); } private: - bool OnMessageReceived(const Message& message) { + virtual bool OnMessageReceived(const Message& message) OVERRIDE { IPC_BEGIN_MESSAGE_MAP(RestrictedDispatchDeadlockClient1, message) IPC_MESSAGE_HANDLER(SyncChannelTestMsg_NoArgs, OnNoArgs) IPC_END_MESSAGE_MAP() @@ -1626,7 +1626,7 @@ class RestrictedDispatchPipeWorker : public Worker { Done(); } - void Run() { + virtual void Run() OVERRIDE { channel()->SetRestrictDispatchChannelGroup(group_); if (is_first()) event1_->Signal(); @@ -1655,7 +1655,7 @@ class RestrictedDispatchPipeWorker : public Worker { bool is_first() { return !!success_; } private: - bool OnMessageReceived(const Message& message) { + virtual bool OnMessageReceived(const Message& message) OVERRIDE { IPC_BEGIN_MESSAGE_MAP(RestrictedDispatchPipeWorker, message) IPC_MESSAGE_HANDLER(SyncChannelTestMsg_PingTTL, OnPingTTL) IPC_MESSAGE_HANDLER(SyncChannelTestMsg_Done, OnDone) @@ -1706,7 +1706,7 @@ class ReentrantReplyServer1 : public Worker { : Worker("reentrant_reply1", Channel::MODE_SERVER), server_ready_(server_ready) { } - void Run() { + virtual void Run() OVERRIDE { server2_channel_.reset(new SyncChannel( "reentrant_reply2", Channel::MODE_CLIENT, this, ipc_thread().message_loop_proxy(), true, shutdown_event())); @@ -1718,7 +1718,7 @@ class ReentrantReplyServer1 : public Worker { } private: - bool OnMessageReceived(const Message& message) { + virtual bool OnMessageReceived(const Message& message) OVERRIDE { IPC_BEGIN_MESSAGE_MAP(ReentrantReplyServer1, message) IPC_MESSAGE_HANDLER(SyncChannelTestMsg_Reentrant2, OnReentrant2) IPC_REPLY_HANDLER(OnReply) @@ -1748,7 +1748,7 @@ class ReentrantReplyServer2 : public Worker { reply_(NULL) { } private: - bool OnMessageReceived(const Message& message) { + virtual bool OnMessageReceived(const Message& message) OVERRIDE { IPC_BEGIN_MESSAGE_MAP(ReentrantReplyServer2, message) IPC_MESSAGE_HANDLER_DELAY_REPLY( SyncChannelTestMsg_Reentrant1, OnReentrant1) @@ -1780,7 +1780,7 @@ class ReentrantReplyClient : public Worker { : Worker("reentrant_reply1", Channel::MODE_CLIENT), server_ready_(server_ready) { } - void Run() { + virtual void Run() OVERRIDE { server_ready_->Wait(); Send(new SyncChannelTestMsg_Reentrant2()); Done(); @@ -1813,7 +1813,7 @@ class VerifiedServer : public Worker { Worker::OverrideThread(listener_thread); } - virtual void OnNestedTestMsg(Message* reply_msg) { + virtual void OnNestedTestMsg(Message* reply_msg) OVERRIDE { VLOG(1) << __FUNCTION__ << " Sending reply: " << reply_text_; SyncChannelNestedTestMsg_String::WriteReplyParams(reply_msg, reply_text_); Send(reply_msg); @@ -1835,7 +1835,7 @@ class VerifiedClient : public Worker { Worker::OverrideThread(listener_thread); } - virtual void Run() { + virtual void Run() OVERRIDE { std::string response; SyncMessage* msg = new SyncChannelNestedTestMsg_String(&response); bool result = Send(msg); diff --git a/ipc/sync_socket_unittest.cc b/ipc/sync_socket_unittest.cc index 57ba326..5555abb 100644 --- a/ipc/sync_socket_unittest.cc +++ b/ipc/sync_socket_unittest.cc @@ -59,7 +59,7 @@ class SyncSocketServerListener : public IPC::Listener { chan_ = chan; } - virtual bool OnMessageReceived(const IPC::Message& msg) { + virtual bool OnMessageReceived(const IPC::Message& msg) OVERRIDE { if (msg.routing_id() == MSG_ROUTING_CONTROL) { IPC_BEGIN_MESSAGE_MAP(SyncSocketServerListener, msg) IPC_MESSAGE_HANDLER(MsgClassSetHandle, OnMsgClassSetHandle) @@ -130,7 +130,7 @@ class SyncSocketClientListener : public IPC::Listener { chan_ = chan; } - virtual bool OnMessageReceived(const IPC::Message& msg) { + virtual bool OnMessageReceived(const IPC::Message& msg) OVERRIDE { if (msg.routing_id() == MSG_ROUTING_CONTROL) { IPC_BEGIN_MESSAGE_MAP(SyncSocketClientListener, msg) IPC_MESSAGE_HANDLER(MsgClassResponse, OnMsgClassResponse) |