Searched refs:worker (Results 1 - 25 of 41) sorted by relevance

12

/netgear-R7000-V1.0.7.12_1.2.5/components/opensource/linux/linux-2.6.36/fs/btrfs/
H A Dasync-thread.c43 /* list of worker threads from struct btrfs_workers */
70 * and so it may not make progress until after our btrfs worker threads
73 * This means we can't use btrfs_start_workers from inside a btrfs worker
75 * involves all of the worker threads.
80 * another worker.
116 static void check_idle_worker(struct btrfs_worker_thread *worker) argument
118 if (!worker->idle && atomic_read(&worker->num_pending) <
119 worker->workers->idle_thresh / 2) {
121 spin_lock_irqsave(&worker
137 check_busy_worker(struct btrfs_worker_thread *worker) argument
153 check_pending_worker_creates(struct btrfs_worker_thread *worker) argument
225 put_worker(struct btrfs_worker_thread *worker) argument
231 try_worker_shutdown(struct btrfs_worker_thread *worker) argument
256 get_next_work(struct btrfs_worker_thread *worker, struct list_head *prio_head, struct list_head *head) argument
302 struct btrfs_worker_thread *worker = arg; local
411 struct btrfs_worker_thread *worker; local
468 struct btrfs_worker_thread *worker; local
524 struct btrfs_worker_thread *worker; local
568 struct btrfs_worker_thread *worker; local
623 struct btrfs_worker_thread *worker = work->worker; local
670 struct btrfs_worker_thread *worker; local
[all...]
H A Dasync-thread.h34 * the basic model of these worker threads is to embed a btrfs_work
58 struct btrfs_worker_thread *worker; member in struct:btrfs_work
72 /* once a worker has this many requests or fewer, it is idle */
102 /* lock for finding the next worker thread to queue on */
108 /* extra name for this worker, used for current->name */
/netgear-R7000-V1.0.7.12_1.2.5/components/opensource/linux/linux-2.6.36/include/linux/
H A Dkthread.h66 #define KTHREAD_WORKER_INIT(worker) { \
68 .work_list = LIST_HEAD_INIT((worker).work_list), \
78 #define DEFINE_KTHREAD_WORKER(worker) \
79 struct kthread_worker worker = KTHREAD_WORKER_INIT(worker)
84 static inline void init_kthread_worker(struct kthread_worker *worker) argument
86 *worker = (struct kthread_worker)KTHREAD_WORKER_INIT(*worker);
97 bool queue_kthread_work(struct kthread_worker *worker,
100 void flush_kthread_worker(struct kthread_worker *worker);
[all...]
/netgear-R7000-V1.0.7.12_1.2.5/ap/gpl/timemachine/db-4.7.25.NC/test/scr024/src/com/sleepycat/collections/test/
H A DNullTransactionRunner.java23 public void run(TransactionWorker worker) argument
27 worker.doWork();
/netgear-R7000-V1.0.7.12_1.2.5/components/opensource/linux/linux-2.6.36/kernel/
H A Dworkqueue.c3 * kernel/workqueue.c - generic async execution with shared worker pool
19 * executed in process context. The worker pool is shared and
20 * automatically managed. There is one worker pool for each CPU and
63 /* worker flags */
71 WORKER_UNBOUND = 1 << 7, /* worker is unbound */
129 struct worker { struct
139 struct task_struct *task; /* I: worker task */
144 int id; /* I: worker id */
145 struct work_struct rebind_work; /* L: rebind worker to cpu */
167 struct timer_list idle_timer; /* L: worker idl
661 struct worker *worker = first_worker(gcwq); local
680 struct worker *worker = kthread_data(task); local
704 struct worker *worker = kthread_data(task), *to_wakeup = NULL; local
743 worker_set_flags(struct worker *worker, unsigned int flags, bool wakeup) argument
780 worker_clr_flags(struct worker *worker, unsigned int flags) argument
843 struct worker *worker; local
983 struct worker *worker; local
1160 worker_enter_idle(struct worker *worker) argument
1197 worker_leave_idle(struct worker *worker) argument
1275 struct worker *worker = container_of(work, struct worker, rebind_work); local
1286 struct worker *worker; local
1317 struct worker *worker = NULL; local
1378 start_worker(struct worker *worker) argument
1395 destroy_worker(struct worker *worker) argument
1428 struct worker *worker; local
1524 struct worker *worker; variable in typeref:struct:worker
1530 start_worker(worker); variable
1572 struct worker *worker; local
1610 manage_workers(struct worker *worker) argument
1881 process_scheduled_works(struct worker *worker) argument
1902 struct worker *worker = __worker; local
2079 insert_wq_barrier(struct cpu_workqueue_struct *cwq, struct wq_barrier *barr, struct work_struct *target, struct worker *worker) argument
2356 struct worker *worker = NULL; local
2444 struct worker *worker; local
3120 struct worker *worker; local
3614 struct worker *worker; local
[all...]
H A Dkthread.c285 struct kthread_worker *worker = worker_ptr; local
288 WARN_ON(worker->task);
289 worker->task = current;
295 spin_lock_irq(&worker->lock);
296 worker->task = NULL;
297 spin_unlock_irq(&worker->lock);
302 spin_lock_irq(&worker->lock);
303 if (!list_empty(&worker->work_list)) {
304 work = list_first_entry(&worker->work_list,
308 spin_unlock_irq(&worker
335 queue_kthread_work(struct kthread_worker *worker, struct kthread_work *work) argument
403 flush_kthread_worker(struct kthread_worker *worker) argument
[all...]
/netgear-R7000-V1.0.7.12_1.2.5/ap/gpl/timemachine/db-4.7.25.NC/java/src/com/sleepycat/collections/
H A DTransactionRunner.java216 public void run(TransactionWorker worker) argument
229 worker.doWork();
268 worker.doWork();
/netgear-R7000-V1.0.7.12_1.2.5/ap/gpl/timemachine/db-4.7.25.NC/examples_java/src/collections/hello/
H A DHelloDatabaseWorld.java61 HelloDatabaseWorld worker = new HelloDatabaseWorld(env);
65 runner.run(worker);
68 worker.close();
/netgear-R7000-V1.0.7.12_1.2.5/ap/gpl/timemachine/db-4.7.25.NC/test/scr016/src/com/sleepycat/db/test/
H A DRepmgrElectionTest.java57 // start the worker threads
59 RepmgrElectionTest worker = new RepmgrElectionTest(i);
60 worker.run();
61 workers.add(worker);
92 TestUtils.DEBUGOUT(1, "Creating worker: " + threadNumber);
188 * End worker thread implementation
/netgear-R7000-V1.0.7.12_1.2.5/components/opensource/linux/linux-2.6.36/drivers/hwmon/ams/
H A Dams.h32 /* Interrupt worker */
33 struct work_struct worker; member in struct:ams
H A Dams-core.c78 schedule_work(&ams_info.worker);
198 INIT_WORK(&ams_info.worker, ams_worker);
224 /* Flush interrupt worker
/netgear-R7000-V1.0.7.12_1.2.5/ap/gpl/minidlna/ffmpeg-2.3.4/libavcodec/
H A Dframe_thread_encoder.c63 pthread_t worker[MAX_THREADS]; member in struct:__anon3141
67 static void * attribute_align_arg worker(void *v){ function
204 if(pthread_create(&c->worker[i], NULL, worker, thread_avctx)) {
229 pthread_join(c->worker[i], NULL);
H A Dpthread_slice.c71 static void* attribute_align_arg worker(void *v) function
220 if(pthread_create(&c->workers[i], NULL, worker, avctx)) {
/netgear-R7000-V1.0.7.12_1.2.5/ap/gpl/iserver/libgcrypt-1.5.0/tests/
H A Dpkbench.c139 benchmark (work_t worker, context_t context) argument
155 ret = (*worker) (context, (i + 1) == loop);
291 work_t worker; member in struct:__anon2426
302 benchmark (worker_functions[i].worker, context);
/netgear-R7000-V1.0.7.12_1.2.5/ap/gpl/timemachine/libgcrypt-1.5.0/tests/
H A Dpkbench.c139 benchmark (work_t worker, context_t context) argument
155 ret = (*worker) (context, (i + 1) == loop);
291 work_t worker; member in struct:__anon6880
302 benchmark (worker_functions[i].worker, context);
/netgear-R7000-V1.0.7.12_1.2.5/components/opensource/linux/linux-2.6.36/drivers/vhost/
H A Dvhost.c139 wake_up_process(dev->worker);
229 dev->worker = NULL;
276 struct task_struct *worker; local
285 worker = kthread_create(vhost_worker, dev, "vhost-%d", current->pid);
286 if (IS_ERR(worker)) {
287 err = PTR_ERR(worker);
291 dev->worker = worker;
292 wake_up_process(worker); /* avoid contributing to loadavg */
300 kthread_stop(worker);
[all...]
H A Dvhost.h103 * All readers access it from worker, which makes it possible to
129 struct task_struct *worker; member in struct:vhost_dev
/netgear-R7000-V1.0.7.12_1.2.5/ap/gpl/amule/wxWidgets-2.8.12/docs/latex/wx/
H A Dconditn.tex7 For example, if a worker thread is doing some long task and another thread has
9 object and the worker thread will signal it on exit (this example is not
11 \helpref{Wait()}{wxthreadwait} for the worker thread, but if there are several
12 worker threads it already makes much more sense).
25 This example shows how a main thread may launch a worker thread which starts
H A Dthreadh.tex7 and the worker thread. Doing this prevents the awkward passing of pointers
9 synchronize with its worker thread in its own wxThread derived object.
H A Dtthreads.tex36 several worker threads which communicate with the main one using events is much
46 to send messages to the worker threads and you will need to use the available
/netgear-R7000-V1.0.7.12_1.2.5/ap/gpl/libpcap-1.4.0/
H A Dpcap-canusb-linux.c81 pthread_t worker; member in struct:canusb_t
308 pthread_create(&this->worker, NULL, canusb_capture_thread, &canusb);
330 pthread_join(canusb.worker, NULL);
/netgear-R7000-V1.0.7.12_1.2.5/ap/gpl/openssl-1.0.2h/crypto/
H A Dsparcv9cap.c51 bn_mul_mont_f worker = funcs[num / 16 - 1]; local
53 if ((*worker) (rp, ap, bp, np, n0))
56 if ((*worker) (rp, ap, bp, np, n0))
/netgear-R7000-V1.0.7.12_1.2.5/ap/gpl/openssl/crypto/
H A Dsparcv9cap.c51 bn_mul_mont_f worker = funcs[num / 16 - 1]; local
53 if ((*worker) (rp, ap, bp, np, n0))
56 if ((*worker) (rp, ap, bp, np, n0))
/netgear-R7000-V1.0.7.12_1.2.5/ap/gpl/minidlna/ffmpeg-2.3.4/libavfilter/
H A Dpthread.c65 static void* attribute_align_arg worker(void *v) function
187 ret = pthread_create(&c->workers[i], NULL, worker, c);
/netgear-R7000-V1.0.7.12_1.2.5/components/opensource/linux/linux-2.6.36/drivers/media/video/hdpvr/
H A Dhdpvr.h102 struct work_struct worker; member in struct:hdpvr_device

Completed in 222 milliseconds

12