Home
last modified time | relevance | path

Searched defs:worker (Results 1 – 25 of 175) sorted by relevance

1234567

/external/tensorflow/tensorflow/contrib/batching/python/ops/
Dbatch_ops_test.py54 def worker(): function
95 def worker(): function
128 def worker(): function
181 def worker(): function
203 def worker(): function
229 def worker(): function
253 def worker(): function
282 def worker(): function
316 def worker(): function
361 def worker(): function
[all …]
/external/libvpx/libvpx/vpx_util/
Dvpx_thread.c33 VPxWorker *const worker = (VPxWorker *)ptr; in thread_loop() local
54 static void change_state(VPxWorker *const worker, VPxWorkerStatus new_status) { in change_state()
79 static void init(VPxWorker *const worker) { in init()
84 static int sync(VPxWorker *const worker) { in sync()
92 static int reset(VPxWorker *const worker) { in reset()
130 static void execute(VPxWorker *const worker) { in execute()
136 static void launch(VPxWorker *const worker) { in launch()
144 static void end(VPxWorker *const worker) { in end()
/external/libaom/libaom/aom_util/
Daom_thread.c42 AVxWorker *const worker = (AVxWorker *)ptr; in thread_loop() local
85 static void change_state(AVxWorker *const worker, AVxWorkerStatus new_status) { in change_state()
110 static void init(AVxWorker *const worker) { in init()
115 static int sync(AVxWorker *const worker) { in sync()
123 static int reset(AVxWorker *const worker) { in reset()
161 static void execute(AVxWorker *const worker) { in execute()
167 static void launch(AVxWorker *const worker) { in launch()
175 static void end(AVxWorker *const worker) { in end()
/external/opencensus-java/exporters/stats/stackdriver/src/test/java/io/opencensus/exporter/stats/stackdriver/
DStackdriverExporterWorkerTest.java130 StackdriverExporterWorker worker = in export() local
177 StackdriverExporterWorker worker = in doNotExportForEmptyViewData() local
197 StackdriverExporterWorker worker = in doNotExportIfFailedToRegisterView() local
214 StackdriverExporterWorker worker = in skipDifferentViewWithSameName() local
241 StackdriverExporterWorker worker = in doNotCreateMetricDescriptorForRegisteredView() local
260 StackdriverExporterWorker worker = in doNotCreateMetricDescriptorForIntervalView() local
/external/webp/src/utils/
Dthread_utils.c205 WebPWorker* const worker = (WebPWorker*)ptr; in ThreadLoop() local
227 static void ChangeState(WebPWorker* const worker, WebPWorkerStatus new_status) { in ChangeState()
253 static void Init(WebPWorker* const worker) { in Init()
258 static int Sync(WebPWorker* const worker) { in Sync()
266 static int Reset(WebPWorker* const worker) { in Reset()
306 static void Execute(WebPWorker* const worker) { in Execute()
312 static void Launch(WebPWorker* const worker) { in Launch()
320 static void End(WebPWorker* const worker) { in End()
/external/caliper/caliper/src/test/java/com/google/caliper/runner/
DWorkerProcessTest.java110 Process worker = createWorkerProcess(FakeWorkers.Exit.class, "0").startWorker(); in shutdownHook_waitFor() local
118 Process worker = createWorkerProcess( in shutdownHook_exitValueThrows() local
134 Process worker = createWorkerProcess(FakeWorkers.Exit.class, "0").startWorker(); in shutdownHook_exitValue() local
147 Process worker = createWorkerProcess( in shutdownHook_destroy() local
/external/ltp/testcases/kernel/fs/fs_fill/
Dfs_fill.c39 struct worker { struct
43 static void *worker(void *p) in worker() argument
/external/libaom/libaom/av1/
Dav1_dx_iface.c127 AVxWorker *const worker = &ctx->frame_workers[i]; in decoder_destroy() local
385 AVxWorker *const worker = &ctx->frame_workers[i]; in init_buffer_callbacks() local
464 AVxWorker *const worker = &ctx->frame_workers[i]; in init_decoder() local
542 AVxWorker *const worker = ctx->frame_workers; in decode_one() local
623 AVxWorker *const worker = &ctx->frame_workers[i]; in decoder_decode() local
760 AVxWorker *const worker = &ctx->frame_workers[ctx->next_output_worker_id]; in decoder_get_frame() local
878 AVxWorker *const worker = ctx->frame_workers; in ctrl_set_reference() local
893 AVxWorker *const worker = ctx->frame_workers; in ctrl_copy_reference() local
907 AVxWorker *const worker = ctx->frame_workers; in ctrl_get_reference() local
923 AVxWorker *const worker = ctx->frame_workers; in ctrl_get_new_frame_image() local
[all …]
/external/tensorflow/tensorflow/core/distributed_runtime/
Dworker_cache.h56 virtual void ReleaseWorker(const string& target, WorkerInterface* worker) { in ReleaseWorker()
58 delete worker; in ReleaseWorker() local
/external/apache-xml/src/main/java/org/apache/xml/utils/
DThreadControllerWrapper.java38 public static void waitThread(Thread worker, Runnable task) in waitThread()
87 public void waitThread(Thread worker, Runnable task) in waitThread()
/external/libvpx/libvpx/test/
Dvp9_thread_test.cc34 void Run(VPxWorker *worker) { in Run()
200 void Init(VPxWorker *const worker) { memset(worker, 0, sizeof(*worker)); } in Init()
202 int Sync(VPxWorker *const worker) { return !worker->had_error; } in Sync()
204 void Execute(VPxWorker *const worker) { in Execute()
208 void Launch(VPxWorker *const worker) { Execute(worker); } in Launch()
/external/grpc-grpc/src/core/lib/iomgr/
Dpollset_windows.cc51 static void remove_worker(grpc_pollset_worker* worker, in remove_worker()
76 grpc_pollset_worker* worker) { in push_front_worker()
112 grpc_pollset_worker worker; in pollset_work() local
/external/opencensus-java/impl_core/src/main/java/io/opencensus/implcore/trace/export/
DSpanExporterImpl.java39 private final Worker worker; field in SpanExporterImpl
54 Worker worker = new Worker(bufferSize, scheduleDelay); in create() local
86 private SpanExporterImpl(Worker worker) { in SpanExporterImpl()
/external/libxcam/modules/soft/
Dsoft_blender.cpp312 SmartPtr<GaussScaleGray> worker = new GaussScaleGray; in scale_down_masks() local
330 SmartPtr<SoftWorker> worker = pyr_layer[level].scale_task[idx]; in start_scaler() local
412 SmartPtr<SoftWorker> worker = pyr_layer[level].lap_task[idx]; in start_lap_task() local
476 SmartPtr<SoftWorker> worker = last_level_blend; in start_blend_task() local
533 SmartPtr<SoftWorker> worker = pyr_layer[level].recon_task; in start_reconstruct_task() local
738 const SmartPtr<Worker> &worker, const SmartPtr<Worker::Arguments> &base, const XCamReturn error) in gauss_scale_done()
776 const SmartPtr<Worker> &worker, const SmartPtr<Worker::Arguments> &base, const XCamReturn error) in lap_done()
803 const SmartPtr<Worker> &worker, const SmartPtr<Worker::Arguments> &base, const XCamReturn error) in blend_task_done()
826 const SmartPtr<Worker> &worker, const SmartPtr<Worker::Arguments> &base, const XCamReturn error) in reconstruct_done()
/external/compiler-rt/test/tsan/
Dpthread_atfork_deadlock.c11 void *worker(void *unused) { in worker() function
Dfork_atexit.cc13 void *worker(void *unused) { in worker() function
/external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/
Dreplay.cpp35 auto worker = coordination.create_coordinator().get_worker(); variable
92 auto worker = coordination.create_coordinator().get_worker(); variable
149 auto worker = coordination.create_coordinator().get_worker(); variable
206 auto worker = coordination.create_coordinator().get_worker(); variable
/external/google-breakpad/src/tools/mac/upload_system_symbols/
Dupload_system_symbols.go193 func (uq *UploadQueue) worker() { func
261 func (dq *DumpQueue) worker() { func
368 func (fq *findQueue) worker() { func
/external/grpc-grpc/test/core/iomgr/
Dtcp_posix_test.cc236 grpc_pollset_worker* worker = nullptr; in read_test() local
287 grpc_pollset_worker* worker = nullptr; in large_read_test() local
355 grpc_pollset_worker* worker = nullptr; in drain_socket_blocking() local
455 grpc_pollset_worker* worker = nullptr; in write_test() local
526 grpc_pollset_worker* worker = nullptr; in release_fd_test() local
543 grpc_pollset_worker* worker = nullptr; in release_fd_test() local
Dtcp_client_posix_test.cc125 grpc_pollset_worker* worker = nullptr; in test_succeeds() local
166 grpc_pollset_worker* worker = nullptr; in test_fails() local
/external/grpc-grpc/test/core/http/
Dhttpcli_test.cc89 grpc_pollset_worker* worker = nullptr; in test_get() local
128 grpc_pollset_worker* worker = nullptr; in test_post() local
Dhttpscli_test.cc92 grpc_pollset_worker* worker = nullptr; in test_get() local
132 grpc_pollset_worker* worker = nullptr; in test_post() local
/external/robolectric-shadows/shadows/supportv4/src/main/java/org/robolectric/shadows/support/v4/
DShadowAsyncTaskLoader.java16 private BackgroundWorker worker; field in ShadowAsyncTaskLoader
/external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/shadows/
DShadowAsyncTaskLoader.java15 private BackgroundWorker worker; field in ShadowAsyncTaskLoader
/external/webp/src/enc/
Dalpha_enc.c394 WebPWorker* const worker = &enc->alpha_worker_; in VP8EncInitAlpha() local
405 WebPWorker* const worker = &enc->alpha_worker_; in VP8EncStartAlpha() local
422 WebPWorker* const worker = &enc->alpha_worker_; in VP8EncFinishAlpha() local
432 WebPWorker* const worker = &enc->alpha_worker_; in VP8EncDeleteAlpha() local

1234567