| /dports/devel/gearmand/gearmand-1.0.6/tests/ |
| H A D | start_worker.cc | 75 gearman_function_t worker_fn; member
94 worker_fn(func_arg), in context_st()
187 context->worker_fn, in thread_runner()
236 const gearman_function_t &worker_fn, in test_worker_start() argument
244 context_st *context= new context_st(handle, worker_fn, port, in test_worker_start()
|
| H A D | burnin.cc | 31 static gearman_return_t worker_fn(gearman_job_st*, void*) in worker_fn() function
44 gearman_function_t func_arg= gearman_function_create(worker_fn); in client_test_st()
|
| H A D | start_worker.h | 98 const gearman_function_t &worker_fn,
|
| /dports/devel/gearmand/gearmand-1.0.6/benchmark/ |
| H A D | blobslap_worker.cc | 61 static void *worker_fn(gearman_job_st *job, void *context,
216 worker_fn, &benchmark))) in main()
227 worker_fn, &benchmark))) in main()
262 static void *worker_fn(gearman_job_st *job, void *context, in worker_fn() function
|
| /dports/misc/py-gluonnlp/gluon-nlp-0.10.0/src/gluonnlp/data/ |
| H A D | datasetloader.py | 78 pin_memory=False, worker_fn=_batch_worker_fn, prefetch=0, argument
86 self._worker_fn = worker_fn
183 worker_fn=_dataset_worker_fn, argument
192 self._worker_fn = worker_fn
432 worker_fn=_dataset_worker_fn,
442 pin_memory=self._pin_memory, worker_fn=_batch_worker_fn,
|
| H A D | dataloader.py | 63 worker_fn=_worker_fn, prefetch=0, dataset=None): argument
71 self._worker_fn = worker_fn
236 worker_fn=_thread_worker_fn if self._thread_pool else _worker_fn,
|
| /dports/misc/py-gluoncv/gluon-cv-0.9.0/gluoncv/data/ |
| H A D | dataloader.py | 162 pin_memory=False, pin_device_id=0, worker_fn=_worker_fn, prefetch=0): argument
165 worker_fn=worker_fn, prefetch=0)
297 worker_fn=_worker_fn, prefetch=self._prefetch)
|
| /dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/bgq/src/test/ |
| H A D | l2atomic_fifo_perf.c | 111 static void * worker_fn (void * arg) { in worker_fn() function
225 if (pthread_create(&info[pid], NULL, &worker_fn, (void*)pid)) { lineno = __LINE__; goto err; } in main()
228 worker_fn((void *)0); in main()
|
| /dports/devel/p5-Gearman-XS/Gearman-XS-0.12/ |
| H A D | Worker.xs | 201 add_function(self, function_name, timeout, worker_fn, context)
205 SV * worker_fn
211 worker_cb->func= newSVsv(worker_fn);
|
| /dports/devel/aml/aml-0.2.1/src/ |
| H A D | thread-pool.c | 90 static void* worker_fn(void* context) in worker_fn() function
147 rc = pthread_create(&thread_pool[i], NULL, worker_fn, NULL); in thread_pool_acquire_default()
|
| /dports/net/py-trio/trio-0.19.0/trio/ |
| H A D | _threads.py | 167 def worker_fn(): function
195 start_thread_soon(worker_fn, deliver_worker_fn_result)
|
| /dports/devel/gearmand/gearmand-1.0.6/examples/ |
| H A D | reverse_worker.cc | 238 gearman_function_t worker_fn= gearman_function_create(reverse_worker); in main() local
241 worker_fn, in main()
|
| /dports/misc/mxnet/incubator-mxnet-1.9.0/python/mxnet/gluon/data/ |
| H A D | dataloader.py | 215 pin_memory=False, pin_device_id=0, worker_fn=worker_loop_v1): argument
235 target=worker_fn,
441 pin_device_id=0, worker_fn=_worker_fn, prefetch=0, dataset=None, argument
450 self._worker_fn = worker_fn
708 worker_fn=_thread_worker_fn if self._thread_pool else _worker_fn,
|
| /dports/misc/py-mxnet/incubator-mxnet-1.9.0/python/mxnet/gluon/data/ |
| H A D | dataloader.py | 215 pin_memory=False, pin_device_id=0, worker_fn=worker_loop_v1): argument
235 target=worker_fn,
441 pin_device_id=0, worker_fn=_worker_fn, prefetch=0, dataset=None, argument
450 self._worker_fn = worker_fn
708 worker_fn=_thread_worker_fn if self._thread_pool else _worker_fn,
|
| /dports/devel/gearmand/gearmand-1.0.6/libgearman/ |
| H A D | worker.cc | 906 gearman_worker_fn *worker_fn, in gearman_worker_add_function() argument
916 if (worker_fn == NULL) in gearman_worker_add_function()
920 gearman_function_t local= gearman_function_create_v1(worker_fn); in gearman_worker_add_function()
|
| /dports/misc/py-xgboost/xgboost-1.5.1/tests/python-gpu/ |
| H A D | test_gpu_with_dask.py | 435 def worker_fn(worker_addr: str, data_ref: Dict) -> None: function
445 worker_fn,
|
| /dports/misc/xgboost/xgboost-1.5.1/tests/python-gpu/ |
| H A D | test_gpu_with_dask.py | 435 def worker_fn(worker_addr: str, data_ref: Dict) -> None: function
445 worker_fn,
|
| /dports/misc/py-xgboost/xgboost-1.5.1/tests/python/ |
| H A D | test_with_dask.py | 1276 def worker_fn(worker_addr: str, data_ref: Dict) -> None: function
1287 worker_fn, workers[i],
|
| /dports/misc/xgboost/xgboost-1.5.1/tests/python/ |
| H A D | test_with_dask.py | 1276 def worker_fn(worker_addr: str, data_ref: Dict) -> None: function
1287 worker_fn, workers[i],
|