Searched defs:worker (Results 1 - 25 of 106) sorted by relevance

12345

/external/caliper/caliper/src/main/java/com/google/caliper/worker/
H A DWorkerOptions.java15 package com.google.caliper.worker;
H A DWorkerComponent.java17 package com.google.caliper.worker;
H A DWorkerMain.java17 package com.google.caliper.worker;
31 * the benchmark and hands it off to the instrument's worker.
50 Worker worker = workerComponent.getWorker();
55 worker.setUpBenchmark();
57 worker.bootstrap();
62 worker.preMeasure(isInWarmup);
65 ShouldContinueMessage message = log.notifyMeasurementEnding(worker.measure());
69 worker.postMeasure();
76 worker.tearDownBenchmark();
H A DAllocationRecorder.java16 package com.google.caliper.worker;
H A DAggregateAllocationsRecorder.java16 package com.google.caliper.worker;
H A DAllAllocationsRecorder.java16 package com.google.caliper.worker;
30 * <p>This recorder is enabled via the {@code trackAllocations} worker option.
55 // Don't track locations up into the worker code, or originating within the worker
H A DMacrobenchmarkAllocationWorker.java17 package com.google.caliper.worker;
H A DAllocation.java16 package com.google.caliper.worker;
H A DArbitraryMeasurementWorker.java17 package com.google.caliper.worker;
H A DMacrobenchmarkWorker.java17 package com.google.caliper.worker;
H A DMicrobenchmarkAllocationWorker.java17 package com.google.caliper.worker;
H A DWorker.java16 package com.google.caliper.worker;
H A DWorkerEventLog.java17 package com.google.caliper.worker;
32 /** The worker's interface for communicating with the runner. */
/external/compiler-rt/test/tsan/
H A Dfork_atexit.cc13 void *worker(void *unused) { function
19 pthread_create(&t, NULL, worker, NULL);
H A Dpthread_atfork_deadlock.c11 void *worker(void *unused) { function
26 pthread_create(&t, NULL, worker, NULL);
/external/caliper/caliper/src/test/java/com/google/caliper/worker/
H A DRuntimeWorkerTest.java15 package com.google.caliper.worker;
17 import static com.google.caliper.worker.RuntimeWorker.INITIAL_REPS;
18 import static com.google.caliper.worker.RuntimeWorker.calculateTargetReps;
/external/ltp/lib/newlib_tests/
H A Dtest09.c28 static void *worker(void *id) function
45 pthread_create(threads+i, NULL, worker, (void *)i);
H A Dtest08.c49 static void *worker(void *id) function
64 pthread_create(threads+i, NULL, worker, (void*)i);
/external/apache-xml/src/main/java/org/apache/xml/utils/
H A DThreadControllerWrapper.java38 public static void waitThread(Thread worker, Runnable task) argument
41 m_tpool.waitThread(worker, task);
79 * Wait until the task is completed on the worker
82 * NEEDSDOC @param worker
87 public void waitThread(Thread worker, Runnable task) argument
92 worker.join();
/external/autotest/scheduler/
H A Dthread_lib.py13 1. worker: The staticmethod executed by all worker threads.
14 2. execute: Takes a list of drones and invokes a worker thread per drone.
17 3. wait_on_drones: Waits for all worker threads started by execute to finish
58 def worker(drone, results_queue): member in class:ThreadedTaskQueue
65 @param results_queue: A queue, into which the worker places
155 target=ThreadedTaskQueue.worker,
/external/drm_hwcomposer/tests/
H A Dworker_test.cpp6 #include "worker.h"
12 : Worker("test-worker", HAL_PRIORITY_URGENT_DISPLAY),
57 TestWorker worker; member in struct:WorkerTest
60 worker.Init();
70 ASSERT_TRUE(worker.initialized());
72 int val = worker.value;
76 ASSERT_EQ(val, worker.value);
78 worker.Control(true);
82 worker.Lock();
83 val = worker
[all...]
/external/fio/t/
H A Dmemlock.c10 static void *worker(void *data) function
50 pthread_create(&pthreads[i], NULL, worker, &td);
/external/python/cpython2/Doc/includes/
H A Dmp_workers.py20 # Function run by worker processes
23 def worker(input, output): function
66 # Start worker processes
68 Process(target=worker, args=(task_queue, done_queue)).start()
/external/caliper/caliper/src/main/java/com/google/caliper/runner/
H A DWorkerProcess.java25 import com.google.caliper.worker.WorkerMain;
45 * A representation of an unstarted worker.
47 * <p>A worker is a sub process that runs a benchmark trial. Specifically it is a JVM running
48 * {@link com.google.caliper.worker.WorkerMain}. Because of this we can make certain assumptions
52 * <li>The worker will connect back to us over a socket connection and send us UTF-8 json
61 private Process worker; field in class:WorkerProcess
96 * Returns a {@link Process} representing this worker. The process will be started if it hasn't
100 if (worker == null) {
102 final Thread shutdownHook = new Thread("worker-shutdown-hook-" + trialId) {
108 worker
[all...]
/external/jacoco/org.jacoco.agent.rt/src/org/jacoco/agent/rt/internal/output/
H A DTcpClientOutput.java35 private Thread worker; field in class:TcpClientOutput
52 worker = new Thread(new Runnable() {
61 worker.setName(getClass().getName());
62 worker.setDaemon(true);
63 worker.start();
68 worker.join();

Completed in 1501 milliseconds

12345