diff --git a/ipc/ipc_channel.h b/ipc/ipc_channel.h index a7982e5554f1..2d8d449c26e9 100644 --- a/ipc/ipc_channel.h +++ b/ipc/ipc_channel.h @@ -143,8 +143,7 @@ class IPC_EXPORT Channel : public Sender { static scoped_ptr CreateServer( const IPC::ChannelHandle &channel_handle, Listener* listener); - - virtual ~Channel(); + ~Channel() override; // Connect the pipe. On the server side, this will initiate // waiting for connections. On the client, it attempts to diff --git a/ipc/ipc_channel_factory.cc b/ipc/ipc_channel_factory.cc index f553203b1238..9bcaa75c3e75 100644 --- a/ipc/ipc_channel_factory.cc +++ b/ipc/ipc_channel_factory.cc @@ -15,12 +15,9 @@ class PlatformChannelFactory : public ChannelFactory { : handle_(handle), mode_(mode) { } - virtual std::string GetName() const override { - return handle_.name; - } + std::string GetName() const override { return handle_.name; } - virtual scoped_ptr BuildChannel( - Listener* listener) override { + scoped_ptr BuildChannel(Listener* listener) override { return Channel::Create(handle_, mode_, listener); } diff --git a/ipc/ipc_channel_posix.h b/ipc/ipc_channel_posix.h index 717e43ee05fa..1cb76102c390 100644 --- a/ipc/ipc_channel_posix.h +++ b/ipc/ipc_channel_posix.h @@ -56,16 +56,16 @@ class IPC_EXPORT ChannelPosix : public Channel, public: ChannelPosix(const IPC::ChannelHandle& channel_handle, Mode mode, Listener* listener); - virtual ~ChannelPosix(); + ~ChannelPosix() override; // Channel implementation - virtual bool Connect() override; - virtual void Close() override; - virtual bool Send(Message* message) override; - virtual base::ProcessId GetPeerPID() const override; - virtual base::ProcessId GetSelfPID() const override; - virtual int GetClientFileDescriptor() const override; - virtual base::ScopedFD TakeClientFileDescriptor() override; + bool Connect() override; + void Close() override; + bool Send(Message* message) override; + base::ProcessId GetPeerPID() const override; + base::ProcessId GetSelfPID() const override; + int GetClientFileDescriptor() const override; + base::ScopedFD TakeClientFileDescriptor() override; // Returns true if the channel supports listening for connections. bool AcceptsConnections() const; @@ -102,12 +102,10 @@ class IPC_EXPORT ChannelPosix : public Channel, void QueueCloseFDMessage(int fd, int hops); // ChannelReader implementation. - virtual ReadState ReadData(char* buffer, - int buffer_len, - int* bytes_read) override; - virtual bool WillDispatchInputMessage(Message* msg) override; - virtual bool DidEmptyInputBuffers() override; - virtual void HandleInternalMessage(const Message& msg) override; + ReadState ReadData(char* buffer, int buffer_len, int* bytes_read) override; + bool WillDispatchInputMessage(Message* msg) override; + bool DidEmptyInputBuffers() override; + void HandleInternalMessage(const Message& msg) override; #if defined(IPC_USES_READWRITE) // Reads the next message from the fd_pipe_ and appends them to the @@ -129,8 +127,8 @@ class IPC_EXPORT ChannelPosix : public Channel, void ClearInputFDs(); // MessageLoopForIO::Watcher implementation. - virtual void OnFileCanReadWithoutBlocking(int fd) override; - virtual void OnFileCanWriteWithoutBlocking(int fd) override; + void OnFileCanReadWithoutBlocking(int fd) override; + void OnFileCanWriteWithoutBlocking(int fd) override; Mode mode_; diff --git a/ipc/ipc_channel_posix_unittest.cc b/ipc/ipc_channel_posix_unittest.cc index d5346b9b7c6b..786623b80622 100644 --- a/ipc/ipc_channel_posix_unittest.cc +++ b/ipc/ipc_channel_posix_unittest.cc @@ -45,35 +45,35 @@ class IPCChannelPosixTestListener : public IPC::Listener { quit_only_on_message_(quit_only_on_message) { } - virtual ~IPCChannelPosixTestListener() {} + ~IPCChannelPosixTestListener() override {} - virtual bool OnMessageReceived(const IPC::Message& message) override { + bool OnMessageReceived(const IPC::Message& message) override { EXPECT_EQ(message.type(), kQuitMessage); status_ = MESSAGE_RECEIVED; QuitRunLoop(); return true; } - virtual void OnChannelConnected(int32 peer_pid) override { + void OnChannelConnected(int32 peer_pid) override { status_ = CONNECTED; if (!quit_only_on_message_) { QuitRunLoop(); } } - virtual void OnChannelError() override { + void OnChannelError() override { status_ = CHANNEL_ERROR; QuitRunLoop(); } - virtual void OnChannelDenied() override { + void OnChannelDenied() override { status_ = DENIED; if (!quit_only_on_message_) { QuitRunLoop(); } } - virtual void OnChannelListenError() override { + void OnChannelListenError() override { status_ = LISTEN_ERROR; if (!quit_only_on_message_) { QuitRunLoop(); diff --git a/ipc/ipc_channel_proxy.h b/ipc/ipc_channel_proxy.h index 84abc6536adb..71a014bd1bfc 100644 --- a/ipc/ipc_channel_proxy.h +++ b/ipc/ipc_channel_proxy.h @@ -76,7 +76,7 @@ class IPC_EXPORT ChannelProxy : public Sender, public base::NonThreadSafe { Listener* listener, const scoped_refptr& ipc_task_runner); - virtual ~ChannelProxy(); + ~ChannelProxy() override; // Initializes the channel proxy. Only call this once to initialize a channel // proxy that was not initialized in its constructor. If create_pipe_now is @@ -98,7 +98,7 @@ class IPC_EXPORT ChannelProxy : public Sender, public base::NonThreadSafe { // Send a message asynchronously. The message is routed to the background // thread where it is passed to the IPC::Channel's Send method. - virtual bool Send(Message* message) override; + bool Send(Message* message) override; // Used to intercept messages as they are received on the background thread. // @@ -152,12 +152,12 @@ class IPC_EXPORT ChannelProxy : public Sender, public base::NonThreadSafe { protected: friend class base::RefCountedThreadSafe; - virtual ~Context(); + ~Context() override; // IPC::Listener methods: - virtual bool OnMessageReceived(const Message& message) override; - virtual void OnChannelConnected(int32 peer_pid) override; - virtual void OnChannelError() override; + bool OnMessageReceived(const Message& message) override; + void OnChannelConnected(int32 peer_pid) override; + void OnChannelError() override; // Like OnMessageReceived but doesn't try the filters. bool OnMessageReceivedNoFilter(const Message& message); diff --git a/ipc/ipc_channel_proxy_unittest.cc b/ipc/ipc_channel_proxy_unittest.cc index 9042f44d3f7e..848367ec782b 100644 --- a/ipc/ipc_channel_proxy_unittest.cc +++ b/ipc/ipc_channel_proxy_unittest.cc @@ -47,9 +47,9 @@ namespace { class QuitListener : public IPC::Listener { public: QuitListener() : bad_message_received_(false) {} - virtual ~QuitListener() {} + ~QuitListener() override {} - virtual bool OnMessageReceived(const IPC::Message& message) override { + bool OnMessageReceived(const IPC::Message& message) override { IPC_BEGIN_MESSAGE_MAP(QuitListener, message) IPC_MESSAGE_HANDLER(WorkerMsg_Quit, OnQuit) IPC_MESSAGE_HANDLER(TestMsg_BadMessage, OnBadMessage) @@ -57,7 +57,7 @@ class QuitListener : public IPC::Listener { return true; } - virtual void OnBadMessageReceived(const IPC::Message& message) override { + void OnBadMessageReceived(const IPC::Message& message) override { bad_message_received_ = true; } @@ -76,14 +76,14 @@ class QuitListener : public IPC::Listener { class ChannelReflectorListener : public IPC::Listener { public: ChannelReflectorListener() : channel_(NULL) {} - virtual ~ChannelReflectorListener() {} + ~ChannelReflectorListener() override {} void Init(IPC::Channel* channel) { DCHECK(!channel_); channel_ = channel; } - virtual bool OnMessageReceived(const IPC::Message& message) override { + bool OnMessageReceived(const IPC::Message& message) override { IPC_BEGIN_MESSAGE_MAP(ChannelReflectorListener, message) IPC_MESSAGE_HANDLER(TestMsg_Bounce, OnTestBounce) IPC_MESSAGE_HANDLER(TestMsg_SendBadMessage, OnSendBadMessage) @@ -143,24 +143,24 @@ class MessageCountFilter : public IPC::MessageFilter { last_filter_event_(NONE), message_filtering_enabled_(false) {} - virtual void OnFilterAdded(IPC::Sender* sender) override { + void OnFilterAdded(IPC::Sender* sender) override { EXPECT_TRUE(sender); EXPECT_EQ(NONE, last_filter_event_); last_filter_event_ = FILTER_ADDED; } - virtual void OnChannelConnected(int32_t peer_pid) override { + void OnChannelConnected(int32_t peer_pid) override { EXPECT_EQ(FILTER_ADDED, last_filter_event_); EXPECT_NE(static_cast(base::kNullProcessId), peer_pid); last_filter_event_ = CHANNEL_CONNECTED; } - virtual void OnChannelError() override { + void OnChannelError() override { EXPECT_EQ(CHANNEL_CONNECTED, last_filter_event_); last_filter_event_ = CHANNEL_ERROR; } - virtual void OnChannelClosing() override { + void OnChannelClosing() override { // We may or may not have gotten OnChannelError; if not, the last event has // to be OnChannelConnected. if (last_filter_event_ != CHANNEL_ERROR) @@ -168,7 +168,7 @@ class MessageCountFilter : public IPC::MessageFilter { last_filter_event_ = CHANNEL_CLOSING; } - virtual void OnFilterRemoved() override { + void OnFilterRemoved() override { // If the channel didn't get a chance to connect, we might see the // OnFilterRemoved event with no other events preceding it. We still want // OnFilterRemoved to be called to allow for deleting the Filter. @@ -177,7 +177,7 @@ class MessageCountFilter : public IPC::MessageFilter { last_filter_event_ = FILTER_REMOVED; } - virtual bool OnMessageReceived(const IPC::Message& message) override { + bool OnMessageReceived(const IPC::Message& message) override { // We should always get the OnFilterAdded and OnChannelConnected events // prior to any messages. EXPECT_EQ(CHANNEL_CONNECTED, last_filter_event_); @@ -203,7 +203,7 @@ class MessageCountFilter : public IPC::MessageFilter { CHECK(false); } - virtual bool GetSupportedMessageClasses( + bool GetSupportedMessageClasses( std::vector* supported_message_classes) const override { if (is_global_filter_) return false; @@ -219,7 +219,7 @@ class MessageCountFilter : public IPC::MessageFilter { FilterEvent last_filter_event() const { return last_filter_event_; } private: - virtual ~MessageCountFilter() {} + ~MessageCountFilter() override {} size_t messages_received_; uint32 supported_message_class_; diff --git a/ipc/ipc_channel_unittest.cc b/ipc/ipc_channel_unittest.cc index b9d0723d434f..1b28376c935e 100644 --- a/ipc/ipc_channel_unittest.cc +++ b/ipc/ipc_channel_unittest.cc @@ -146,11 +146,9 @@ TEST_F(IPCChannelTest, ChannelProxyTest) { class ChannelListenerWithOnConnectedSend : public IPC::TestChannelListener { public: ChannelListenerWithOnConnectedSend() {} - virtual ~ChannelListenerWithOnConnectedSend() {} + ~ChannelListenerWithOnConnectedSend() override {} - virtual void OnChannelConnected(int32 peer_pid) override { - SendNextMessage(); - } + void OnChannelConnected(int32 peer_pid) override { SendNextMessage(); } }; #if defined(OS_WIN) diff --git a/ipc/ipc_forwarding_message_filter.h b/ipc/ipc_forwarding_message_filter.h index 474fbf4591ab..75080840d2f3 100644 --- a/ipc/ipc_forwarding_message_filter.h +++ b/ipc/ipc_forwarding_message_filter.h @@ -45,10 +45,10 @@ class IPC_EXPORT ForwardingMessageFilter : public MessageFilter { void RemoveRoute(int routing_id); // MessageFilter methods: - virtual bool OnMessageReceived(const Message& message) override; + bool OnMessageReceived(const Message& message) override; private: - virtual ~ForwardingMessageFilter(); + ~ForwardingMessageFilter() override; std::set message_ids_to_filter_; diff --git a/ipc/ipc_fuzzing_tests.cc b/ipc/ipc_fuzzing_tests.cc index a85491c72f22..f9475a1adb00 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) override { + 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) override { + bool OnMessageReceived(const IPC::Message& msg) override { last_msg_ = new IPC::Message(msg); base::MessageLoop::current()->Quit(); return true; diff --git a/ipc/ipc_message.h b/ipc/ipc_message.h index a48fcb1681e5..a1b26e1d289e 100644 --- a/ipc/ipc_message.h +++ b/ipc/ipc_message.h @@ -50,7 +50,7 @@ class IPC_EXPORT Message : public Pickle { HAS_SENT_TIME_BIT = 0x80, }; - virtual ~Message(); + ~Message() override; Message(); diff --git a/ipc/ipc_message_macros.h b/ipc/ipc_message_macros.h index 0978765b993d..60041559005d 100644 --- a/ipc/ipc_message_macros.h +++ b/ipc/ipc_message_macros.h @@ -600,66 +600,63 @@ typedef Schema::Param Param; \ enum { ID = IPC_MESSAGE_ID() }; \ msg_class(IPC_TYPE_IN_##in_cnt in_list); \ - virtual ~msg_class(); \ + ~msg_class() override; \ static bool Read(const Message* msg, Schema::Param* p); \ static void Log(std::string* name, const Message* msg, std::string* l); \ IPC_ASYNC_MESSAGE_METHODS_##in_cnt \ }; -#define IPC_ASYNC_ROUTED_DECL(msg_class, in_cnt, out_cnt, in_list, out_list) \ - class IPC_MESSAGE_EXPORT msg_class : public IPC::Message { \ - public: \ - typedef IPC::MessageSchema Schema; \ - typedef Schema::Param Param; \ - enum { ID = IPC_MESSAGE_ID() }; \ - msg_class(int32 routing_id IPC_COMMA_##in_cnt \ - IPC_TYPE_IN_##in_cnt in_list); \ - virtual ~msg_class(); \ - static bool Read(const Message* msg, Schema::Param* p); \ - static void Log(std::string* name, const Message* msg, std::string* l); \ - IPC_ASYNC_MESSAGE_METHODS_##in_cnt \ +#define IPC_ASYNC_ROUTED_DECL(msg_class, in_cnt, out_cnt, in_list, out_list) \ + class IPC_MESSAGE_EXPORT msg_class : public IPC::Message { \ + public: \ + typedef IPC::MessageSchema Schema; \ + typedef Schema::Param Param; \ + enum { ID = IPC_MESSAGE_ID() }; \ + msg_class(int32 routing_id \ + IPC_COMMA_##in_cnt IPC_TYPE_IN_##in_cnt in_list); \ + ~msg_class() override; \ + static bool Read(const Message* msg, Schema::Param* p); \ + static void Log(std::string* name, const Message* msg, std::string* l); \ + IPC_ASYNC_MESSAGE_METHODS_##in_cnt \ }; -#define IPC_SYNC_CONTROL_DECL(msg_class, in_cnt, out_cnt, in_list, out_list) \ - class IPC_MESSAGE_EXPORT msg_class : public IPC::SyncMessage { \ - public: \ - typedef IPC::SyncMessageSchema Schema; \ - typedef Schema::ReplyParam ReplyParam; \ - typedef Schema::SendParam SendParam; \ - enum { ID = IPC_MESSAGE_ID() }; \ - msg_class(IPC_TYPE_IN_##in_cnt in_list \ - IPC_COMMA_AND_##in_cnt(IPC_COMMA_##out_cnt) \ - IPC_TYPE_OUT_##out_cnt out_list); \ - virtual ~msg_class(); \ - static bool ReadSendParam(const Message* msg, Schema::SendParam* p); \ - static bool ReadReplyParam( \ - const Message* msg, \ - TupleTypes::ValueTuple* p); \ - static void Log(std::string* name, const Message* msg, std::string* l); \ - IPC_SYNC_MESSAGE_METHODS_##out_cnt \ +#define IPC_SYNC_CONTROL_DECL(msg_class, in_cnt, out_cnt, in_list, out_list) \ + class IPC_MESSAGE_EXPORT msg_class : public IPC::SyncMessage { \ + public: \ + typedef IPC::SyncMessageSchema Schema; \ + typedef Schema::ReplyParam ReplyParam; \ + typedef Schema::SendParam SendParam; \ + enum { ID = IPC_MESSAGE_ID() }; \ + msg_class(IPC_TYPE_IN_##in_cnt in_list \ + IPC_COMMA_AND_##in_cnt(IPC_COMMA_##out_cnt) \ + IPC_TYPE_OUT_##out_cnt out_list); \ + ~msg_class() override; \ + static bool ReadSendParam(const Message* msg, Schema::SendParam* p); \ + static bool ReadReplyParam(const Message* msg, \ + TupleTypes::ValueTuple* p); \ + static void Log(std::string* name, const Message* msg, std::string* l); \ + IPC_SYNC_MESSAGE_METHODS_##out_cnt \ }; -#define IPC_SYNC_ROUTED_DECL(msg_class, in_cnt, out_cnt, in_list, out_list) \ - class IPC_MESSAGE_EXPORT msg_class : public IPC::SyncMessage { \ - public: \ - typedef IPC::SyncMessageSchema Schema; \ - typedef Schema::ReplyParam ReplyParam; \ - typedef Schema::SendParam SendParam; \ - enum { ID = IPC_MESSAGE_ID() }; \ - msg_class(int32 routing_id \ - IPC_COMMA_OR_##in_cnt(IPC_COMMA_##out_cnt) \ - IPC_TYPE_IN_##in_cnt in_list \ - IPC_COMMA_AND_##in_cnt(IPC_COMMA_##out_cnt) \ - IPC_TYPE_OUT_##out_cnt out_list); \ - virtual ~msg_class(); \ - static bool ReadSendParam(const Message* msg, Schema::SendParam* p); \ - static bool ReadReplyParam( \ - const Message* msg, \ - TupleTypes::ValueTuple* p); \ - static void Log(std::string* name, const Message* msg, std::string* l); \ - IPC_SYNC_MESSAGE_METHODS_##out_cnt \ +#define IPC_SYNC_ROUTED_DECL(msg_class, in_cnt, out_cnt, in_list, out_list) \ + class IPC_MESSAGE_EXPORT msg_class : public IPC::SyncMessage { \ + public: \ + typedef IPC::SyncMessageSchema Schema; \ + typedef Schema::ReplyParam ReplyParam; \ + typedef Schema::SendParam SendParam; \ + enum { ID = IPC_MESSAGE_ID() }; \ + msg_class(int32 routing_id IPC_COMMA_OR_##in_cnt(IPC_COMMA_##out_cnt) \ + IPC_TYPE_IN_##in_cnt in_list \ + IPC_COMMA_AND_##in_cnt(IPC_COMMA_##out_cnt) \ + IPC_TYPE_OUT_##out_cnt out_list); \ + ~msg_class() override; \ + static bool ReadSendParam(const Message* msg, Schema::SendParam* p); \ + static bool ReadReplyParam(const Message* msg, \ + TupleTypes::ValueTuple* p); \ + static void Log(std::string* name, const Message* msg, std::string* l); \ + IPC_SYNC_MESSAGE_METHODS_##out_cnt \ }; #if defined(IPC_MESSAGE_IMPL) diff --git a/ipc/ipc_perftest_support.cc b/ipc/ipc_perftest_support.cc index e60de91ec607..ab06ed61b94b 100644 --- a/ipc/ipc_perftest_support.cc +++ b/ipc/ipc_perftest_support.cc @@ -81,7 +81,7 @@ class ChannelReflectorListener : public Listener { VLOG(1) << "Client listener up"; } - virtual ~ChannelReflectorListener() { + ~ChannelReflectorListener() override { VLOG(1) << "Client listener down"; latency_tracker_.ShowResults(); } @@ -91,7 +91,7 @@ class ChannelReflectorListener : public Listener { channel_ = channel; } - virtual bool OnMessageReceived(const Message& message) override { + bool OnMessageReceived(const Message& message) override { CHECK(channel_); PickleIterator iter(message); @@ -142,9 +142,7 @@ class PerformanceChannelListener : public Listener { VLOG(1) << "Server listener up"; } - virtual ~PerformanceChannelListener() { - VLOG(1) << "Server listener down"; - } + ~PerformanceChannelListener() override { VLOG(1) << "Server listener down"; } void Init(Sender* sender) { DCHECK(!sender_); @@ -160,7 +158,7 @@ class PerformanceChannelListener : public Listener { payload_ = std::string(msg_size_, 'a'); } - virtual bool OnMessageReceived(const Message& message) override { + bool OnMessageReceived(const Message& message) override { CHECK(sender_); PickleIterator iter(message); diff --git a/ipc/ipc_send_fds_test.cc b/ipc/ipc_send_fds_test.cc index 3961fa16e52d..332a631068e5 100644 --- a/ipc/ipc_send_fds_test.cc +++ b/ipc/ipc_send_fds_test.cc @@ -33,7 +33,7 @@ const char* kDevZeroPath = "/dev/zero"; class MyChannelDescriptorListenerBase : public IPC::Listener { public: - virtual bool OnMessageReceived(const IPC::Message& message) override { + bool OnMessageReceived(const IPC::Message& message) override { PickleIterator iter(message); base::FileDescriptor descriptor; @@ -60,12 +60,10 @@ class MyChannelDescriptorListener : public MyChannelDescriptorListenerBase { return num_fds_received_ == kNumFDsToSend; } - virtual void OnChannelError() override { - base::MessageLoop::current()->Quit(); - } + void OnChannelError() override { base::MessageLoop::current()->Quit(); } protected: - virtual void HandleFD(int fd) override { + void HandleFD(int fd) override { // Check that we can read from the FD. char buf; ssize_t amt_read = read(fd, &buf, 1); @@ -202,9 +200,7 @@ class MyCBListener : public MyChannelDescriptorListenerBase { } protected: - virtual void HandleFD(int fd) override { - cb_.Run(fd); - } + void HandleFD(int fd) override { cb_.Run(fd); } private: base::Callback cb_; }; diff --git a/ipc/ipc_sync_channel.h b/ipc/ipc_sync_channel.h index 3f62d2f35600..35934850ed7c 100644 --- a/ipc/ipc_sync_channel.h +++ b/ipc/ipc_sync_channel.h @@ -91,9 +91,9 @@ class IPC_EXPORT SyncChannel : public ChannelProxy { const scoped_refptr& ipc_task_runner, base::WaitableEvent* shutdown_event); - virtual ~SyncChannel(); + ~SyncChannel() override; - virtual bool Send(Message* message) override; + bool Send(Message* message) override; // Sets the dispatch group for this channel, to only allow re-entrant dispatch // of messages to other channels in the same group. @@ -170,17 +170,17 @@ class IPC_EXPORT SyncChannel : public ChannelProxy { base::WaitableEventWatcher::EventCallback MakeWaitableEventCallback(); private: - virtual ~SyncContext(); + ~SyncContext() override; // ChannelProxy methods that we override. // Called on the listener thread. - virtual void Clear() override; + void Clear() override; // Called on the IPC thread. - virtual bool OnMessageReceived(const Message& msg) override; - virtual void OnChannelError() override; - virtual void OnChannelOpened() override; - virtual void OnChannelClosed() override; + bool OnMessageReceived(const Message& msg) override; + void OnChannelError() override; + void OnChannelOpened() override; + void OnChannelClosed() override; // Cancels all pending Send calls. void CancelPendingSends(); diff --git a/ipc/ipc_sync_channel_unittest.cc b/ipc/ipc_sync_channel_unittest.cc index 3560d5ba0f58..9ad0e58c3be1 100644 --- a/ipc/ipc_sync_channel_unittest.cc +++ b/ipc/ipc_sync_channel_unittest.cc @@ -58,13 +58,13 @@ class Worker : public Listener, public Sender { is_shutdown_(false) { } - virtual ~Worker() { + ~Worker() override { // Shutdown() must be called before destruction. CHECK(is_shutdown_); } void AddRef() { } void Release() { } - virtual bool Send(Message* msg) override { return channel_->Send(msg); } + bool Send(Message* msg) override { return channel_->Send(msg); } void WaitForChannelCreation() { channel_created_->Wait(); } void CloseChannel() { DCHECK(base::MessageLoop::current() == ListenerThread()->message_loop()); @@ -200,7 +200,7 @@ class Worker : public Listener, public Sender { listener_event->Signal(); } - virtual bool OnMessageReceived(const Message& message) override { + 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, @@ -274,7 +274,7 @@ class SimpleServer : public Worker { explicit SimpleServer(bool pump_during_send) : Worker(Channel::MODE_SERVER, "simpler_server"), pump_during_send_(pump_during_send) { } - virtual void Run() override { + void Run() override { SendAnswerToLife(pump_during_send_, true); Done(); } @@ -286,7 +286,7 @@ class SimpleClient : public Worker { public: SimpleClient() : Worker(Channel::MODE_CLIENT, "simple_client") { } - virtual void OnAnswer(int* answer) override { + void OnAnswer(int* answer) override { *answer = 42; Done(); } @@ -316,12 +316,12 @@ class TwoStepServer : public Worker { : Worker(Channel::MODE_SERVER, "simpler_server"), create_pipe_now_(create_pipe_now) { } - virtual void Run() override { + void Run() override { SendAnswerToLife(false, true); Done(); } - virtual SyncChannel* CreateChannel() override { + SyncChannel* CreateChannel() override { SyncChannel* channel = SyncChannel::Create(channel_name(), mode(), this, ipc_thread().message_loop_proxy().get(), @@ -339,12 +339,12 @@ class TwoStepClient : public Worker { : Worker(Channel::MODE_CLIENT, "simple_client"), create_pipe_now_(create_pipe_now) { } - virtual void OnAnswer(int* answer) override { + void OnAnswer(int* answer) override { *answer = 42; Done(); } - virtual SyncChannel* CreateChannel() override { + SyncChannel* CreateChannel() override { SyncChannel* channel = SyncChannel::Create(channel_name(), mode(), this, ipc_thread().message_loop_proxy().get(), @@ -378,7 +378,7 @@ class DelayClient : public Worker { public: DelayClient() : Worker(Channel::MODE_CLIENT, "delay_client") { } - virtual void OnAnswerDelay(Message* reply_msg) override { + void OnAnswerDelay(Message* reply_msg) override { SyncChannelTestMsg_AnswerToLife::WriteReplyParams(reply_msg, 42); Send(reply_msg); Done(); @@ -406,7 +406,7 @@ class NoHangServer : public Worker { : Worker(Channel::MODE_SERVER, "no_hang_server"), got_first_reply_(got_first_reply), pump_during_send_(pump_during_send) { } - virtual void Run() override { + void Run() override { SendAnswerToLife(pump_during_send_, true); got_first_reply_->Signal(); @@ -424,7 +424,7 @@ class NoHangClient : public Worker { : Worker(Channel::MODE_CLIENT, "no_hang_client"), got_first_reply_(got_first_reply) { } - virtual void OnAnswerDelay(Message* reply_msg) override { + 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); @@ -459,7 +459,7 @@ class UnblockServer : public Worker { : Worker(Channel::MODE_SERVER, "unblock_server"), pump_during_send_(pump_during_send), delete_during_send_(delete_during_send) { } - virtual void Run() override { + void Run() override { if (delete_during_send_) { // Use custom code since race conditions mean the answer may or may not be // available. @@ -474,7 +474,7 @@ class UnblockServer : public Worker { Done(); } - virtual void OnDoubleDelay(int in, Message* reply_msg) override { + void OnDoubleDelay(int in, Message* reply_msg) override { SyncChannelTestMsg_Double::WriteReplyParams(reply_msg, in * 2); Send(reply_msg); if (delete_during_send_) @@ -491,7 +491,7 @@ class UnblockClient : public Worker { : Worker(Channel::MODE_CLIENT, "unblock_client"), pump_during_send_(pump_during_send) { } - virtual void OnAnswer(int* answer) override { + void OnAnswer(int* answer) override { SendDouble(pump_during_send_, true); *answer = 42; Done(); @@ -533,12 +533,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) {} - virtual void Run() override { + void Run() override { SendDouble(pump_first_, expected_send_result_); Done(); } - virtual void OnDouble(int in, int* out) override { + void OnDouble(int in, int* out) override { *out = in * 2; SendAnswerToLife(pump_second_, expected_send_result_); } @@ -552,7 +552,7 @@ class RecursiveClient : public Worker { : Worker(Channel::MODE_CLIENT, "recursive_client"), pump_during_send_(pump_during_send), close_channel_(close_channel) {} - virtual void OnDoubleDelay(int in, Message* reply_msg) override { + void OnDoubleDelay(int in, Message* reply_msg) override { SendDouble(pump_during_send_, !close_channel_); if (close_channel_) { delete reply_msg; @@ -563,7 +563,7 @@ class RecursiveClient : public Worker { Done(); } - virtual void OnAnswerDelay(Message* reply_msg) override { + void OnAnswerDelay(Message* reply_msg) override { if (close_channel_) { delete reply_msg; CloseChannel(); @@ -629,7 +629,7 @@ class MultipleServer1 : public Worker { : Worker("test_channel1", Channel::MODE_SERVER), pump_during_send_(pump_during_send) { } - virtual void Run() override { + void Run() override { SendDouble(pump_during_send_, true); Done(); } @@ -645,7 +645,7 @@ class MultipleClient1 : public Worker { client1_msg_received_(client1_msg_received), client1_can_reply_(client1_can_reply) { } - virtual void OnDouble(int in, int* out) override { + void OnDouble(int in, int* out) override { client1_msg_received_->Signal(); *out = in * 2; client1_can_reply_->Wait(); @@ -660,7 +660,7 @@ class MultipleServer2 : public Worker { public: MultipleServer2() : Worker("test_channel2", Channel::MODE_SERVER) { } - virtual void OnAnswer(int* result) override { + void OnAnswer(int* result) override { *result = 42; Done(); } @@ -676,7 +676,7 @@ class MultipleClient2 : public Worker { client1_can_reply_(client1_can_reply), pump_during_send_(pump_during_send) { } - virtual void Run() override { + void Run() override { client1_msg_received_->Wait(); SendAnswerToLife(pump_during_send_, true); client1_can_reply_->Signal(); @@ -746,7 +746,7 @@ class QueuedReplyServer : public Worker { Worker::OverrideThread(listener_thread); } - virtual void OnNestedTestMsg(Message* reply_msg) override { + void OnNestedTestMsg(Message* reply_msg) override { VLOG(1) << __FUNCTION__ << " Sending reply: " << reply_text_; SyncChannelNestedTestMsg_String::WriteReplyParams(reply_msg, reply_text_); Send(reply_msg); @@ -775,7 +775,7 @@ class QueuedReplyClient : public Worker { Worker::OverrideThread(listener_thread); } - virtual void Run() override { + void Run() override { std::string response; SyncMessage* msg = new SyncChannelNestedTestMsg_String(&response); if (pump_during_send_) @@ -848,7 +848,7 @@ class ChattyClient : public Worker { ChattyClient() : Worker(Channel::MODE_CLIENT, "chatty_client") { } - virtual void OnAnswer(int* answer) override { + 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; @@ -895,7 +895,7 @@ class DoneEventRaceServer : public Worker { DoneEventRaceServer() : Worker(Channel::MODE_SERVER, "done_event_race_server") { } - virtual void Run() override { + void Run() override { base::MessageLoop::current()->PostTask(FROM_HERE, base::Bind(&NestedCallback, this)); base::MessageLoop::current()->PostDelayedTask( @@ -934,7 +934,7 @@ class TestSyncMessageFilter : public SyncMessageFilter { message_loop_(message_loop) { } - virtual void OnFilterAdded(Sender* sender) override { + void OnFilterAdded(Sender* sender) override { SyncMessageFilter::OnFilterAdded(sender); message_loop_->PostTask( FROM_HERE, @@ -951,7 +951,7 @@ class TestSyncMessageFilter : public SyncMessageFilter { } private: - virtual ~TestSyncMessageFilter() {} + ~TestSyncMessageFilter() override {} Worker* worker_; scoped_refptr message_loop_; @@ -969,9 +969,7 @@ class SyncMessageFilterServer : public Worker { thread_.message_loop_proxy()); } - virtual void Run() override { - channel()->AddFilter(filter_.get()); - } + void Run() override { channel()->AddFilter(filter_.get()); } base::Thread thread_; scoped_refptr filter_; @@ -998,12 +996,12 @@ class ServerSendAfterClose : public Worker { } private: - virtual void Run() override { + void Run() override { CloseChannel(); Done(); } - virtual bool Send(Message* msg) override { + bool Send(Message* msg) override { send_result_ = Worker::Send(msg); Done(); return send_result_; @@ -1065,7 +1063,7 @@ class RestrictedDispatchServer : public Worker { base::Thread* ListenerThread() { return Worker::ListenerThread(); } private: - virtual bool OnMessageReceived(const Message& message) override { + bool OnMessageReceived(const Message& message) override { IPC_BEGIN_MESSAGE_MAP(RestrictedDispatchServer, message) IPC_MESSAGE_HANDLER(SyncChannelTestMsg_NoArgs, OnNoArgs) IPC_MESSAGE_HANDLER(SyncChannelTestMsg_PingTTL, OnPingTTL) @@ -1098,7 +1096,7 @@ class NonRestrictedDispatchServer : public Worker { } private: - virtual bool OnMessageReceived(const Message& message) override { + bool OnMessageReceived(const Message& message) override { IPC_BEGIN_MESSAGE_MAP(NonRestrictedDispatchServer, message) IPC_MESSAGE_HANDLER(SyncChannelTestMsg_NoArgs, OnNoArgs) IPC_MESSAGE_HANDLER(SyncChannelTestMsg_Done, Done) @@ -1123,7 +1121,7 @@ class RestrictedDispatchClient : public Worker { success_(success), sent_ping_event_(sent_ping_event) {} - virtual void Run() override { + void Run() override { // Incoming messages from our channel should only be dispatched when we // send a message on that same channel. channel()->SetRestrictDispatchChannelGroup(1); @@ -1187,7 +1185,7 @@ class RestrictedDispatchClient : public Worker { } private: - virtual bool OnMessageReceived(const Message& message) override { + 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) @@ -1281,7 +1279,7 @@ class RestrictedDispatchDeadlockServer : public Worker { SendMessageToClient(); } - virtual void Run() override { + void Run() override { channel()->SetRestrictDispatchChannelGroup(1); server_ready_event_->Signal(); } @@ -1289,7 +1287,7 @@ class RestrictedDispatchDeadlockServer : public Worker { base::Thread* ListenerThread() { return Worker::ListenerThread(); } private: - virtual bool OnMessageReceived(const Message& message) override { + bool OnMessageReceived(const Message& message) override { IPC_BEGIN_MESSAGE_MAP(RestrictedDispatchDeadlockServer, message) IPC_MESSAGE_HANDLER(SyncChannelTestMsg_NoArgs, OnNoArgs) IPC_MESSAGE_HANDLER(SyncChannelTestMsg_Done, Done) @@ -1329,9 +1327,7 @@ class RestrictedDispatchDeadlockClient2 : public Worker { received_noarg_reply_(false), done_issued_(false) {} - virtual void Run() override { - server_ready_event_->Wait(); - } + void Run() override { server_ready_event_->Wait(); } void OnDoClient2Task() { events_[3]->Wait(); @@ -1347,7 +1343,7 @@ class RestrictedDispatchDeadlockClient2 : public Worker { base::Thread* ListenerThread() { return Worker::ListenerThread(); } private: - virtual bool OnMessageReceived(const Message& message) override { + bool OnMessageReceived(const Message& message) override { IPC_BEGIN_MESSAGE_MAP(RestrictedDispatchDeadlockClient2, message) IPC_MESSAGE_HANDLER(SyncChannelTestMsg_NoArgs, OnNoArgs) IPC_END_MESSAGE_MAP() @@ -1390,7 +1386,7 @@ class RestrictedDispatchDeadlockClient1 : public Worker { received_noarg_reply_(false), done_issued_(false) {} - virtual void Run() override { + void Run() override { server_ready_event_->Wait(); server_->ListenerThread()->message_loop()->PostTask( FROM_HERE, @@ -1410,7 +1406,7 @@ class RestrictedDispatchDeadlockClient1 : public Worker { } private: - virtual bool OnMessageReceived(const Message& message) override { + bool OnMessageReceived(const Message& message) override { IPC_BEGIN_MESSAGE_MAP(RestrictedDispatchDeadlockClient1, message) IPC_MESSAGE_HANDLER(SyncChannelTestMsg_NoArgs, OnNoArgs) IPC_END_MESSAGE_MAP() @@ -1523,7 +1519,7 @@ class RestrictedDispatchPipeWorker : public Worker { Done(); } - virtual void Run() override { + void Run() override { channel()->SetRestrictDispatchChannelGroup(group_); if (is_first()) event1_->Signal(); @@ -1556,7 +1552,7 @@ class RestrictedDispatchPipeWorker : public Worker { bool is_first() { return !!success_; } private: - virtual bool OnMessageReceived(const Message& message) override { + bool OnMessageReceived(const Message& message) override { IPC_BEGIN_MESSAGE_MAP(RestrictedDispatchPipeWorker, message) IPC_MESSAGE_HANDLER(SyncChannelTestMsg_PingTTL, OnPingTTL) IPC_MESSAGE_HANDLER(SyncChannelTestMsg_Done, OnDone) @@ -1607,7 +1603,7 @@ class ReentrantReplyServer1 : public Worker { : Worker("reentrant_reply1", Channel::MODE_SERVER), server_ready_(server_ready) { } - virtual void Run() override { + void Run() override { server2_channel_ = SyncChannel::Create("reentrant_reply2", IPC::Channel::MODE_CLIENT, @@ -1623,7 +1619,7 @@ class ReentrantReplyServer1 : public Worker { } private: - virtual bool OnMessageReceived(const Message& message) override { + bool OnMessageReceived(const Message& message) override { IPC_BEGIN_MESSAGE_MAP(ReentrantReplyServer1, message) IPC_MESSAGE_HANDLER(SyncChannelTestMsg_Reentrant2, OnReentrant2) IPC_REPLY_HANDLER(OnReply) @@ -1653,7 +1649,7 @@ class ReentrantReplyServer2 : public Worker { reply_(NULL) { } private: - virtual bool OnMessageReceived(const Message& message) override { + bool OnMessageReceived(const Message& message) override { IPC_BEGIN_MESSAGE_MAP(ReentrantReplyServer2, message) IPC_MESSAGE_HANDLER_DELAY_REPLY( SyncChannelTestMsg_Reentrant1, OnReentrant1) @@ -1685,7 +1681,7 @@ class ReentrantReplyClient : public Worker { : Worker("reentrant_reply1", Channel::MODE_CLIENT), server_ready_(server_ready) { } - virtual void Run() override { + void Run() override { server_ready_->Wait(); Send(new SyncChannelTestMsg_Reentrant2()); Done(); @@ -1718,7 +1714,7 @@ class VerifiedServer : public Worker { Worker::OverrideThread(listener_thread); } - virtual void OnNestedTestMsg(Message* reply_msg) override { + void OnNestedTestMsg(Message* reply_msg) override { VLOG(1) << __FUNCTION__ << " Sending reply: " << reply_text_; SyncChannelNestedTestMsg_String::WriteReplyParams(reply_msg, reply_text_); Send(reply_msg); @@ -1740,7 +1736,7 @@ class VerifiedClient : public Worker { Worker::OverrideThread(listener_thread); } - virtual void Run() override { + void Run() override { std::string response; SyncMessage* msg = new SyncChannelNestedTestMsg_String(&response); bool result = Send(msg); diff --git a/ipc/ipc_sync_message.h b/ipc/ipc_sync_message.h index a74159116413..2b00f03b22b3 100644 --- a/ipc/ipc_sync_message.h +++ b/ipc/ipc_sync_message.h @@ -25,7 +25,7 @@ class IPC_EXPORT SyncMessage : public Message { public: SyncMessage(int32 routing_id, uint32 type, PriorityValue priority, MessageReplyDeserializer* deserializer); - virtual ~SyncMessage(); + ~SyncMessage() override; // Call this to get a deserializer for the output parameters. // Note that this can only be called once, and the caller is responsible diff --git a/ipc/ipc_sync_message_filter.h b/ipc/ipc_sync_message_filter.h index 015cbf8b19dc..49c3ca031719 100644 --- a/ipc/ipc_sync_message_filter.h +++ b/ipc/ipc_sync_message_filter.h @@ -31,16 +31,16 @@ class IPC_EXPORT SyncMessageFilter : public MessageFilter, public Sender { explicit SyncMessageFilter(base::WaitableEvent* shutdown_event); // MessageSender implementation. - virtual bool Send(Message* message) override; + bool Send(Message* message) override; // MessageFilter implementation. - virtual void OnFilterAdded(Sender* sender) override; - virtual void OnChannelError() override; - virtual void OnChannelClosing() override; - virtual bool OnMessageReceived(const Message& message) override; + void OnFilterAdded(Sender* sender) override; + void OnChannelError() override; + void OnChannelClosing() override; + bool OnMessageReceived(const Message& message) override; protected: - virtual ~SyncMessageFilter(); + ~SyncMessageFilter() override; private: void SendOnIOThread(Message* message); diff --git a/ipc/ipc_test_channel_listener.h b/ipc/ipc_test_channel_listener.h index 228cbf717c1a..ae5288d93d1f 100644 --- a/ipc/ipc_test_channel_listener.h +++ b/ipc/ipc_test_channel_listener.h @@ -20,10 +20,10 @@ class TestChannelListener : public Listener { static void SendOneMessage(Sender* sender, const char* text); TestChannelListener() : sender_(NULL), messages_left_(50) {} - virtual ~TestChannelListener() {} + ~TestChannelListener() override {} - virtual bool OnMessageReceived(const Message& message) override; - virtual void OnChannelError() override; + bool OnMessageReceived(const Message& message) override; + void OnChannelError() override; void Init(Sender* s) { sender_ = s; diff --git a/ipc/ipc_test_sink.h b/ipc/ipc_test_sink.h index 13386f107d99..75e582db6828 100644 --- a/ipc/ipc_test_sink.h +++ b/ipc/ipc_test_sink.h @@ -73,19 +73,19 @@ class Message; class TestSink : public Channel { public: TestSink(); - virtual ~TestSink(); + ~TestSink() override; // Interface in IPC::Channel. This copies the message to the sink and then // deletes it. - virtual bool Send(IPC::Message* message) override; - virtual bool Connect() override WARN_UNUSED_RESULT; - virtual void Close() override; - virtual base::ProcessId GetPeerPID() const override; - virtual base::ProcessId GetSelfPID() const override; + bool Send(IPC::Message* message) override; + bool Connect() override WARN_UNUSED_RESULT; + void Close() override; + base::ProcessId GetPeerPID() const override; + base::ProcessId GetSelfPID() const override; #if defined(OS_POSIX) && !defined(OS_NACL) - virtual int GetClientFileDescriptor() const override; - virtual base::ScopedFD TakeClientFileDescriptor() override; + int GetClientFileDescriptor() const override; + base::ScopedFD TakeClientFileDescriptor() override; #endif // defined(OS_POSIX) && !defined(OS_NACL) // Used by the source of the messages to send the message to the sink. This diff --git a/ipc/mojo/ipc_channel_mojo.cc b/ipc/mojo/ipc_channel_mojo.cc index a5663411e5ca..a93adf168efb 100644 --- a/ipc/mojo/ipc_channel_mojo.cc +++ b/ipc/mojo/ipc_channel_mojo.cc @@ -27,11 +27,9 @@ class MojoChannelFactory : public ChannelFactory { Channel::Mode mode) : delegate_(delegate), channel_handle_(channel_handle), mode_(mode) {} - virtual std::string GetName() const override { - return channel_handle_.name; - } + std::string GetName() const override { return channel_handle_.name; } - virtual scoped_ptr BuildChannel(Listener* listener) override { + scoped_ptr BuildChannel(Listener* listener) override { return ChannelMojo::Create(delegate_, channel_handle_, mode_, listener); } diff --git a/ipc/mojo/ipc_channel_mojo.h b/ipc/mojo/ipc_channel_mojo.h index b307fd49c6be..e5a4e335541c 100644 --- a/ipc/mojo/ipc_channel_mojo.h +++ b/ipc/mojo/ipc_channel_mojo.h @@ -87,21 +87,21 @@ class IPC_MOJO_EXPORT ChannelMojo : public Channel, static scoped_ptr CreateClientFactory( const ChannelHandle& channel_handle); - virtual ~ChannelMojo(); + ~ChannelMojo() override; // ChannelMojoHost tells the client handle using this API. void OnClientLaunched(base::ProcessHandle handle); // Channel implementation - virtual bool Connect() override; - virtual void Close() override; - virtual bool Send(Message* message) override; - virtual base::ProcessId GetPeerPID() const override; - virtual base::ProcessId GetSelfPID() const override; + bool Connect() override; + void Close() override; + bool Send(Message* message) override; + base::ProcessId GetPeerPID() const override; + base::ProcessId GetSelfPID() const override; #if defined(OS_POSIX) && !defined(OS_NACL) - virtual int GetClientFileDescriptor() const override; - virtual base::ScopedFD TakeClientFileDescriptor() override; + int GetClientFileDescriptor() const override; + base::ScopedFD TakeClientFileDescriptor() override; // These access protected API of IPC::Message, which has ChannelMojo // as a friend class. @@ -114,9 +114,8 @@ class IPC_MOJO_EXPORT ChannelMojo : public Channel, #endif // defined(OS_POSIX) && !defined(OS_NACL) // MojoBootstrapDelegate implementation - virtual void OnPipeAvailable( - mojo::embedder::ScopedPlatformHandle handle) override; - virtual void OnBootstrapError() override; + void OnPipeAvailable(mojo::embedder::ScopedPlatformHandle handle) override; + void OnBootstrapError() override; // Called from MessagePipeReader implementations void OnMessageReceived(Message& message); diff --git a/ipc/mojo/ipc_channel_mojo_host.cc b/ipc/mojo/ipc_channel_mojo_host.cc index 6f9075ae233c..beb18ee5e99f 100644 --- a/ipc/mojo/ipc_channel_mojo_host.cc +++ b/ipc/mojo/ipc_channel_mojo_host.cc @@ -17,12 +17,12 @@ namespace IPC { class ChannelMojoHost::ChannelDelegate : public ChannelMojo::Delegate { public: explicit ChannelDelegate(scoped_refptr io_task_runner); - virtual ~ChannelDelegate(); + ~ChannelDelegate() override; // ChannelMojo::Delegate - virtual base::WeakPtr ToWeakPtr() override; - virtual void OnChannelCreated(base::WeakPtr channel) override; - virtual scoped_refptr GetIOTaskRunner() override; + base::WeakPtr ToWeakPtr() override; + void OnChannelCreated(base::WeakPtr channel) override; + scoped_refptr GetIOTaskRunner() override; // Returns an weak ptr of ChannelDelegate instead of Delegate base::WeakPtr GetWeakPtr(); diff --git a/ipc/mojo/ipc_channel_mojo_readers.h b/ipc/mojo/ipc_channel_mojo_readers.h index fae62adc7663..cadf453c393b 100644 --- a/ipc/mojo/ipc_channel_mojo_readers.h +++ b/ipc/mojo/ipc_channel_mojo_readers.h @@ -33,9 +33,9 @@ class MessageReader : public MessagePipeReader { bool Send(scoped_ptr message); // MessagePipeReader implementation - virtual void OnMessageReceived() override; - virtual void OnPipeClosed() override; - virtual void OnPipeError(MojoResult error) override; + void OnMessageReceived() override; + void OnPipeClosed() override; + void OnPipeError(MojoResult error) override; private: ChannelMojo* owner_; @@ -52,8 +52,8 @@ class ControlReader : public MessagePipeReader { virtual bool Connect(); // MessagePipeReader implementation - virtual void OnPipeClosed() override; - virtual void OnPipeError(MojoResult error) override; + void OnPipeClosed() override; + void OnPipeError(MojoResult error) override; protected: ChannelMojo* owner_; @@ -65,13 +65,13 @@ class ControlReader : public MessagePipeReader { class ServerControlReader : public ControlReader { public: ServerControlReader(mojo::ScopedMessagePipeHandle pipe, ChannelMojo* owner); - virtual ~ServerControlReader(); + ~ServerControlReader() override; // ControlReader override - virtual bool Connect() override; + bool Connect() override; // MessagePipeReader implementation - virtual void OnMessageReceived() override; + void OnMessageReceived() override; private: MojoResult SendHelloRequest(); @@ -88,7 +88,7 @@ class ClientControlReader : public ControlReader { ClientControlReader(mojo::ScopedMessagePipeHandle pipe, ChannelMojo* owner); // MessagePipeReader implementation - virtual void OnMessageReceived() override; + void OnMessageReceived() override; private: MojoResult RespondHelloRequest(MojoHandle message_channel); diff --git a/ipc/mojo/ipc_channel_mojo_unittest.cc b/ipc/mojo/ipc_channel_mojo_unittest.cc index cefa29e08af8..1697ff70838b 100644 --- a/ipc/mojo/ipc_channel_mojo_unittest.cc +++ b/ipc/mojo/ipc_channel_mojo_unittest.cc @@ -27,9 +27,9 @@ class ListenerThatExpectsOK : public IPC::Listener { ListenerThatExpectsOK() : received_ok_(false) {} - virtual ~ListenerThatExpectsOK() {} + ~ListenerThatExpectsOK() override {} - virtual bool OnMessageReceived(const IPC::Message& message) override { + bool OnMessageReceived(const IPC::Message& message) override { PickleIterator iter(message); std::string should_be_ok; EXPECT_TRUE(iter.ReadString(&should_be_ok)); @@ -39,7 +39,7 @@ class ListenerThatExpectsOK : public IPC::Listener { return true; } - virtual void OnChannelError() override { + void OnChannelError() override { // The connection should be healthy while the listener is waiting // message. An error can occur after that because the peer // process dies. @@ -79,7 +79,7 @@ class ChannelClient { class IPCChannelMojoTest : public IPCTestBase { protected: - virtual scoped_ptr CreateChannelFactory( + scoped_ptr CreateChannelFactory( const IPC::ChannelHandle& handle, base::TaskRunner* runner) override { host_.reset(new IPC::ChannelMojoHost(task_runner())); @@ -87,7 +87,7 @@ class IPCChannelMojoTest : public IPCTestBase { handle); } - virtual bool DidStartClient() override { + bool DidStartClient() override { bool ok = IPCTestBase::DidStartClient(); DCHECK(ok); host_->OnClientLaunched(client_process()); @@ -106,7 +106,7 @@ class TestChannelListenerWithExtraExpectations : is_connected_called_(false) { } - virtual void OnChannelConnected(int32 peer_pid) override { + void OnChannelConnected(int32 peer_pid) override { IPC::TestChannelListener::OnChannelConnected(peer_pid); EXPECT_TRUE(base::kNullProcessId != peer_pid); is_connected_called_ = true; @@ -165,15 +165,13 @@ class ListenerExpectingErrors : public IPC::Listener { : has_error_(false) { } - virtual void OnChannelConnected(int32 peer_pid) override { + void OnChannelConnected(int32 peer_pid) override { base::MessageLoop::current()->Quit(); } - virtual bool OnMessageReceived(const IPC::Message& message) override { - return true; - } + bool OnMessageReceived(const IPC::Message& message) override { return true; } - virtual void OnChannelError() override { + void OnChannelError() override { has_error_ = true; base::MessageLoop::current()->Quit(); } @@ -187,7 +185,7 @@ class ListenerExpectingErrors : public IPC::Listener { class IPCChannelMojoErrorTest : public IPCTestBase { protected: - virtual scoped_ptr CreateChannelFactory( + scoped_ptr CreateChannelFactory( const IPC::ChannelHandle& handle, base::TaskRunner* runner) override { host_.reset(new IPC::ChannelMojoHost(task_runner())); @@ -195,7 +193,7 @@ class IPCChannelMojoErrorTest : public IPCTestBase { handle); } - virtual bool DidStartClient() override { + bool DidStartClient() override { bool ok = IPCTestBase::DidStartClient(); DCHECK(ok); host_->OnClientLaunched(client_process()); @@ -211,11 +209,9 @@ class ListenerThatQuits : public IPC::Listener { ListenerThatQuits() { } - virtual bool OnMessageReceived(const IPC::Message& message) override { - return true; - } + bool OnMessageReceived(const IPC::Message& message) override { return true; } - virtual void OnChannelConnected(int32 peer_pid) override { + void OnChannelConnected(int32 peer_pid) override { base::MessageLoop::current()->Quit(); } }; @@ -324,9 +320,9 @@ class ListenerThatExpectsFile : public IPC::Listener { ListenerThatExpectsFile() : sender_(NULL) {} - virtual ~ListenerThatExpectsFile() {} + ~ListenerThatExpectsFile() override {} - virtual bool OnMessageReceived(const IPC::Message& message) override { + bool OnMessageReceived(const IPC::Message& message) override { PickleIterator iter(message); base::ScopedFD fd; @@ -340,9 +336,7 @@ class ListenerThatExpectsFile : public IPC::Listener { return true; } - virtual void OnChannelError() override { - NOTREACHED(); - } + void OnChannelError() override { NOTREACHED(); } static std::string GetSendingFileContent() { return "Hello"; diff --git a/ipc/mojo/ipc_mojo_bootstrap.cc b/ipc/mojo/ipc_mojo_bootstrap.cc index 7233de0fa2d0..745826586e16 100644 --- a/ipc/mojo/ipc_mojo_bootstrap.cc +++ b/ipc/mojo/ipc_mojo_bootstrap.cc @@ -20,15 +20,15 @@ class MojoServerBootstrap : public MojoBootstrap { public: MojoServerBootstrap(); - virtual void OnClientLaunched(base::ProcessHandle process) override; + void OnClientLaunched(base::ProcessHandle process) override; private: void SendClientPipe(); void SendClientPipeIfReady(); // Listener implementations - virtual bool OnMessageReceived(const Message& message) override; - virtual void OnChannelConnected(int32 peer_pid) override; + bool OnMessageReceived(const Message& message) override; + void OnChannelConnected(int32 peer_pid) override; mojo::embedder::ScopedPlatformHandle server_pipe_; base::ProcessHandle client_process_; @@ -112,12 +112,12 @@ class MojoClientBootstrap : public MojoBootstrap { public: MojoClientBootstrap(); - virtual void OnClientLaunched(base::ProcessHandle process) override; + void OnClientLaunched(base::ProcessHandle process) override; private: // Listener implementations - virtual bool OnMessageReceived(const Message& message) override; - virtual void OnChannelConnected(int32 peer_pid) override; + bool OnMessageReceived(const Message& message) override; + void OnChannelConnected(int32 peer_pid) override; DISALLOW_COPY_AND_ASSIGN(MojoClientBootstrap); }; diff --git a/ipc/mojo/ipc_mojo_bootstrap.h b/ipc/mojo/ipc_mojo_bootstrap.h index 540becfbd2b7..0d007ddbb72b 100644 --- a/ipc/mojo/ipc_mojo_bootstrap.h +++ b/ipc/mojo/ipc_mojo_bootstrap.h @@ -41,7 +41,7 @@ class IPC_MOJO_EXPORT MojoBootstrap : public Listener { Delegate* delegate); MojoBootstrap(); - virtual ~MojoBootstrap(); + ~MojoBootstrap() override; // Start the handshake over the underlying platform channel. bool Connect(); @@ -68,8 +68,8 @@ class IPC_MOJO_EXPORT MojoBootstrap : public Listener { void Init(scoped_ptr channel, Delegate* delegate); // Listener implementations - virtual void OnBadMessageReceived(const Message& message) override; - virtual void OnChannelError() override; + void OnBadMessageReceived(const Message& message) override; + void OnChannelError() override; scoped_ptr channel_; Delegate* delegate_; diff --git a/ipc/mojo/ipc_mojo_bootstrap_unittest.cc b/ipc/mojo/ipc_mojo_bootstrap_unittest.cc index 8bffd8877e58..a071d66a7e8f 100644 --- a/ipc/mojo/ipc_mojo_bootstrap_unittest.cc +++ b/ipc/mojo/ipc_mojo_bootstrap_unittest.cc @@ -23,9 +23,8 @@ class TestingDelegate : public IPC::MojoBootstrap::Delegate { public: TestingDelegate() : passed_(false) {} - virtual void OnPipeAvailable( - mojo::embedder::ScopedPlatformHandle handle) override; - virtual void OnBootstrapError() override; + void OnPipeAvailable(mojo::embedder::ScopedPlatformHandle handle) override; + void OnBootstrapError() override; bool passed() const { return passed_; } diff --git a/ipc/mojo/ipc_mojo_perftest.cc b/ipc/mojo/ipc_mojo_perftest.cc index dca405ee1dba..29e78397ce2b 100644 --- a/ipc/mojo/ipc_mojo_perftest.cc +++ b/ipc/mojo/ipc_mojo_perftest.cc @@ -29,7 +29,7 @@ class MojoChannelPerfTest : public IPC::test::IPCChannelPerfTestBase { MojoChannelPerfTest(); - virtual scoped_ptr CreateChannelFactory( + scoped_ptr CreateChannelFactory( const IPC::ChannelHandle& handle, base::TaskRunner* runner) override { host_.reset(new IPC::ChannelMojoHost(task_runner())); @@ -37,7 +37,7 @@ class MojoChannelPerfTest : public IPC::test::IPCChannelPerfTestBase { handle); } - virtual bool DidStartClient() override { + bool DidStartClient() override { bool ok = IPCTestBase::DidStartClient(); DCHECK(ok); host_->OnClientLaunched(client_process()); @@ -73,8 +73,7 @@ class MojoTestClient : public IPC::test::PingPongTestClient { MojoTestClient(); - virtual scoped_ptr CreateChannel( - IPC::Listener* listener) override; + scoped_ptr CreateChannel(IPC::Listener* listener) override; }; MojoTestClient::MojoTestClient() { diff --git a/ipc/sync_socket_unittest.cc b/ipc/sync_socket_unittest.cc index 040dcdc510c0..77ae72d39e33 100644 --- a/ipc/sync_socket_unittest.cc +++ b/ipc/sync_socket_unittest.cc @@ -58,7 +58,7 @@ class SyncSocketServerListener : public IPC::Listener { chan_ = chan; } - virtual bool OnMessageReceived(const IPC::Message& msg) override { + 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) @@ -129,7 +129,7 @@ class SyncSocketClientListener : public IPC::Listener { chan_ = chan; } - virtual bool OnMessageReceived(const IPC::Message& msg) override { + 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) diff --git a/ipc/unix_domain_socket_util_unittest.cc b/ipc/unix_domain_socket_util_unittest.cc index a67c0773026b..90c2ada75402 100644 --- a/ipc/unix_domain_socket_util_unittest.cc +++ b/ipc/unix_domain_socket_util_unittest.cc @@ -27,9 +27,7 @@ class SocketAcceptor : public base::MessageLoopForIO::Watcher { base::Bind(&SocketAcceptor::StartWatching, base::Unretained(this), fd)); } - virtual ~SocketAcceptor() { - Close(); - } + ~SocketAcceptor() override { Close(); } int server_fd() const { return server_fd_; } @@ -60,13 +58,13 @@ class SocketAcceptor : public base::MessageLoopForIO::Watcher { watcher->StopWatchingFileDescriptor(); delete watcher; } - virtual void OnFileCanReadWithoutBlocking(int fd) override { + void OnFileCanReadWithoutBlocking(int fd) override { ASSERT_EQ(-1, server_fd_); IPC::ServerAcceptConnection(fd, &server_fd_); watcher_->StopWatchingFileDescriptor(); accepted_event_.Signal(); } - virtual void OnFileCanWriteWithoutBlocking(int fd) override {} + void OnFileCanWriteWithoutBlocking(int fd) override {} int server_fd_; base::MessageLoopProxy* target_thread_;