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
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
|
// Copyright (c) 2006-2008 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.
// See http://dev.chromium.org/developers/design-documents/multi-process-resource-loading
#ifndef CHROME_COMMON_RESOURCE_DISPATCHER_H__
#define CHROME_COMMON_RESOURCE_DISPATCHER_H__
#include <deque>
#include <queue>
#include <string>
#include "base/hash_tables.h"
#include "base/shared_memory.h"
#include "base/task.h"
#include "chrome/common/filter_policy.h"
#include "chrome/common/ipc_channel.h"
#include "webkit/glue/resource_loader_bridge.h"
struct ResourceResponseHead;
// This class serves as a communication interface between the
// ResourceDispatcherHost in the browser process and the ResourceLoaderBridge in
// the child process. It can be used from any child process.
class ResourceDispatcher {
public:
explicit ResourceDispatcher(IPC::Message::Sender* sender);
~ResourceDispatcher();
// Called to possibly handle the incoming IPC message. Returns true if
// handled, else false.
bool OnMessageReceived(const IPC::Message& message);
// creates a ResourceLoaderBridge for this type of dispatcher, this is so
// this can be tested regardless of the ResourceLoaderBridge::Create
// implementation.
webkit_glue::ResourceLoaderBridge* CreateBridge(const std::string& method,
const GURL& url,
const GURL& policy_url,
const GURL& referrer,
const std::string& frame_origin,
const std::string& main_frame_origin,
const std::string& headers,
const std::string& default_mime_type,
int load_flags,
int origin_pid,
ResourceType::Type resource_type,
uint32 request_context /* used for plugin->browser requests */,
int route_id);
// Adds a request from the pending_requests_ list, returning the new
// requests' ID
int AddPendingRequest(webkit_glue::ResourceLoaderBridge::Peer* callback,
ResourceType::Type resource_type);
// Removes a request from the pending_requests_ list, returning true if the
// request was found and removed.
bool RemovePendingRequest(int request_id);
IPC::Message::Sender* message_sender() const {
return message_sender_;
}
// Toggles the is_deferred attribute for the specified request.
void SetDefersLoading(int request_id, bool value);
private:
friend class ResourceDispatcherTest;
typedef std::deque<IPC::Message*> MessageQueue;
struct PendingRequestInfo {
PendingRequestInfo() { }
PendingRequestInfo(webkit_glue::ResourceLoaderBridge::Peer* peer,
ResourceType::Type resource_type)
: peer(peer),
resource_type(resource_type),
filter_policy(FilterPolicy::DONT_FILTER),
is_deferred(false) {
}
~PendingRequestInfo() { }
webkit_glue::ResourceLoaderBridge::Peer* peer;
ResourceType::Type resource_type;
FilterPolicy::Type filter_policy;
MessageQueue deferred_message_queue;
bool is_deferred;
};
typedef base::hash_map<int, PendingRequestInfo> PendingRequestList;
// Message response handlers, called by the message handler for this process.
void OnUploadProgress(const IPC::Message& message,
int request_id,
int64 position,
int64 size);
void OnDownloadProgress(const IPC::Message& message,
int request_id, int64 position, int64 size);
void OnReceivedResponse(int request_id, const ResourceResponseHead&);
void OnReceivedRedirect(int request_id, const GURL& new_url);
void OnReceivedData(const IPC::Message& message,
int request_id,
base::SharedMemoryHandle data,
int data_len);
void OnRequestComplete(int request_id,
const URLRequestStatus& status,
const std::string& security_info);
// Dispatch the message to one of the message response handlers.
void DispatchMessage(const IPC::Message& message);
// Dispatch any deferred messages for the given request, provided it is not
// again in the deferred state.
void FlushDeferredMessages(int request_id);
// Returns true if the message passed in is a resource related message.
static bool IsResourceDispatcherMessage(const IPC::Message& message);
IPC::Message::Sender* message_sender_;
// All pending requests issued to the host
PendingRequestList pending_requests_;
ScopedRunnableMethodFactory<ResourceDispatcher> method_factory_;
DISALLOW_EVIL_CONSTRUCTORS(ResourceDispatcher);
};
#endif // CHROME_COMMON_RESOURCE_DISPATCHER_H__
|
