1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
|
// 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());
}
|
