| /packages/apps/Camera2/src/com/android/camera/one/v2/sharedimagereader/util/ |
| ImageCloser.java | 19 import com.android.camera.async.ConcurrentBufferQueue;
|
| /packages/apps/Camera2/src/com/android/camera/processing/memory/ |
| LruResourcePool.java | 19 import com.android.camera.async.SafeCloseable;
|
| /packages/apps/Dialer/java/com/android/incallui/async/ |
| PausableExecutorImpl.java | 17 package com.android.incallui.async;
|
| /external/libmojo/base/android/java/src/org/chromium/base/ |
| SystemMessageHandler.java | 69 // Marking the message async provides fair Chromium task dispatch when
80 * to L MR1 the async Message API was hidden, and for such cases we fall
87 public static void setAsynchronous(Message message, boolean async) {
88 IMPL.setAsynchronous(message, async);
95 public void setAsynchronous(Message message, boolean async);
110 public void setAsynchronous(Message msg, boolean async) {
111 msg.setAsynchronous(async);
135 public void setAsynchronous(Message msg, boolean async) {
140 mMessageMethodSetAsynchronous.invoke(msg, async);
142 Log.e(TAG, "Illegal access to async message creation, disabling.")
[all...] |
| /external/curl/lib/ |
| asyn-ares.c | 170 static void destroy_async_data(struct Curl_async *async);
179 destroy_async_data(&conn->async);
183 * destroy_async_data() cleans up async resolver data.
185 static void destroy_async_data(struct Curl_async *async)
187 free(async->hostname);
189 if(async->os_specific) {
190 struct ResolverResults *res = (struct ResolverResults *)async->os_specific;
198 async->os_specific = NULL;
201 async->hostname = NULL;
312 conn->async.os_specific
[all...] |
| /external/python/cpython3/Lib/test/test_asyncio/ |
| test_pep492.py | 38 async def test(lock):
41 async with lock as _lock:
60 async def test(lock):
84 async def reader():
86 async for line in stream:
97 async def foo(): pass
115 async def foo(): pass
132 async def bar():
134 async def foo():
148 async def foo()
[all...] |
| /external/python/cpython3/Lib/test/ |
| test_asyncgen.py | 41 async def iterate():
43 async for i in gen:
53 code = '''async def foo():
58 with self.assertRaisesRegex(SyntaxError, 'yield from.*inside async'):
62 code = '''async def foo():
66 with self.assertRaisesRegex(SyntaxError, 'yield from.*inside async'):
70 code = '''async def foo():
76 with self.assertRaisesRegex(SyntaxError, 'return.*value.*async gen'):
80 code = '''async def foo():
85 with self.assertRaisesRegex(SyntaxError, 'return.*value.*async gen')
[all...] |
| /hardware/intel/img/hwcomposer/merrifield/platforms/merrifield/ |
| PlatfBufferManager.cpp | 57 const crop_t& destRect, bool filter, bool async)
71 if (!async) {
|
| /hardware/intel/img/hwcomposer/merrifield/platforms/merrifield_plus/ |
| PlatfBufferManager.cpp | 57 const crop_t& destRect, bool filter, bool async)
71 if (!async) {
|
| /hardware/intel/img/hwcomposer/moorefield_hdmi/platforms/merrifield_plus/ |
| PlatfBufferManager.cpp | 57 crop_t& srcCrop, uint32_t async)
71 if (!async) {
|
| /packages/apps/Camera2/src/com/android/camera/one/v2/sharedimagereader/metadatasynchronizer/ |
| MetadataPoolFactory.java | 19 import com.android.camera.async.BufferQueueController;
20 import com.android.camera.async.Updatable;
|
| /prebuilts/go/darwin-x86/src/runtime/ |
| chanbarrier_test.go | 22 type async struct {
26 ch := make(chan *async, 0)
32 case ch <- &async{resp: nil, err: myError{}}:
38 ch <- &async{resp: nil, err: myError{}}
|
| /prebuilts/go/linux-x86/src/runtime/ |
| chanbarrier_test.go | 22 type async struct {
26 ch := make(chan *async, 0)
32 case ch <- &async{resp: nil, err: myError{}}:
38 ch <- &async{resp: nil, err: myError{}}
|
| /packages/apps/Camera2/src/com/android/camera/async/ |
| BufferQueue.java | 17 package com.android.camera.async;
36 * @throws com.android.camera.async.BufferQueue.BufferQueueClosedException If the stream is closed and no more values
49 * @throws com.android.camera.async.BufferQueue.BufferQueueClosedException If the stream is closed and no more values
|
| /packages/apps/Camera2/src/com/android/camera/burst/ |
| SurfaceTextureContainer.java | 22 import com.android.camera.async.SafeCloseable;
|
| /packages/apps/Camera2/src/com/android/camera/captureintent/resource/ |
| ResourceSurfaceTexture.java | 19 import com.android.camera.async.SafeCloseable;
|
| ResourceCaptureTools.java | 19 import com.android.camera.async.MainThread;
20 import com.android.camera.async.RefCountBase;
21 import com.android.camera.async.SafeCloseable;
105 * @return A {@link com.android.camera.async.MainThread} object.
|
| /packages/apps/Camera2/src/com/android/camera/one/v2/common/ |
| SimpleCaptureStream.java | 21 import com.android.camera.async.BufferQueue;
|
| /packages/apps/Camera2/src/com/android/camera/one/v2/sharedimagereader/ |
| SharedImageReaderFactory.java | 19 import com.android.camera.async.HandlerFactory;
20 import com.android.camera.async.Lifetime;
21 import com.android.camera.async.Observable;
22 import com.android.camera.async.Updatable;
|
| /packages/apps/Camera2/src/com/android/camera/one/v2/sharedimagereader/ringbuffer/ |
| AvailableTicketCounter.java | 19 import com.android.camera.async.ConcurrentState;
20 import com.android.camera.async.Lifetime;
21 import com.android.camera.async.Observable;
22 import com.android.camera.async.SafeCloseable;
|
| /frameworks/wilhelm/src/objects/ |
| CAudioPlayer.cpp | 24 SLresult CAudioPlayer_Realize(void *self, SLboolean async)
30 result = android_audioPlayer_realize(thiz, async);
47 SLresult CAudioPlayer_Resume(void *self, SLboolean async)
|
| /packages/apps/Camera2/src/com/android/camera/one/v2/initialization/ |
| CameraStarter.java | 21 import com.android.camera.async.Lifetime;
22 import com.android.camera.async.Observable;
23 import com.android.camera.async.Updatable;
|
| /packages/apps/Settings/src/com/android/settings/enterprise/ |
| EnterprisePrivacySettings.java | 55 return buildPreferenceControllers(context, true /* async */);
59 boolean async) {
67 context, async));
69 new AdminGrantedLocationPermissionsPreferenceController(context, async));
71 new AdminGrantedMicrophonePermissionPreferenceController(context, async));
73 context, async));
118 return buildPreferenceControllers(context, false /* async */);
|
| /external/libcxx/test/std/thread/futures/futures.async/ |
| async.pass.cpp | 17 // async(F&& f, Args&&... args);
21 // async(launch policy, F&& f, Args&&... args);
85 std::future<Ret> f = std::async(std::forward<Args>(args)...);
88 // Check that deferred async's have not invoked the function.
97 // If the async is deferred it should take more than 100ms, otherwise
109 // it to be std::launch::async.
113 std::launch AnyPolicy = std::launch::async | std::launch::deferred;
119 test<int>(checkInt, false, std::launch::async, f0);
126 test<int&>(checkIntRef, false, std::launch::async, f1);
133 test<void>(checkVoid, false, std::launch::async, f2)
[all...] |
| /external/llvm/unittests/Support/ |
| ThreadPool.cpp | 89 // test that async & barrier work together properly.
95 Pool.async([this, &checked_in, i] {
110 // Test that async works with a function requiring multiple parameters.
115 Pool.async(TestFunc, std::ref(checked_in), i);
121 TEST_F(ThreadPoolTest, Async) {
125 Pool.async([this, &i] {
129 Pool.async([&i] { ++i; });
140 Pool.async([this, &i] {
145 Pool.async([&i] { ++i; }).get();
159 Pool.async([this, &checked_in, i]
[all...] |
