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
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
|
// Copyright (c) 2011 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.
#ifndef CHROME_FRAME_URLMON_URL_REQUEST_H_
#define CHROME_FRAME_URLMON_URL_REQUEST_H_
#include <urlmon.h>
#include <atlbase.h>
#include <atlcom.h>
#include <map>
#include <string>
#include "base/threading/thread.h"
#include "chrome_frame/plugin_url_request.h"
#include "chrome_frame/urlmon_moniker.h"
#include "chrome_frame/utils.h"
class UrlmonUrlRequest;
class UrlmonUrlRequestManager
: public PluginUrlRequestManager,
public PluginUrlRequestDelegate {
public:
// Sub resources on the pages in chrome frame are fetched on this thread.
class ResourceFetcherThread : public base::Thread {
public:
explicit ResourceFetcherThread(const char* name);
virtual ~ResourceFetcherThread();
virtual void Init();
virtual void CleanUp();
};
// Contains the privacy information for all requests issued by this instance.
struct PrivacyInfo {
public:
struct PrivacyEntry {
PrivacyEntry() : flags(0) {}
std::wstring policy_ref;
int32 flags;
};
typedef std::map<std::wstring, PrivacyEntry> PrivacyRecords;
PrivacyInfo() : privacy_impacted(false) {}
bool privacy_impacted;
PrivacyRecords privacy_records;
};
UrlmonUrlRequestManager();
~UrlmonUrlRequestManager();
// Use specific bind context when Chrome request this url.
// Used from ChromeActiveDocument's implementation of IPersistMoniker::Load().
void SetInfoForUrl(const std::wstring& url,
IMoniker* moniker, LPBC bind_context);
// Returns a copy of the url privacy information for this instance.
PrivacyInfo privacy_info() {
return privacy_info_;
}
virtual void AddPrivacyDataForUrl(const std::string& url,
const std::string& policy_ref,
int32 flags);
// This function passes the window on which notifications are to be fired.
void put_notification_window(HWND window) {
notification_window_ = window;
}
// This function passes information on whether ChromeFrame is running in
// privileged mode.
void set_privileged_mode(bool privileged_mode) {
privileged_mode_ = privileged_mode;
}
void set_container(IUnknown* container) {
container_ = container;
}
private:
friend class MessageLoop;
// PluginUrlRequestManager implementation.
virtual PluginUrlRequestManager::ThreadSafeFlags GetThreadSafeFlags();
virtual void StartRequest(int request_id,
const AutomationURLRequest& request_info);
virtual void ReadRequest(int request_id, int bytes_to_read);
virtual void EndRequest(int request_id);
virtual void DownloadRequestInHost(int request_id);
virtual void StopAll();
virtual void GetCookiesForUrl(const GURL& url, int cookie_id);
virtual void SetCookiesForUrl(const GURL& url, const std::string& cookie);
// PluginUrlRequestDelegate implementation
virtual void OnResponseStarted(int request_id, const char* mime_type,
const char* headers, int size,
base::Time last_modified,
const std::string& redirect_url,
int redirect_status,
const net::HostPortPair& socket_address);
virtual void OnReadComplete(int request_id, const std::string& data);
virtual void OnResponseEnd(int request_id,
const net::URLRequestStatus& status);
virtual void OnCookiesRetrieved(bool success, const GURL& url,
const std::string& cookie_string,
int cookie_id);
// This method is passed as a callback to UrlmonUrlRequest::TerminateBind.
// We simply forward moniker and bind_ctx to host ActiveX/ActiveDocument,
// so it may start NavigateWithBindContext.
void BindTerminated(IMoniker* moniker, IBindCtx* bind_ctx,
IStream* post_data, const char* request_headers);
// Helper function to initiate a download request in the host.
void DownloadRequestInHostHelper(UrlmonUrlRequest* request);
// Map for (request_id <-> UrlmonUrlRequest)
typedef std::map<int, scoped_refptr<UrlmonUrlRequest> > RequestMap;
RequestMap request_map_;
RequestMap background_request_map_;
// The caller is responsible for acquiring any locks needed to access the
// request map.
scoped_refptr<UrlmonUrlRequest> LookupRequest(int request_id,
RequestMap* request_map);
// The background_request_map_ is referenced from multiple threads. Lock to
// synchronize access.
base::Lock background_resource_map_lock_;
// Helper function to stop all requests in the request map.
void StopAllRequestsHelper(RequestMap* request_map,
base::Lock* request_map_lock);
// Helper function for initiating a new IE request.
void StartRequestHelper(int request_id,
const AutomationURLRequest& request_info,
RequestMap* request_map,
base::Lock* request_map_lock);
scoped_refptr<UrlmonUrlRequest> pending_request_;
scoped_ptr<ResourceFetcherThread> background_thread_;
bool stopping_;
// Controls whether we download subresources on the page in a background
// worker thread.
bool background_worker_thread_enabled_;
PrivacyInfo privacy_info_;
// The window to be used to fire notifications on.
HWND notification_window_;
// Set to true if the ChromeFrame instance is running in privileged mode.
bool privileged_mode_;
// A pointer to the containing object. We maintain a weak reference to avoid
// lifetime issues.
IUnknown* container_;
};
#endif // CHROME_FRAME_URLMON_URL_REQUEST_H_
|
