diff options
Diffstat (limited to 'ui/viewer/viewer_ipc_server.cc')
-rw-r--r-- | ui/viewer/viewer_ipc_server.cc | 98 |
1 files changed, 0 insertions, 98 deletions
diff --git a/ui/viewer/viewer_ipc_server.cc b/ui/viewer/viewer_ipc_server.cc deleted file mode 100644 index 578d193..0000000 --- a/ui/viewer/viewer_ipc_server.cc +++ /dev/null @@ -1,98 +0,0 @@ -// Copyright (c) 2012 The Chromium Authors. All rights reserved. -// Use of this source code is governed by a BSD-style license that can be -// found in the LICENSE file. - -#include "ui/viewer/viewer_ipc_server.h" - -#include "ui/viewer/viewer_messages.h" -#include "ui/viewer/viewer_process.h" -#include "ipc/ipc_logging.h" - -ViewerIPCServer::ViewerIPCServer(const IPC::ChannelHandle& channel_handle) - : client_connected_(false), channel_handle_(channel_handle) { -} - -ViewerIPCServer::~ViewerIPCServer() { -#ifdef IPC_MESSAGE_LOG_ENABLED - IPC::Logging::GetInstance()->SetIPCSender(NULL); -#endif - - channel_->RemoveFilter(sync_message_filter_.get()); -} - -bool ViewerIPCServer::Init() { -#ifdef IPC_MESSAGE_LOG_ENABLED - IPC::Logging::GetInstance()->SetIPCSender(this); -#endif - sync_message_filter_ = - new IPC::SyncMessageFilter(g_viewer_process->shutdown_event()); - CreateChannel(); - return true; -} - -bool ViewerIPCServer::Send(IPC::Message* msg) { - if (!channel_.get()) { - delete msg; - return false; - } - - return channel_->Send(msg); -} - -bool ViewerIPCServer::OnMessageReceived(const IPC::Message& msg) { - bool handled = true; - // When we get a message, always mark the client as connected. The - // ChannelProxy::Context is only letting OnChannelConnected get called once, - // so on the Mac and Linux, we never would set client_connected_ to true - // again on subsequent connections. - client_connected_ = true; - IPC_BEGIN_MESSAGE_MAP(ViewerIPCServer, msg) - IPC_MESSAGE_HANDLER(ViewerMsg_PbufferHandle, - OnPbufferHandle) - IPC_MESSAGE_UNHANDLED(handled = false) - IPC_END_MESSAGE_MAP() - return handled; -} - -void ViewerIPCServer::OnChannelConnected(int32 peer_pid) { - DCHECK(!client_connected_); - client_connected_ = true; -} - -void ViewerIPCServer::OnChannelError() { - // When a client (typically a browser process) disconnects, the pipe is - // closed and we get an OnChannelError. Since we want to keep servicing - // client requests, we will recreate the channel. - bool client_was_connected = client_connected_; - client_connected_ = false; - if (client_was_connected) { - if (g_viewer_process->HandleClientDisconnect()) { -#if defined(OS_WIN) - // On Windows, once an error on a named pipe occurs, the named pipe is no - // longer valid and must be re-created. This is not the case on Mac or - // Linux. - CreateChannel(); -#endif - } - } else { - // If the client was never even connected we had an error connecting. - if (!client_connected_) { - LOG(ERROR) << "Unable to open viewer ipc channel " - << "named: " << channel_handle_.name; - } - } -} - -void ViewerIPCServer::OnPbufferHandle(const std::string& todo) { - NOTREACHED(); -} - -void ViewerIPCServer::CreateChannel() { - channel_.reset(NULL); // Tear down the existing channel, if any. - channel_.reset(new IPC::SyncChannel(channel_handle_, - IPC::Channel::MODE_NAMED_SERVER, this, - g_viewer_process->io_message_loop_proxy(), true, - g_viewer_process->shutdown_event())); - DCHECK(sync_message_filter_.get()); - channel_->AddFilter(sync_message_filter_.get()); -} |