Home
last modified time | relevance | path

Searched refs:worker (Results 1 – 25 of 563) sorted by relevance

12345678910>>...23

/external/libvpx/libvpx/vpx_util/
Dvpx_thread.c30 static void execute(VPxWorker *const worker); // Forward declaration.
33 VPxWorker *const worker = (VPxWorker *)ptr; in thread_loop() local
36 pthread_mutex_lock(&worker->impl_->mutex_); in thread_loop()
37 while (worker->status_ == OK) { // wait in idling mode in thread_loop()
38 pthread_cond_wait(&worker->impl_->condition_, &worker->impl_->mutex_); in thread_loop()
40 if (worker->status_ == WORK) { in thread_loop()
41 execute(worker); in thread_loop()
42 worker->status_ = OK; in thread_loop()
43 } else if (worker->status_ == NOT_OK) { // finish the worker in thread_loop()
47 pthread_cond_signal(&worker->impl_->condition_); in thread_loop()
[all …]
/external/libaom/libaom/aom_util/
Daom_thread.c39 static void execute(AVxWorker *const worker); // Forward declaration.
42 AVxWorker *const worker = (AVxWorker *)ptr; in thread_loop() local
44 if (worker->thread_name != NULL) { in thread_loop()
51 strncpy(thread_name, worker->thread_name, sizeof(thread_name) - 1); in thread_loop()
56 if (worker->thread_name != NULL) { in thread_loop()
60 strncpy(thread_name, worker->thread_name, sizeof(thread_name) - 1); in thread_loop()
67 pthread_mutex_lock(&worker->impl_->mutex_); in thread_loop()
68 while (worker->status_ == OK) { // wait in idling mode in thread_loop()
69 pthread_cond_wait(&worker->impl_->condition_, &worker->impl_->mutex_); in thread_loop()
71 if (worker->status_ == WORK) { in thread_loop()
[all …]
/external/webp/src/utils/
Dthread_utils.c205 WebPWorker* const worker = (WebPWorker*)ptr; in ThreadLoop() local
206 WebPWorkerImpl* const impl = (WebPWorkerImpl*)worker->impl_; in ThreadLoop()
210 while (worker->status_ == OK) { // wait in idling mode in ThreadLoop()
213 if (worker->status_ == WORK) { in ThreadLoop()
214 WebPGetWorkerInterface()->Execute(worker); in ThreadLoop()
215 worker->status_ = OK; in ThreadLoop()
216 } else if (worker->status_ == NOT_OK) { // finish the worker in ThreadLoop()
231 static void ChangeState(WebPWorker* const worker, WebPWorkerStatus new_status) { in ChangeState() argument
235 WebPWorkerImpl* const impl = (WebPWorkerImpl*)worker->impl_; in ChangeState()
239 if (worker->status_ >= OK) { in ChangeState()
[all …]
/external/drm_hwcomposer/tests/
Dworker_test.cpp57 TestWorker worker; member
60 worker.Init(); in SetUp()
70 ASSERT_TRUE(worker.initialized()); in TEST_F()
72 int val = worker.value; in TEST_F()
76 ASSERT_EQ(val, worker.value); in TEST_F()
78 worker.Control(true); in TEST_F()
82 worker.Lock(); in TEST_F()
83 val = worker.value; in TEST_F()
85 ASSERT_EQ(val, worker.value); in TEST_F()
86 worker.Unlock(); in TEST_F()
[all …]
/external/grpc-grpc/src/core/lib/iomgr/
Dpollset_windows.cc51 static void remove_worker(grpc_pollset_worker* worker, in remove_worker() argument
53 worker->links[type].prev->links[type].next = worker->links[type].next; in remove_worker()
54 worker->links[type].next->links[type].prev = worker->links[type].prev; in remove_worker()
55 worker->links[type].next = worker->links[type].prev = worker; in remove_worker()
76 grpc_pollset_worker* worker) { in push_front_worker() argument
77 worker->links[type].prev = root; in push_front_worker()
78 worker->links[type].next = worker->links[type].prev->links[type].next; in push_front_worker()
79 worker->links[type].prev->links[type].next = in push_front_worker()
80 worker->links[type].next->links[type].prev = worker; in push_front_worker()
112 grpc_pollset_worker worker; in pollset_work() local
[all …]
Dev_epoll1_linux.cc187 #define SET_KICK_STATE(worker, kick_state) \ argument
189 (worker)->state = (kick_state); \
190 (worker)->kick_state_mutator = __LINE__; \
458 static bool worker_insert(grpc_pollset* pollset, grpc_pollset_worker* worker) { in worker_insert() argument
460 pollset->root_worker = worker; in worker_insert()
461 worker->next = worker->prev = worker; in worker_insert()
464 worker->next = pollset->root_worker; in worker_insert()
465 worker->prev = worker->next->prev; in worker_insert()
466 worker->next->prev = worker; in worker_insert()
467 worker->prev->next = worker; in worker_insert()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/
Dpollset_windows.cc51 static void remove_worker(grpc_pollset_worker* worker, in remove_worker() argument
53 worker->links[type].prev->links[type].next = worker->links[type].next; in remove_worker()
54 worker->links[type].next->links[type].prev = worker->links[type].prev; in remove_worker()
55 worker->links[type].next = worker->links[type].prev = worker; in remove_worker()
76 grpc_pollset_worker* worker) { in push_front_worker() argument
77 worker->links[type].prev = root; in push_front_worker()
78 worker->links[type].next = worker->links[type].prev->links[type].next; in push_front_worker()
79 worker->links[type].prev->links[type].next = in push_front_worker()
80 worker->links[type].next->links[type].prev = worker; in push_front_worker()
112 grpc_pollset_worker worker; in pollset_work() local
[all …]
Dev_epoll1_linux.cc193 #define SET_KICK_STATE(worker, kick_state) \ argument
195 (worker)->state = (kick_state); \
196 (worker)->kick_state_mutator = __LINE__; \
477 static bool worker_insert(grpc_pollset* pollset, grpc_pollset_worker* worker) { in worker_insert() argument
479 pollset->root_worker = worker; in worker_insert()
480 worker->next = worker->prev = worker; in worker_insert()
483 worker->next = pollset->root_worker; in worker_insert()
484 worker->prev = worker->next->prev; in worker_insert()
485 worker->next->prev = worker; in worker_insert()
486 worker->prev->next = worker; in worker_insert()
[all …]
Dev_epollex_linux.cc970 grpc_pollset_worker* worker, pwlinks link) { argument
972 *root_worker = worker;
973 worker->links[link].next = worker->links[link].prev = worker;
976 worker->links[link].next = *root_worker;
977 worker->links[link].prev = worker->links[link].next->links[link].prev;
978 worker->links[link].next->links[link].prev = worker;
979 worker->links[link].prev->links[link].next = worker;
988 grpc_pollset_worker* worker, argument
990 if (worker == *root_worker) {
991 if (worker == worker->links[link].next) {
[all …]
/external/rust/crates/rayon-core/src/
Dlog.rs37 worker: usize,
42 ThreadTerminate { worker: usize },
45 ThreadIdle { worker: usize, latch_addr: usize },
49 ThreadFoundWork { worker: usize, yields: u32 },
55 ThreadSawLatchSet { worker: usize, latch_addr: usize },
59 ThreadSleepy { worker: usize, jobs_counter: usize },
64 ThreadSleepInterruptedByLatch { worker: usize, latch_addr: usize },
69 ThreadSleepInterruptedByJob { worker: usize },
72 ThreadSleeping { worker: usize, latch_addr: usize },
75 ThreadAwoken { worker: usize, latch_addr: usize },
[all …]
/external/rust/crates/tokio/src/runtime/thread_pool/
Dworker.rs105 worker: Arc<Worker>, field
188 let core = cx.worker.core.take(); in block_in_place()
248 cx.worker.core.set(core); in block_in_place()
255 let worker = cx.worker.clone(); in block_in_place() localVariable
256 runtime::spawn_blocking(move || run(worker)); in block_in_place()
278 for worker in self.0.drain(..) { in launch()
279 runtime::spawn_blocking(move || run(worker)); in launch()
284 fn run(worker: Arc<Worker>) { in run()
287 let core = match worker.core.take() { in run()
294 worker, in run()
[all …]
/external/libchrome/base/task_scheduler/
Dscheduler_worker_unittest.cc62 void OnMainEntry(const SchedulerWorker* worker) override {} in OnMainEntry() argument
63 scoped_refptr<Sequence> GetWork(SchedulerWorker* worker) override { in GetWork() argument
150 void OnMainEntry(const SchedulerWorker* worker) override { in OnMainEntry() argument
152 EXPECT_EQ(outer_->worker_.get(), worker); in OnMainEntry()
162 scoped_refptr<Sequence> GetWork(SchedulerWorker* worker) override { in GetWork() argument
164 EXPECT_EQ(outer_->worker_.get(), worker); in GetWork()
428 scoped_refptr<Sequence> GetWork(SchedulerWorker* worker) in GetWork() argument
435 if (CanCleanup(worker)) { in GetWork()
437 worker->Cleanup(); in GetWork()
466 void OnMainExit(SchedulerWorker* worker) override { in OnMainExit() argument
[all …]
Dscheduler_worker_pool_impl.cc56 const SchedulerWorker* worker) { in ContainsWorker() argument
58 [worker](const scoped_refptr<SchedulerWorker>& i) { in ContainsWorker()
59 return i.get() == worker; in ContainsWorker()
77 void OnMainEntry(const SchedulerWorker* worker) override;
78 scoped_refptr<Sequence> GetWork(SchedulerWorker* worker) override;
82 void OnMainExit(SchedulerWorker* worker) override;
105 bool CanCleanupLockRequired(const SchedulerWorker* worker) const;
110 void CleanupLockRequired(SchedulerWorker* worker);
113 void OnWorkerBecomesIdleLockRequired(SchedulerWorker* worker);
235 SchedulerWorker* worker = in Start() local
[all …]
Dscheduler_worker_stack.cc20 void SchedulerWorkerStack::Push(SchedulerWorker* worker) { in Push() argument
21 DCHECK(!Contains(worker)) << "SchedulerWorker already on stack"; in Push()
24 stack_.push_back(worker); in Push()
30 SchedulerWorker* const worker = stack_.back(); in Pop() local
34 return worker; in Pop()
43 bool SchedulerWorkerStack::Contains(const SchedulerWorker* worker) const { in Contains()
44 return ContainsValue(stack_, worker); in Contains()
47 void SchedulerWorkerStack::Remove(const SchedulerWorker* worker) { in Remove() argument
49 DCHECK_NE(worker, stack_.back()); in Remove()
50 auto it = std::find(stack_.begin(), stack_.end(), worker); in Remove()
/external/chromium-trace/catapult/common/py_utils/py_utils/
Dexc_util_unittest.py115 worker = FaultyClient(FakeProcessingError, FakeCleanupError)
120 worker.Process()
124 worker.Cleanup()
131 self.assertItemsEqual(worker.called, ['Process', 'Cleanup'])
134 worker = FaultyClient(FakeProcessingError)
139 worker.Process()
143 worker.Cleanup()
147 self.assertItemsEqual(worker.called, ['Process', 'Cleanup'])
150 worker = FaultyClient(FakeCleanupError)
156 worker.Process()
[all …]
/external/tensorflow/tensorflow/compiler/mlir/tensorflow/tests/
Dcross_host_transfer.mlir5 …// CHECK-NEXT: %[[RESULT_0:.*]] = "tf.Const"() {device = "/job:worker/replica:0/task:0/device:CPU:…
6 …%0 = "tf.Const"() {device = "/job:worker/replica:0/task:0/device:CPU:0", value = dense<3.000000e+0…
8 …ECK-NEXT: tf_device.send %[[RESULT_0]] "key-0" "/job:worker/replica:0/task:1" {device = "/job:work…
9 …: %[[RESULT_1:.*]] = tf_device.receive "key-0" "/job:worker/replica:0/task:0" {device = "/job:work…
10 …// CHECK-NEXT: %[[RESULT_2:.*]] = "tf.Sqrt"(%[[RESULT_1]]) {device = "/job:worker/replica:0/task:1…
11 …%1 = "tf.Sqrt"(%0) {device = "/job:worker/replica:0/task:1/device:CPU:0"} : (tensor<f32>) -> tenso…
13 …// CHECK-NEXT: %[[RESULT_3:.*]] = "tf.Sqrt"(%[[RESULT_1]]) {device = "/job:worker/replica:0/task:1…
14 …%2 = "tf.Sqrt"(%0) {device = "/job:worker/replica:0/task:1/device:CPU:0"} : (tensor<f32>) -> tenso…
20 …// CHECK-NEXT: %[[RESULT_0:.*]] = "tf.Const"() {device = "/job:worker/replica:0/task:0/device:CPU:…
21 …%0 = "tf.Const"() {device = "/job:worker/replica:0/task:0/device:CPU:0", value = dense<3.000000e+0…
[all …]
Dtpu_compile_op_replication_pass.mlir3 …ensor<i32> {tf.device = "/job:worker/replica:0/task:0/device:CPU:0"}, %[[ARG_1:.*]]: tensor<i32> {…
4 …0: tensor<i32> {tf.device = "/job:worker/replica:0/task:0/device:CPU:0"}, %arg1: tensor<i32> {tf.d…
5 …TATUS_0:.*]], %[[PROGRAM_0:.*]] = "tf._TPUCompileMlir"() {device = "/job:worker/replica:0/task:1/d…
6 …// CHECK-NEXT: "tf.TPUCompileSucceededAssert"(%[[STATUS_0]]) {device = "/job:worker/replica:0/task…
7 …TATUS_1:.*]], %[[PROGRAM_1:.*]] = "tf._TPUCompileMlir"() {device = "/job:worker/replica:0/task:0/d…
8 …%compilation_status, %program = "tf._TPUCompileMlir"() {device = "/job:worker/replica:0/task:0/dev…
9 …// CHECK-NEXT: "tf.TPUCompileSucceededAssert"(%[[STATUS_1]]) {device = "/job:worker/replica:0/task…
10 …"tf.TPUCompileSucceededAssert"(%compilation_status) {device = "/job:worker/replica:0/task:0/device…
11 …// CHECK-NEXT: %[[ADD_0:.*]] = "tf.AddV2"(%[[ARG_0]], %[[ARG_0]]) {device = "/job:worker/replica:0…
12 …%0 = "tf.AddV2"(%arg0, %arg0) {device = "/job:worker/replica:0/task:0/device:TPU:0"} : (tensor<i32…
[all …]
Dcluster_tf_ops_pass.mlir6 // - A remote subgraph which contains remote ops on worker:1.
7 …a:0/task:0/device:CPU:0"}, %[[ARG_1:.*]]: tensor<i32> {tf.device = "/job:worker/replica:0/task:1/d…
12 // CHECK-NEXT: %[[RESULT_1:.*]] = tf_device.remote_run "/job:worker/replica:0/task:1" @[[MAIN_PAR…
14 …t/replica:0/task:0/device:CPU:0"}, %arg1: tensor<i32> {tf.device = "/job:worker/replica:0/task:1/d…
17 …%2 = "tf.AddV2"(%arg1, %arg1) {device = "/job:worker/replica:0/task:1/device:CPU:0"} : (tensor<i32…
20 // Subgraph of @main function that is placed on worker:1
21 // CHECK: func @[[MAIN_PARTITION_0]](%[[ARG_0:.*]]: tensor<i32> {tf.device = "/job:worker/replica:0…
22 // CHECK-SAME: host = "/job:worker/replica:0/task:1"
24 // CHECK-SAME: device = "/job:worker/replica:0/task:1/device:CPU:0"
42 // - Two remote subgraph which contains remote ops on worker:1 and worker:2.
[all …]
Dtf_device_replication_pass.mlir3 …ensor<i32> {tf.device = "/job:worker/replica:0/task:0/device:CPU:0"}, %[[ARG_1:.*]]: tensor<i32> {…
4 …0: tensor<i32> {tf.device = "/job:worker/replica:0/task:0/device:CPU:0"}, %arg1: tensor<i32> {tf.d…
5 …// CHECK-NEXT: %[[RESULT_0:.*]] = "tf.AddV2"(%[[ARG_0]], %[[ARG_0]]) {device = "/job:worker/replic…
6 …// CHECK-NEXT: %[[RESULT_1:.*]] = "tf.AddV2"(%[[ARG_0]], %[[ARG_0]]) {device = "/job:worker/replic…
7 …// CHECK-NEXT: %[[RESULT_2:.*]] = "tf.AddV2"(%[[ARG_1]], %[[ARG_1]]) {device = "/job:worker/replic…
8 …// CHECK-NEXT: %[[RESULT_3:.*]] = "tf.AddV2"(%[[ARG_1]], %[[ARG_1]]) {device = "/job:worker/replic…
9 …"/job:worker/replica:0/task:0/device:CPU:0", "/job:worker/replica:0/task:0/device:CPU:1", "/job:wo…
19 func @test_2(%arg0: tensor<i32> {tf.device = "/job:worker/replica:0/task:0/device:CPU:0"}) -> (tens…
/external/tensorflow/tensorflow/core/protobuf/
Dworker_service.proto20 import "tensorflow/core/protobuf/worker.proto";
32 // A worker service keeps track of multiple "registered graphs". Each
34 // only the nodes that should execute on this worker (and any
41 // See worker.proto for details.
44 // See worker.proto for details.
48 // See worker.proto for details.
52 // See worker.proto for details.
55 // See worker.proto for details.
58 // See worker.proto for details.
61 // See worker.proto for details.
[all …]
/external/perfetto/infra/ci/
DMakefile18 override GCE_LOCAL_STARTUP_SCRIPT := worker/gce-startup-script.sh
20 override GCE_STARTUP_SCRIPT := gs://perfetto/ci/worker-startup-script/${SCRIPT_HASH}
36 build: build-worker build-sandbox
38 .PHONY: build-worker
39 build-worker: .deps/${BUILDER}-worker
53 .deps/${BUILDER}-worker: worker/* ${COMMON_DEPS}
54 mkdir -p worker/tmp
55 cp -a config.py common_utils.py worker/tmp/
56 ${BUILDER} build --rm --force-rm -t ${WORKER_IMG} worker
57 rm -rf worker/tmp/
[all …]
/external/tensorflow/tensorflow/compiler/xla/python/tpu_driver/client/
Dtpu_client.py36 def create(worker=None, force=False): argument
40 if worker is None:
46 if worker == 'local' or 'local://' in worker:
49 if worker == 'local':
50 worker = 'local://'
52 return _tpu_client.TpuClient.Get(worker)
55 TpuBackend._local_backend = _tpu_client.TpuClient.Get(worker)
59 return _tpu_client.TpuClient.Get(worker)
/external/ltp/testcases/kernel/io/direct_io/
Ddma_thread_diotest.c155 static worker_t *worker; variable
161 worker_t *worker = (worker_t *)arg; in worker_thread() local
162 int offset = worker->offset; in worker_thread()
163 int fd = worker->fd; in worker_thread()
164 unsigned char *buffer = worker->buffer; in worker_thread()
165 int pattern = worker->pattern; in worker_thread()
166 int length = worker->length; in worker_thread()
177 worker->worker_number, strerror(errno)); in worker_thread()
261 worker[j].fd = SAFE_OPEN(cleanup, filename, in dma_thread_diotest_verify()
263 worker[j].pattern = n; in dma_thread_diotest_verify()
[all …]
/external/tensorflow/tensorflow/python/data/experimental/service/
Dserver_lib_test.py99 worker = server_lib.WorkerServer(
101 worker.start()
106 worker = server_lib.WorkerServer(
108 self.assertEqual(worker._address, "localhost:{}".format(port))
112 worker = server_lib.WorkerServer(
114 worker.start()
123 worker = server_lib.WorkerServer(
125 worker._stop()
126 worker._stop()
137 worker = server_lib.WorkerServer(
[all …]
/external/llvm-project/llvm/docs/
DHowToAddABuilder.rst9 buildbot-worker to private worker builder to LLVM Buildbot Infrastructure.
41 #. Install buildbot-worker (currently we are using buildbot version 2.8.5).
42 Depending on the platform, buildbot-worker could be available to download and
46 #. Create a designated user account, your buildbot-worker will be running under,
49 #. Choose the buildbot-worker root directory (all builds will be placed under
50 it), buildbot-worker access name and password the build master will be using
51 to authenticate your buildbot-worker.
53 #. Create a buildbot-worker in context of that buildbot-worker account. Point it
55 Creating a worker
56 <http://docs.buildbot.net/current/tutorial/firstrun.html#creating-a-worker>`_
[all …]

12345678910>>...23