| /packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/ |
| IconLoaderTest.java | 19 import com.android.quicksearchbox.util.Consumer;
50 AssertConsumer<Object> consumer = new AssertConsumer<Object>(); local
51 value.getLater(consumer);
52 consumer.assertNull();
60 AssertConsumer<Object> consumer = new AssertConsumer<Object>(); local
61 value.getLater(consumer);
62 consumer.assertNotNull();
66 protected static class AssertConsumer<C> implements Consumer<C> {
|
| /external/oauth/core/src/main/java/net/oauth/ |
| ConsumerProperties.java | 28 * A pool of OAuthConsumers that are constructed from Properties. Each consumer
30 * from Properties whose names are prefixed with the consumer's name. For
31 * example, a consumer's credentials come from properties named
72 /** Get the consumer with the given name. */
74 OAuthConsumer consumer; local
76 consumer = pool.get(name);
78 if (consumer == null) {
79 consumer = newConsumer(name);
84 pool.put(name, consumer);
90 consumer = first
105 OAuthConsumer consumer = new OAuthConsumer(consumerProperties local
[all...] |
| OAuthAccessor.java | 38 public final OAuthConsumer consumer; field in class:OAuthAccessor
43 public OAuthAccessor(OAuthConsumer consumer) {
44 this.consumer = consumer;
68 * consumer.getProperty("httpMethod") or (if that's null)
77 method = (String) this.consumer.getProperty("httpMethod");
85 Object accepted = consumer.getProperty(OAuthConsumer.ACCEPT_ENCODING);
|
| /external/chromium_org/chrome/browser/common/ |
| cancelable_request.cc | 13 CancelableRequestConsumerBase* consumer) {
25 consumer->OnRequestAdded(this, handle);
27 request->Init(this, handle, consumer);
55 item->second->consumer()->OnRequestRemoved(this, item->first);
61 CancelableRequestConsumerBase* consumer = NULL; local
70 consumer = i->second->consumer();
73 // else the consumer might be gone).
79 // Notify the consumer that the request is gone
80 consumer->OnRequestRemoved(this, handle)
[all...] |
| /external/chromium_org/third_party/WebKit/Source/testing/runner/ |
| MockWebMediaStreamCenter.cpp | 98 MockWebAudioDestinationConsumer* consumer = new MockWebAudioDestinationConsumer(); local
99 source.addAudioConsumer(consumer);
100 source.removeAudioConsumer(consumer);
101 delete consumer;
|
| /external/harfbuzz_ng/util/ |
| main-font-text.hh | 41 consumer (&options) {}
58 consumer.init (&font_opts);
64 consumer.consume_line (buffer, text, text_len, input.text_before, input.text_after);
67 consumer.finish (&font_opts);
69 return consumer.failed ? 1 : 0;
76 consumer_t consumer; member in struct:main_font_text_t
|
| /external/llvm/tools/llvm-diff/ |
| DiffLog.h | 23 class Consumer;
30 Consumer &consumer; member in class:llvm::LogBuilder
41 LogBuilder(Consumer &c, StringRef Format)
42 : consumer(c), Format(Format) {}
61 Consumer &consumer; member in class:llvm::DiffLogBuilder
64 DiffLogBuilder(Consumer &c) : consumer(c) {}
|
| DifferenceEngine.h | 39 Engine.consumer.enterContext(L, R);
43 Engine.consumer.exitContext();
61 DifferenceEngine(Consumer &consumer)
62 : consumer(consumer), globalValueOracle(0) {}
67 consumer.log(text);
70 return LogBuilder(consumer, text);
72 Consumer& getConsumer() const { return consumer; }
86 Consumer &consumer; member in class:llvm::DifferenceEngine
[all...] |
| /external/chromium_org/chrome/browser/net/gaia/ |
| gaia_oauth_fetcher_unittest.cc | 58 MockGaiaOAuthFetcher(GaiaOAuthConsumer* consumer,
62 consumer, getter, service_scope) {}
112 MockGaiaOAuthConsumer consumer;
113 EXPECT_CALL(consumer, OnGetOAuthTokenSuccess(oauth_token)).Times(1);
117 MockGaiaOAuthFetcher oauth_fetcher(&consumer,
137 MockGaiaOAuthConsumer consumer; local
138 EXPECT_CALL(consumer,
143 MockGaiaOAuthFetcher oauth_fetcher(&consumer,
175 MockGaiaOAuthConsumer consumer; local
176 EXPECT_CALL(consumer,
208 MockGaiaOAuthConsumer consumer; local
233 MockGaiaOAuthConsumer consumer; local
[all...] |
| /frameworks/native/libs/gui/tests/ |
| Surface_test.cpp | 92 sp<CpuConsumer> consumer = new CpuConsumer(bq, 1); local
|
| /external/chromium/chrome/browser/geolocation/ |
| access_token_store_browsertest.cc | 44 CancelableRequestConsumerBase* consumer,
49 (*store)->LoadAccessTokens(consumer, callback);
61 CancelableRequestConsumer consumer; local
66 store->LoadAccessTokens(&consumer, NewCallback(
68 EXPECT_TRUE(consumer.HasPendingRequests());
70 consumer.GetClientData(store.get(), first_handle);
72 EXPECT_FALSE(consumer.HasPendingRequests());
75 store->LoadAccessTokens(&consumer, NewCallback(
77 store->LoadAccessTokens(&consumer, NewCallback(
79 EXPECT_TRUE(consumer.HasPendingRequests())
[all...] |
| /external/chromium/chrome/common/extensions/docs/examples/apps/hello-php/ |
| index.php | 47 public $consumer; variable
52 $this->consumer = new OAuthConsumer( variable
109 $this->consumer, $this->token, 'GET', $url, array());
111 $request->sign_request($this->signatureMethod, $this->consumer,
|
| /external/chromium_org/chrome/browser/password_manager/ |
| password_store_default_unittest.cc | 175 MockPasswordStoreConsumer consumer; local
178 ON_CALL(consumer, OnPasswordStoreRequestDone(_, _))
182 EXPECT_CALL(consumer,
187 store->GetAutofillableLogins(&consumer);
|
| password_store_unittest.cc | 241 MockPasswordStoreConsumer consumer; local
244 ON_CALL(consumer, OnGetPasswordStoreResults(_))
250 EXPECT_CALL(consumer,
253 EXPECT_CALL(consumer,
257 EXPECT_CALL(consumer,
262 store->GetLogins(www_google, &consumer);
263 store->GetLogins(accounts_google, &consumer);
264 store->GetLogins(bar_example, &consumer);
|
| password_store_win_unittest.cc | 199 MockPasswordStoreConsumer consumer; local
202 ON_CALL(consumer, OnGetPasswordStoreResults(_))
235 EXPECT_CALL(consumer,
239 store_->GetLogins(*form, &consumer);
265 MockPasswordStoreConsumer consumer; local
266 store_->GetLogins(*form, &consumer);
372 MockPasswordStoreConsumer consumer; local
375 ON_CALL(consumer, OnGetPasswordStoreResults(_))
380 EXPECT_CALL(consumer,
384 store_->GetLogins(*form, &consumer);
393 MockPasswordStoreConsumer consumer; local
415 MockPasswordStoreConsumer consumer; local
[all...] |
| /external/chromium_org/chrome/common/extensions/docs/examples/apps/hello-php/ |
| index.php | 46 public $consumer; variable
51 $this->consumer = new OAuthConsumer( variable
108 $this->consumer, $this->token, 'GET', $url, array());
110 $request->sign_request($this->signatureMethod, $this->consumer,
|
| /external/chromium_org/components/webdata/common/ |
| web_data_request_manager.cc | 17 WebDataRequest::WebDataRequest(WebDataServiceConsumer* consumer,
19 : manager_(manager), cancelled_(false), consumer_(consumer) {
135 // Notify the consumer if needed.
137 WebDataServiceConsumer* consumer = request->GetConsumer(); local
139 if (consumer) {
141 consumer->OnWebDataServiceRequestDone(request->GetHandle(), r.get());
|
| /packages/apps/Gallery2/src/com/android/gallery3d/data/ |
| MediaSource.java | 71 // and invoke consumer.consume() for each MediaItem with the given id.
76 public void mapMediaItems(ArrayList<PathId> list, ItemConsumer consumer) {
92 consumer.consume(pid.id, (MediaItem) obj);
|
| /external/chromium/chrome/browser/password_manager/ |
| password_store_win_unittest.cc | 179 MockPasswordStoreConsumer consumer; local
182 ON_CALL(consumer, OnPasswordStoreRequestDone(_, _))
215 EXPECT_CALL(consumer,
220 store->GetLogins(*form, &consumer);
252 MockPasswordStoreConsumer consumer; local
253 store->GetLogins(*form, &consumer);
452 MockPasswordStoreConsumer consumer; local
455 ON_CALL(consumer, OnPasswordStoreRequestDone(_, _))
460 EXPECT_CALL(consumer,
465 store->GetAutofillableLogins(&consumer);
534 MockPasswordStoreConsumer consumer; local
557 MockPasswordStoreConsumer consumer; local
580 MockPasswordStoreConsumer consumer; local
[all...] |
| /external/chromium/chrome/browser/sessions/ |
| session_service_unittest.cc | 633 CancelableRequestConsumer consumer; local
635 service()->GetCurrentSession(&consumer,
|
| /external/chromium/chrome/common/net/gaia/ |
| gaia_auth_fetcher_unittest.cc | 156 MockGaiaConsumer consumer; local
157 EXPECT_CALL(consumer, OnClientLoginFailure(expected_error))
160 GaiaAuthFetcher auth(&consumer, std::string(),
178 MockGaiaConsumer consumer; local
179 EXPECT_CALL(consumer, OnIssueAuthTokenFailure(_, expected_error))
182 GaiaAuthFetcher auth(&consumer, std::string(),
201 MockGaiaConsumer consumer; local
202 EXPECT_CALL(consumer, OnClientLoginFailure(expected_error))
205 GaiaAuthFetcher auth(&consumer, std::string(),
250 MockGaiaConsumer consumer; local
266 MockGaiaConsumer consumer; local
300 MockGaiaConsumer consumer; local
375 MockGaiaConsumer consumer; local
397 MockGaiaConsumer consumer; local
420 MockGaiaConsumer consumer; local
450 MockGaiaConsumer consumer; local
475 MockGaiaConsumer consumer; local
[all...] |
| /external/chromium_org/chrome/test/logging/win/ |
| log_file_reader.cc | 72 // An implementation of a trace consumer that delegates to a given (at
96 // Reads the file using a trace consumer. |ProcessEvent| will be invoked for
228 TraceConsumer<&ProcessEvent> consumer; local
231 hr = consumer.OpenFileSession(log_file.value().c_str());
236 consumer.Consume();
237 consumer.Close();
|
| /external/chromium_org/third_party/WebKit/Source/core/platform/chromium/support/ |
| WebMediaStreamSource.cpp | 186 static PassRefPtr<ConsumerWrapper> create(WebAudioDestinationConsumer* consumer)
188 return adoptRef(new ConsumerWrapper(consumer));
194 WebAudioDestinationConsumer* consumer() { return m_consumer; } function in class:WebKit::ConsumerWrapper
197 explicit ConsumerWrapper(WebAudioDestinationConsumer* consumer) : m_consumer(consumer) { }
222 void WebMediaStreamSource::addAudioConsumer(WebAudioDestinationConsumer* consumer)
225 ASSERT(!m_private.isNull() && consumer);
227 m_private->addAudioConsumer(ConsumerWrapper::create(consumer));
230 bool WebMediaStreamSource::removeAudioConsumer(WebAudioDestinationConsumer* consumer)
233 ASSERT(!m_private.isNull() && consumer);
[all...] |
| /external/clang/lib/Frontend/ |
| ChainedIncludesSource.cpp | 113 OwningPtr<ASTConsumer> consumer; local
114 consumer.reset(new PCHGenerator(Clang->getPreprocessor(), "-", 0,
117 consumer->GetASTMutationListener());
118 Clang->setASTConsumer(consumer.take());
217 void ChainedIncludesSource::StartTranslationUnit(ASTConsumer *Consumer) {
218 return getFinalReader().StartTranslationUnit(Consumer);
|
| /external/valgrind/main/drd/tests/ |
| circular_buffer.c | 1 /* Test program that performs producer-consumer style communication through
167 static void consumer(int* id) function
216 (void * (*)(void *)) consumer, &thread_arg[i]);
|
