Home
last modified time | relevance | path

Searched refs:worker_thread (Results 1 – 19 of 19) sorted by relevance

/minix3/minix/servers/vfs/
H A Dworker.c7 static void worker_wake(struct worker_thread *worker);
30 struct worker_thread *wp; in worker_init()
70 struct worker_thread *wp; in worker_cleanup()
124 struct worker_thread *worker; in worker_assign()
243 self = (struct worker_thread *) arg; in worker_main()
445 struct worker_thread *worker = self; in worker_sleep()
459 static void worker_wake(struct worker_thread *worker) in worker_wake()
474 struct worker_thread *worker_suspend(void) in worker_suspend()
493 void worker_resume(struct worker_thread *org_self) in worker_resume()
526 void worker_signal(struct worker_thread *worker) in worker_signal()
[all …]
H A Dtll.h11 struct worker_thread *t_owner;/* Owner of non-read-only lock */
16 struct worker_thread *t_write;/* Write/read-only access requestors queue */
17 struct worker_thread *t_serial;/* Read-serialized access requestors queue */
H A Dcomm.c6 static int sendmsg(struct vmnt *vmp, endpoint_t dst, struct worker_thread *wp);
12 static int sendmsg(struct vmnt *vmp, endpoint_t dst, struct worker_thread *wp) in sendmsg()
53 struct worker_thread *worker; in fs_cancel()
68 struct worker_thread *worker; in fs_sendmore()
227 struct worker_thread *queue; in queuemsg()
H A Dthreads.h23 struct worker_thread { struct
35 struct worker_thread *w_next; argument
H A Dglo.h34 EXTERN struct worker_thread *self;
37 EXTERN struct worker_thread workers[NR_WTHREADS];
H A Dtype.h9 struct worker_thread *c_req_queue;/* Queue of procs waiting to send a message */
H A Dproto.h21 struct worker_thread;
416 struct worker_thread *worker_get(thread_t worker_tid);
417 void worker_signal(struct worker_thread *worker);
421 void worker_stop(struct worker_thread *worker);
425 struct worker_thread *worker_suspend(void);
426 void worker_resume(struct worker_thread *org_self);
H A Ddmap.c30 struct worker_thread *org_self; in lock_dmap()
282 struct worker_thread *worker; in dmap_endpt_up()
H A Dfproc.h72 struct worker_thread *fp_worker;/* active worker thread, or NULL */
H A Dmain.c37 static void do_reply(struct worker_thread *wp);
61 struct worker_thread *wp; in main()
187 static void do_reply(struct worker_thread *wp) in do_reply()
531 struct worker_thread *org_self; in lock_proc()
H A Dtll.c13 struct worker_thread *queue; in tll_append()
258 struct worker_thread *new_owner; in tll_unlock()
H A Dvnode.c182 struct worker_thread *w; in unlock_vnode()
H A Dbdev.c195 struct worker_thread *wp; in bdev_reply()
H A Dread.c51 struct worker_thread *org_self; in lock_bsf()
H A Dcdev.c432 struct worker_thread *wp; in cdev_generic_reply()
H A Dfiledes.c316 struct worker_thread *org_self; in lock_filp()
H A Dsdev.c993 struct worker_thread *wp; in sdev_reply()
/minix3/external/public-domain/xz/dist/src/liblzma/common/
H A Dstream_encoder_mt.c48 typedef struct worker_thread_s worker_thread; typedef
88 worker_thread *next;
145 worker_thread *threads;
158 worker_thread *threads_free;
162 worker_thread *thr;
181 worker_error(worker_thread *thr, lzma_ret ret) in worker_error()
198 worker_encode(worker_thread *thr, worker_state state) in worker_encode()
347 worker_thread *thr = thr_ptr; in worker_start()
473 worker_thread *thr = &coder->threads[coder->threads_initialized]; in initialize_new_thread()
1019 options->threads * sizeof(worker_thread), in stream_encoder_mt_init()
[all …]
/minix3/minix/lib/libblockdriver/
H A Ddriver_mt.c143 static void *worker_thread(void *param) in worker_thread() function
232 r = mthread_create(&wp->mthread, &attr, worker_thread, (void *) wp); in master_create_worker()