Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(26)

Side by Side Diff: third_party/WebKit/Source/platform/blob/BlobRegistry.cpp

Issue 2329683002: Rename blobRegistry() functions and methods to getBlobRegistry(). (Closed)
Patch Set: Created 4 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 /* 1 /*
2 * Copyright (C) 2010 Google Inc. All rights reserved. 2 * Copyright (C) 2010 Google Inc. All rights reserved.
3 * 3 *
4 * Redistribution and use in source and binary forms, with or without 4 * Redistribution and use in source and binary forms, with or without
5 * modification, are permitted provided that the following conditions are 5 * modification, are permitted provided that the following conditions are
6 * met: 6 * met:
7 * 7 *
8 * * Redistributions of source code must retain the above copyright 8 * * Redistributions of source code must retain the above copyright
9 * notice, this list of conditions and the following disclaimer. 9 * notice, this list of conditions and the following disclaimer.
10 * * Redistributions in binary form must reproduce the above 10 * * Redistributions in binary form must reproduce the above
(...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after
51 #include <memory> 51 #include <memory>
52 52
53 namespace blink { 53 namespace blink {
54 54
55 class BlobOriginMap : public URLSecurityOriginMap { 55 class BlobOriginMap : public URLSecurityOriginMap {
56 public: 56 public:
57 BlobOriginMap(); 57 BlobOriginMap();
58 SecurityOrigin* getOrigin(const KURL&) override; 58 SecurityOrigin* getOrigin(const KURL&) override;
59 }; 59 };
60 60
61 static WebBlobRegistry* blobRegistry() 61 static WebBlobRegistry* getBlobRegistry()
62 { 62 {
63 return Platform::current()->blobRegistry(); 63 return Platform::current()->getBlobRegistry();
64 } 64 }
65 65
66 typedef HashMap<String, RefPtr<SecurityOrigin>> BlobURLOriginMap; 66 typedef HashMap<String, RefPtr<SecurityOrigin>> BlobURLOriginMap;
67 static ThreadSpecific<BlobURLOriginMap>& originMap() 67 static ThreadSpecific<BlobURLOriginMap>& originMap()
68 { 68 {
69 // We want to create the BlobOriginMap exactly once because it is shared by 69 // We want to create the BlobOriginMap exactly once because it is shared by
70 // all the threads. 70 // all the threads.
71 DEFINE_THREAD_SAFE_STATIC_LOCAL(BlobOriginMap, cache, new BlobOriginMap); 71 DEFINE_THREAD_SAFE_STATIC_LOCAL(BlobOriginMap, cache, new BlobOriginMap);
72 (void)cache; // BlobOriginMap's constructor does the interesting work. 72 (void)cache; // BlobOriginMap's constructor does the interesting work.
73 73
(...skipping 13 matching lines...) Expand all
87 } 87 }
88 88
89 static void removeFromOriginMap(const KURL& url) 89 static void removeFromOriginMap(const KURL& url)
90 { 90 {
91 if (BlobURL::getOrigin(url) == "null") 91 if (BlobURL::getOrigin(url) == "null")
92 originMap()->remove(url.getString()); 92 originMap()->remove(url.getString());
93 } 93 }
94 94
95 void BlobRegistry::registerBlobData(const String& uuid, std::unique_ptr<BlobData > data) 95 void BlobRegistry::registerBlobData(const String& uuid, std::unique_ptr<BlobData > data)
96 { 96 {
97 blobRegistry()->registerBlobData(uuid, WebBlobData(std::move(data))); 97 getBlobRegistry()->registerBlobData(uuid, WebBlobData(std::move(data)));
98 } 98 }
99 99
100 void BlobRegistry::addBlobDataRef(const String& uuid) 100 void BlobRegistry::addBlobDataRef(const String& uuid)
101 { 101 {
102 blobRegistry()->addBlobDataRef(uuid); 102 getBlobRegistry()->addBlobDataRef(uuid);
103 } 103 }
104 104
105 void BlobRegistry::removeBlobDataRef(const String& uuid) 105 void BlobRegistry::removeBlobDataRef(const String& uuid)
106 { 106 {
107 blobRegistry()->removeBlobDataRef(uuid); 107 getBlobRegistry()->removeBlobDataRef(uuid);
108 } 108 }
109 109
110 void BlobRegistry::registerPublicBlobURL(SecurityOrigin* origin, const KURL& url , PassRefPtr<BlobDataHandle> handle) 110 void BlobRegistry::registerPublicBlobURL(SecurityOrigin* origin, const KURL& url , PassRefPtr<BlobDataHandle> handle)
111 { 111 {
112 saveToOriginMap(origin, url); 112 saveToOriginMap(origin, url);
113 blobRegistry()->registerPublicBlobURL(url, handle->uuid()); 113 getBlobRegistry()->registerPublicBlobURL(url, handle->uuid());
114 } 114 }
115 115
116 void BlobRegistry::revokePublicBlobURL(const KURL& url) 116 void BlobRegistry::revokePublicBlobURL(const KURL& url)
117 { 117 {
118 removeFromOriginMap(url); 118 removeFromOriginMap(url);
119 blobRegistry()->revokePublicBlobURL(url); 119 getBlobRegistry()->revokePublicBlobURL(url);
120 } 120 }
121 121
122 static void registerStreamURLTask(const KURL& url, const String& type) 122 static void registerStreamURLTask(const KURL& url, const String& type)
123 { 123 {
124 if (WebBlobRegistry* registry = blobRegistry()) 124 if (WebBlobRegistry* registry = getBlobRegistry())
125 registry->registerStreamURL(url, type); 125 registry->registerStreamURL(url, type);
126 } 126 }
127 127
128 void BlobRegistry::registerStreamURL(const KURL& url, const String& type) 128 void BlobRegistry::registerStreamURL(const KURL& url, const String& type)
129 { 129 {
130 if (isMainThread()) 130 if (isMainThread())
131 registerStreamURLTask(url, type); 131 registerStreamURLTask(url, type);
132 else 132 else
133 Platform::current()->mainThread()->getWebTaskRunner()->postTask(BLINK_FR OM_HERE, crossThreadBind(&registerStreamURLTask, url, type)); 133 Platform::current()->mainThread()->getWebTaskRunner()->postTask(BLINK_FR OM_HERE, crossThreadBind(&registerStreamURLTask, url, type));
134 } 134 }
135 135
136 static void registerStreamURLFromTask(const KURL& url, const KURL& srcURL) 136 static void registerStreamURLFromTask(const KURL& url, const KURL& srcURL)
137 { 137 {
138 if (WebBlobRegistry* registry = blobRegistry()) 138 if (WebBlobRegistry* registry = getBlobRegistry())
139 registry->registerStreamURL(url, srcURL); 139 registry->registerStreamURL(url, srcURL);
140 } 140 }
141 141
142 void BlobRegistry::registerStreamURL(SecurityOrigin* origin, const KURL& url, co nst KURL& srcURL) 142 void BlobRegistry::registerStreamURL(SecurityOrigin* origin, const KURL& url, co nst KURL& srcURL)
143 { 143 {
144 saveToOriginMap(origin, url); 144 saveToOriginMap(origin, url);
145 145
146 if (isMainThread()) 146 if (isMainThread())
147 registerStreamURLFromTask(url, srcURL); 147 registerStreamURLFromTask(url, srcURL);
148 else 148 else
149 Platform::current()->mainThread()->getWebTaskRunner()->postTask(BLINK_FR OM_HERE, crossThreadBind(&registerStreamURLFromTask, url, srcURL)); 149 Platform::current()->mainThread()->getWebTaskRunner()->postTask(BLINK_FR OM_HERE, crossThreadBind(&registerStreamURLFromTask, url, srcURL));
150 } 150 }
151 151
152 static void addDataToStreamTask(const KURL& url, PassRefPtr<RawData> streamData) 152 static void addDataToStreamTask(const KURL& url, PassRefPtr<RawData> streamData)
153 { 153 {
154 if (WebBlobRegistry* registry = blobRegistry()) 154 if (WebBlobRegistry* registry = getBlobRegistry())
155 registry->addDataToStream(url, streamData->data(), streamData->length()) ; 155 registry->addDataToStream(url, streamData->data(), streamData->length()) ;
156 } 156 }
157 157
158 void BlobRegistry::addDataToStream(const KURL& url, PassRefPtr<RawData> streamDa ta) 158 void BlobRegistry::addDataToStream(const KURL& url, PassRefPtr<RawData> streamDa ta)
159 { 159 {
160 if (isMainThread()) 160 if (isMainThread())
161 addDataToStreamTask(url, std::move(streamData)); 161 addDataToStreamTask(url, std::move(streamData));
162 else 162 else
163 Platform::current()->mainThread()->getWebTaskRunner()->postTask(BLINK_FR OM_HERE, crossThreadBind(&addDataToStreamTask, url, streamData)); 163 Platform::current()->mainThread()->getWebTaskRunner()->postTask(BLINK_FR OM_HERE, crossThreadBind(&addDataToStreamTask, url, streamData));
164 } 164 }
165 165
166 static void flushStreamTask(const KURL& url) 166 static void flushStreamTask(const KURL& url)
167 { 167 {
168 if (WebBlobRegistry* registry = blobRegistry()) 168 if (WebBlobRegistry* registry = getBlobRegistry())
169 registry->flushStream(url); 169 registry->flushStream(url);
170 } 170 }
171 171
172 void BlobRegistry::flushStream(const KURL& url) 172 void BlobRegistry::flushStream(const KURL& url)
173 { 173 {
174 if (isMainThread()) 174 if (isMainThread())
175 flushStreamTask(url); 175 flushStreamTask(url);
176 else 176 else
177 Platform::current()->mainThread()->getWebTaskRunner()->postTask(BLINK_FR OM_HERE, crossThreadBind(&flushStreamTask, url)); 177 Platform::current()->mainThread()->getWebTaskRunner()->postTask(BLINK_FR OM_HERE, crossThreadBind(&flushStreamTask, url));
178 } 178 }
179 179
180 static void finalizeStreamTask(const KURL& url) 180 static void finalizeStreamTask(const KURL& url)
181 { 181 {
182 if (WebBlobRegistry* registry = blobRegistry()) 182 if (WebBlobRegistry* registry = getBlobRegistry())
183 registry->finalizeStream(url); 183 registry->finalizeStream(url);
184 } 184 }
185 185
186 void BlobRegistry::finalizeStream(const KURL& url) 186 void BlobRegistry::finalizeStream(const KURL& url)
187 { 187 {
188 if (isMainThread()) 188 if (isMainThread())
189 finalizeStreamTask(url); 189 finalizeStreamTask(url);
190 else 190 else
191 Platform::current()->mainThread()->getWebTaskRunner()->postTask(BLINK_FR OM_HERE, crossThreadBind(&finalizeStreamTask, url)); 191 Platform::current()->mainThread()->getWebTaskRunner()->postTask(BLINK_FR OM_HERE, crossThreadBind(&finalizeStreamTask, url));
192 } 192 }
193 193
194 static void abortStreamTask(const KURL& url) 194 static void abortStreamTask(const KURL& url)
195 { 195 {
196 if (WebBlobRegistry* registry = blobRegistry()) 196 if (WebBlobRegistry* registry = getBlobRegistry())
197 registry->abortStream(url); 197 registry->abortStream(url);
198 } 198 }
199 199
200 void BlobRegistry::abortStream(const KURL& url) 200 void BlobRegistry::abortStream(const KURL& url)
201 { 201 {
202 if (isMainThread()) 202 if (isMainThread())
203 abortStreamTask(url); 203 abortStreamTask(url);
204 else 204 else
205 Platform::current()->mainThread()->getWebTaskRunner()->postTask(BLINK_FR OM_HERE, crossThreadBind(&abortStreamTask, url)); 205 Platform::current()->mainThread()->getWebTaskRunner()->postTask(BLINK_FR OM_HERE, crossThreadBind(&abortStreamTask, url));
206 } 206 }
207 207
208 static void unregisterStreamURLTask(const KURL& url) 208 static void unregisterStreamURLTask(const KURL& url)
209 { 209 {
210 if (WebBlobRegistry* registry = blobRegistry()) 210 if (WebBlobRegistry* registry = getBlobRegistry())
211 registry->unregisterStreamURL(url); 211 registry->unregisterStreamURL(url);
212 } 212 }
213 213
214 void BlobRegistry::unregisterStreamURL(const KURL& url) 214 void BlobRegistry::unregisterStreamURL(const KURL& url)
215 { 215 {
216 removeFromOriginMap(url); 216 removeFromOriginMap(url);
217 217
218 if (isMainThread()) 218 if (isMainThread())
219 unregisterStreamURLTask(url); 219 unregisterStreamURLTask(url);
220 else 220 else
221 Platform::current()->mainThread()->getWebTaskRunner()->postTask(BLINK_FR OM_HERE, crossThreadBind(&unregisterStreamURLTask, url)); 221 Platform::current()->mainThread()->getWebTaskRunner()->postTask(BLINK_FR OM_HERE, crossThreadBind(&unregisterStreamURLTask, url));
222 } 222 }
223 223
224 BlobOriginMap::BlobOriginMap() 224 BlobOriginMap::BlobOriginMap()
225 { 225 {
226 SecurityOrigin::setMap(this); 226 SecurityOrigin::setMap(this);
227 } 227 }
228 228
229 SecurityOrigin* BlobOriginMap::getOrigin(const KURL& url) 229 SecurityOrigin* BlobOriginMap::getOrigin(const KURL& url)
230 { 230 {
231 if (url.protocolIs("blob")) 231 if (url.protocolIs("blob"))
232 return originMap()->get(url.getString()); 232 return originMap()->get(url.getString());
233 return 0; 233 return 0;
234 } 234 }
235 235
236 } // namespace blink 236 } // namespace blink
OLDNEW
« no previous file with comments | « content/test/test_blink_web_unit_test_support.cc ('k') | third_party/WebKit/Source/platform/testing/TestingPlatformSupport.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698