/external/guava/guava/src/com/google/common/util/concurrent/ |
ForwardingListeningExecutorService.java | 39 public <T> ListenableFuture<T> submit(Callable<T> task) { method in class:ForwardingListeningExecutorService 40 return delegate().submit(task); 44 public ListenableFuture<?> submit(Runnable task) { method in class:ForwardingListeningExecutorService 45 return delegate().submit(task); 49 public <T> ListenableFuture<T> submit(Runnable task, T result) { method in class:ForwardingListeningExecutorService 50 return delegate().submit(task, result);
|
AbstractListeningExecutorService.java | 49 @Override public ListenableFuture<?> submit(Runnable task) { method in class:AbstractListeningExecutorService 50 return (ListenableFuture<?>) super.submit(task); 53 @Override public <T> ListenableFuture<T> submit(Runnable task, @Nullable T result) { method in class:AbstractListeningExecutorService 54 return (ListenableFuture<T>) super.submit(task, result); 57 @Override public <T> ListenableFuture<T> submit(Callable<T> task) { method in class:AbstractListeningExecutorService 58 return (ListenableFuture<T>) super.submit(task);
|
ListeningExecutorService.java | 41 <T> ListenableFuture<T> submit(Callable<T> task); method in interface:ListeningExecutorService 48 ListenableFuture<?> submit(Runnable task); method in interface:ListeningExecutorService 55 <T> ListenableFuture<T> submit(Runnable task, T result); method in interface:ListeningExecutorService
|
ForwardingExecutorService.java | 104 public <T> Future<T> submit(Callable<T> task) { method in class:ForwardingExecutorService 105 return delegate().submit(task); 109 public Future<?> submit(Runnable task) { method in class:ForwardingExecutorService 110 return delegate().submit(task); 114 public <T> Future<T> submit(Runnable task, T result) { method in class:ForwardingExecutorService 115 return delegate().submit(task, result);
|
WrappingExecutorService.java | 99 public final <T> Future<T> submit(Callable<T> task) { 100 return delegate.submit(wrapTask(checkNotNull(task))); 104 public final Future<?> submit(Runnable task) { 105 return delegate.submit(wrapTask(task)); 109 public final <T> Future<T> submit(Runnable task, T result) { 110 return delegate.submit(wrapTask(task), result);
|
/device/google/cuttlefish_common/host/commands/virtual_usb_manager/usbip/ |
messages.cpp | 62 std::ostream& operator<<(std::ostream& out, const CmdReqSubmit& submit) { 64 out << "\t\ttr_flg:\t" << std::hex << submit.transfer_flags << std::dec 66 out << "\t\ttr_len:\t" << submit.transfer_buffer_length << '\n'; 67 out << "\t\tstart:\t" << submit.start_frame << '\n'; 68 out << "\t\tpktcnt:\t" << submit.number_of_packets << '\n'; 69 out << "\t\tttl:\t" << submit.deadline_interval << '\n'; 70 out << "\t\tsetup:\t" << submit.setup << '\n'; 74 std::ostream& operator<<(std::ostream& out, const CmdRepSubmit& submit) { 76 out << "\t\tstatus:\t" << submit.status << '\n'; 77 out << "\t\tlen:\t" << submit.actual_length << '\n' [all...] |
/external/mesa3d/src/gallium/drivers/vc5/ |
v3dx_simulator.c | 142 v3dX(simulator_flush)(struct v3d_hw *v3d, struct drm_vc5_submit_cl *submit, 157 if (submit->qma) { 158 V3D_WRITE(V3D_CLE_0_CT0QMA, submit->qma); 159 V3D_WRITE(V3D_CLE_0_CT0QMS, submit->qms); 162 if (submit->qts) { 165 submit->qts); 168 V3D_WRITE(V3D_CLE_0_CT0QBA, submit->bcl_start); 169 V3D_WRITE(V3D_CLE_0_CT0QEA, submit->bcl_end); 179 V3D_WRITE(V3D_CLE_0_CT1QBA, submit->rcl_start); 180 V3D_WRITE(V3D_CLE_0_CT1QEA, submit->rcl_end) [all...] |
vc5_job.c | 127 uint32_t *bo_handles = (void *)(uintptr_t)job->submit.bo_handles; 129 if (job->submit.bo_handle_count >= job->bo_handles_size) { 133 job->submit.bo_handles = (uintptr_t)(void *)bo_handles; 135 bo_handles[job->submit.bo_handle_count++] = bo->handle; 360 job->submit.bcl_start, job->submit.bcl_end); 362 clif_dump_add_cl(clif, job->submit.bcl_start, job->submit.bcl_end); 365 job->submit.rcl_start, job->submit.rcl_end) [all...] |
/frameworks/av/media/codec2/sfplugin/ |
SkipCutBuffer.h | 38 // Submit one MediaBuffer for skipping and cutting. This may consume all or 41 void submit(MediaBuffer *buffer); 42 void submit(const sp<ABuffer>& buffer); // same as above, but with an ABuffer 43 void submit(const sp<MediaCodecBuffer>& buffer); // same as above, but with an ABuffer
|
/frameworks/av/media/libstagefright/include/media/stagefright/ |
SkipCutBuffer.h | 38 // Submit one MediaBuffer for skipping and cutting. This may consume all or 41 void submit(MediaBuffer *buffer); 42 void submit(const sp<ABuffer>& buffer); // same as above, but with an ABuffer 43 void submit(const sp<MediaCodecBuffer>& buffer); // same as above, but with an ABuffer
|
/external/mesa3d/src/gallium/drivers/vc4/ |
vc4_job.c | 136 * those are only added immediately before submit. 401 struct drm_vc4_submit_cl submit = { local 415 vc4_submit_setup_rcl_surface(job, &submit.color_read, 420 &submit.color_write, 423 &submit.msaa_color_write, 428 vc4_submit_setup_rcl_surface(job, &submit.zs_read, 431 vc4_submit_setup_rcl_surface(job, &submit.zs_write, 433 vc4_submit_setup_rcl_msaa_surface(job, &submit.msaa_zs_write, 442 submit.color_write.bits |= VC4_RENDER_CONFIG_MS_MODE_4X; 446 submit.color_write.bits |= VC4_RENDER_CONFIG_DECIMATE_MODE_4X [all...] |
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
_thread_pool.py | 27 def submit(self, fn, *args, **kwargs): member in class:RecordingThreadPool 30 self._tp_executor.submit(fn, *args, **kwargs)
|
/external/libdrm/etnaviv/ |
etnaviv_cmd_stream.c | 103 free(priv->submit.relocs); 104 free(priv->submit.pmrs); 113 priv->submit.nr_bos = 0; 114 priv->submit.nr_relocs = 0; 115 priv->submit.nr_pmrs = 0; 132 idx = APPEND(&priv->submit, bos); 135 priv->submit.bos[idx].flags = 0; 136 priv->submit.bos[idx].handle = bo->handle; 171 priv->submit.bos[idx].flags |= ETNA_SUBMIT_BO_READ; 173 priv->submit.bos[idx].flags |= ETNA_SUBMIT_BO_WRITE [all...] |
/external/droiddriver/ |
contributing_aosp.md | 5 Follow instructions at https://source.android.com/source/downloading.html except those noted below. You need to set up authentication to be able to submit changes. 28 [Submitting patches to Android](https://source.android.com/source/submit-patches.html) 37 If commits are uploaded together (on the same branch) then they are considered dependent upon eachother. To submit an individual commit without requiring other commits to be merged first, that commit must be cherry picked to a new branch. This can be done either locally or via the gerrit UI.
|
/external/guava/guava-bootstrap/src/java/util/concurrent/ |
ExecutorService.java | 28 <T> Future<T> submit(Callable<T> task); method in interface:ExecutorService 30 <T> Future<T> submit(Runnable task, T result); method in interface:ExecutorService 32 Future<?> submit(Runnable task); method in interface:ExecutorService
|
/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
AbstractListeningExecutorServiceTest.java | 43 ListenableFuture<?> runnableFuture = e.submit(runnable); 48 ListenableFuture<String> callableFuture = e.submit(new TestCallable()); 54 ListenableFuture<Integer> runnableFuture2 = e.submit(runnable2, 3);
|
WrappingExecutorServiceTest.java | 74 Future<?> f = testExecutor.submit(doNothing()); 75 mock.assertLastMethodCalled("submit"); 81 Future<String> f = testExecutor.submit(doNothing(), RESULT_VALUE); 82 mock.assertLastMethodCalled("submit"); 89 Future<String> f = testExecutor.submit(task); 90 mock.assertLastMethodCalled("submit"); 236 return inline.submit(Iterables.get(tasks, 0)).get(); 245 return inline.submit(Iterables.get(tasks, 0)).get(timeout, unit); 272 public <T> Future<T> submit(Callable<T> task) { method in class:WrappingExecutorServiceTest.MockExecutor 273 lastMethodCalled = "submit"; 279 public Future<?> submit(Runnable task) { method in class:WrappingExecutorServiceTest.MockExecutor 286 public <T> Future<T> submit(Runnable task, T result) { method in class:WrappingExecutorServiceTest.MockExecutor [all...] |
/external/libdrm/freedreno/msm/ |
msm_ringbuffer.c | 35 /* represents a single cmd buffer in the submit ioctl. Each cmd buffer has 54 /* submit ioctl related tables: 56 * that is global to the submit ioctl call. The reloc's table is tracked 67 } submit; member in struct:msm_ringbuffer 69 /* should have matching entries in submit.bos: */ 74 /* should have matching entries in submit.cmds: */ 82 * shadows msm_ringbuffer::submit::cmds for tracking submit ioctl 202 idx = APPEND(&msm_ring->submit, bos); 205 msm_ring->submit.bos[idx].flags = 0 [all...] |
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/framework/foundation/ |
_logging_pool_test.py | 52 pool.submit(lambda: test_list.append(object())).result() 58 raised_exception = pool.submit(lambda: 1 / 0).exception() 66 future = pool.submit(callable_object, passed_object)
|
/developers/build/prebuilts/gradle/AutofillFramework/kotlinApp/Application/src/main/java/com/example/android/autofillframework/app/ |
CreditCardCompoundViewActivity.kt | 33 submitButton.setOnClickListener { submit() } 46 private fun submit() {
|
/developers/samples/android/input/autofill/AutofillFramework/kotlinApp/Application/src/main/java/com/example/android/autofillframework/app/ |
CreditCardCompoundViewActivity.kt | 33 submitButton.setOnClickListener { submit() } 46 private fun submit() {
|
/external/skia/tools/gpu/mock/ |
MockTestContext.cpp | 25 void submit() override {}
|
/external/skqp/tools/gpu/mock/ |
MockTestContext.cpp | 25 void submit() override {}
|
/external/swiftshader/src/Vulkan/ |
VkQueue.hpp | 44 void submit(uint32_t submitCount, const VkSubmitInfo* pSubmits, VkFence fence);
|
/external/guava/guava-tests/test/com/google/common/collect/ |
QueuesTest.java | 87 threadPool.submit(new Producer(q, 20)); 88 threadPool.submit(new Producer(q, 20)); 89 threadPool.submit(new Producer(q, 20)); 90 threadPool.submit(new Producer(q, 20)); 91 threadPool.submit(new Producer(q, 20)); 112 Future<?> submitter = threadPool.submit(new Producer(q, 1)); 160 threadPool.submit(new Producer(q, 1)); 179 threadPool.submit(new Interrupter(Thread.currentThread())); 195 threadPool.submit(new Runnable() { 251 threadPool.submit(new Interrupter(Thread.currentThread())) [all...] |