/netgear-R7000-V1.0.7.12_1.2.5/components/opensource/linux/linux-2.6.36/fs/btrfs/ |
H A D | async-thread.c | 43 /* 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 D | async-thread.h | 34 * 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 D | kthread.h | 66 #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 D | NullTransactionRunner.java | 23 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 D | workqueue.c | 3 * 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 D | kthread.c | 285 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 D | TransactionRunner.java | 216 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 D | HelloDatabaseWorld.java | 61 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 D | RepmgrElectionTest.java | 57 // 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 D | ams.h | 32 /* Interrupt worker */ 33 struct work_struct worker; member in struct:ams
|
H A D | ams-core.c | 78 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 D | frame_thread_encoder.c | 63 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 D | pthread_slice.c | 71 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 D | pkbench.c | 139 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 D | pkbench.c | 139 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 D | vhost.c | 139 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 D | vhost.h | 103 * 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 D | conditn.tex | 7 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 D | threadh.tex | 7 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 D | tthreads.tex | 36 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 D | pcap-canusb-linux.c | 81 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 D | sparcv9cap.c | 51 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 D | sparcv9cap.c | 51 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 D | pthread.c | 65 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 D | hdpvr.h | 102 struct work_struct worker; member in struct:hdpvr_device
|