Home
last modified time | relevance | path

Searched refs:work (Results 1 – 25 of 28) sorted by relevance

12

/unit/src/
H A Dnxt_work_queue.c135 work = &chunk->work; in nxt_work_queue_allocate()
138 work[i].next = &work[i + 1]; in nxt_work_queue_allocate()
142 work++; in nxt_work_queue_allocate()
146 work = NULL; in nxt_work_queue_allocate()
204 work = wq->head; in nxt_work_queue_pop()
214 *obj = work->obj; in nxt_work_queue_pop()
241 lwq->tail = work; in nxt_locked_work_queue_add()
260 work = lwq->head; in nxt_locked_work_queue_pop()
306 nxt_work_queue_add(wq, work->handler, work->task, in nxt_locked_work_queue_move()
307 work->obj, work->data); in nxt_locked_work_queue_move()
[all …]
H A Dnxt_work_queue.h51 nxt_work_t work; member
97 nxt_work_t *work = _work; \
99 work->handler = _handler; \
100 work->task = _task; \
101 work->obj = _obj; \
102 work->data = _data; \
120 nxt_work_t *work);
H A Dnxt_thread_pool.c42 nxt_thread_pool_post(nxt_thread_pool_t *tp, nxt_work_t *work) in nxt_thread_pool_post() argument
50 nxt_locked_work_queue_add(&tp->work_queue, work); in nxt_thread_pool_post()
90 link->work.data = tp; in nxt_thread_pool_init()
220 link->work.data = tp; in nxt_thread_pool_wait()
248 nxt_work_set(&tp->work, nxt_thread_pool_exit, &tp->task, tp, NULL); in nxt_thread_pool_destroy()
250 nxt_thread_pool_post(tp, &tp->work); in nxt_thread_pool_destroy()
289 nxt_work_set(&tp->work, nxt_thread_pool_exit, &tp->task, tp, in nxt_thread_pool_exit()
292 nxt_thread_pool_post(tp, &tp->work); in nxt_thread_pool_exit()
299 nxt_work_set(&tp->work, tp->exit, &tp->engine->task, tp, in nxt_thread_pool_exit()
302 nxt_event_engine_post(tp->engine, &tp->work); in nxt_thread_pool_exit()
H A Dnxt_buf.c15 nxt_work_t work; member
86 ts->work.handler = nxt_buf_ts_completion; in nxt_buf_mem_ts_alloc()
87 ts->work.task = task; in nxt_buf_mem_ts_alloc()
88 ts->work.obj = b; in nxt_buf_mem_ts_alloc()
89 ts->work.data = b->parent; in nxt_buf_mem_ts_alloc()
257 ts->work.handler = b->completion_handler; in nxt_buf_ts_handle()
258 ts->work.obj = obj; in nxt_buf_ts_handle()
259 ts->work.data = data; in nxt_buf_ts_handle()
261 nxt_event_engine_post(ts->engine, &ts->work); in nxt_buf_ts_handle()
H A Dnxt_thread.c117 data = link->work.data; in nxt_thread_trampoline()
119 if (link->work.handler != NULL) { in nxt_thread_trampoline()
199 link->work.obj = (void *) (uintptr_t) thr->handle; in nxt_thread_exit()
200 engine = nxt_container_of(link->work.task, nxt_event_engine_t, task); in nxt_thread_exit()
202 nxt_event_engine_post(engine, &link->work); in nxt_thread_exit()
H A Dnxt_thread_pool.h23 nxt_work_t work; member
41 nxt_work_t *work);
H A Dnxt_mp.c321 work = mp->cleanup; in nxt_mp_destroy()
322 next_work = work->next; in nxt_mp_destroy()
324 work->handler(work->task, work->obj, work->data); in nxt_mp_destroy()
1044 nxt_work_t *work; in nxt_mp_cleanup() local
1048 if (nxt_slow_path(work == NULL)) { in nxt_mp_cleanup()
1052 work->next = mp->cleanup; in nxt_mp_cleanup()
1053 work->handler = handler; in nxt_mp_cleanup()
1054 work->task = task; in nxt_mp_cleanup()
1055 work->obj = obj; in nxt_mp_cleanup()
1056 work->data = data; in nxt_mp_cleanup()
[all …]
H A Dnxt_job.c116 nxt_work_set(&job->work, nxt_job_thread_trampoline, in nxt_job_start()
119 ret = nxt_thread_pool_post(job->thread_pool, &job->work); in nxt_job_start()
162 nxt_work_set(&job->work, nxt_job_thread_return_handler, in nxt_job_return()
165 nxt_event_engine_post(job->engine, &job->work); in nxt_job_return()
H A Dnxt_job.h50 nxt_work_t work; member
H A Dnxt_port.c548 nxt_work_t work; member
593 pw->work.handler = nxt_port_post_handler; in nxt_port_post()
594 pw->work.task = &port->engine->task; in nxt_port_post()
595 pw->work.obj = pw; in nxt_port_post()
596 pw->work.data = data; in nxt_port_post()
601 nxt_event_engine_post(port->engine, &pw->work); in nxt_port_post()
H A Dnxt_router.c3241 job->work.obj = NULL; in nxt_router_engine_quit()
3242 job->work.data = NULL; in nxt_router_engine_quit()
3391 for (work = jobs; work != NULL; work = next) { in nxt_router_engine_post()
3392 next = work->next; in nxt_router_engine_post()
3393 work->next = NULL; in nxt_router_engine_post()
3472 work->task = link->work.task; in nxt_router_thread_start()
3473 work->obj = work; in nxt_router_thread_start()
3474 work->data = port; in nxt_router_thread_start()
3476 nxt_event_engine_post(link->work.task->thread->engine, work); in nxt_router_thread_start()
3534 job->work.next = NULL; in nxt_router_listen_socket_create()
[all …]
H A Dnxt_event_conn_job_sendfile.c155 nxt_work_set(&jbs->job.work, nxt_event_conn_job_sendfile_handler, in nxt_event_conn_job_sendfile_handler()
158 nxt_thread_pool_post(task->thread->thread_pool, &jbs->job.work); in nxt_event_conn_job_sendfile_handler()
H A Dnxt_thread.h85 nxt_work_t work; member
H A Dnxt_signal.c140 link->work.data = engine; in nxt_signal_thread_start()
H A Dnxt_event_engine.c250 nxt_event_engine_post(nxt_event_engine_t *engine, nxt_work_t *work) in nxt_event_engine_post() argument
255 if (nxt_slow_path(work->next != NULL)) { in nxt_event_engine_post()
260 nxt_locked_work_queue_add(&engine->locked_work_queue, work); in nxt_event_engine_post()
H A Dnxt_router.h94 nxt_work_t work; member
H A Dnxt_thread_time.c92 link->work.data = (void *) (uintptr_t) interval; in nxt_time_thread_start()
H A Dnxt_event_engine.h506 nxt_work_t *work);
/unit/
H A DLICENSE36 "Work" shall mean the work of authorship, whether in Source or
38 copyright notice that is included in or attached to the work
41 "Derivative Works" shall mean any work, whether in Source or Object
44 represent, as a whole, an original work of authorship. For the purposes
49 "Contribution" shall mean any work of authorship, including
162 work stoppage, computer failure or malfunction, or any and all
H A DCHANGES59 *) Bugfix: Ruby Sinatra applications don't work without custom logging.
73 *) Bugfix: ECMAScript modules did not work with the recent Node.js
453 *) Bugfix: negative address matching in router might work improperly in
505 *) Bugfix: threads in Python applications might not work correctly.
507 *) Bugfix: Ruby on Rails applications might not work on Ruby 2.6.
593 did not work.
651 Control API did not work.
697 *) Bugfix: module discovery did not work on 64-bit big-endian systems
721 *) Bugfix: Go applications did not work when Unit was built with musl C
747 *) Bugfix: "header_read_timeout" might not work properly.
[all …]
H A DCONTRIBUTING.md86 …it](https://docs.github.com/en/issues/tracking-your-work-with-issues/linking-a-pull-request-to-an-…
/unit/src/java/nginx/unit/websocket/server/
H A DLocalStrings.properties3 # this work for additional information regarding copyright ownership.
/unit/src/java/nginx/unit/websocket/pojo/
H A DLocalStrings.properties3 # this work for additional information regarding copyright ownership.
/unit/pkg/deb/debian.module/
H A Dcopyright.unit-jsc-common321 "Work" shall mean the work of authorship, whether in Source or
323 copyright notice that is included in or attached to the work
326 "Derivative Works" shall mean any work, whether in Source or Object
329 represent, as a whole, an original work of authorship. For the purposes
334 "Contribution" shall mean any work of authorship, including
447 work stoppage, computer failure or malfunction, or any and all
464 APPENDIX: How to apply the Apache License to your work.
466 To apply the Apache License to your work, attach the following
516 1.6. "Larger Work" means a work which combines Covered Software or
853 and You agree to work with Initial Developer and Contributors to
/unit/pkg/rpm/rpmbuild/SOURCES/
H A DCOPYRIGHT.unit-jsc-common321 "Work" shall mean the work of authorship, whether in Source or
323 copyright notice that is included in or attached to the work
326 "Derivative Works" shall mean any work, whether in Source or Object
329 represent, as a whole, an original work of authorship. For the purposes
334 "Contribution" shall mean any work of authorship, including
447 work stoppage, computer failure or malfunction, or any and all
464 APPENDIX: How to apply the Apache License to your work.
466 To apply the Apache License to your work, attach the following
516 1.6. "Larger Work" means a work which combines Covered Software or
853 and You agree to work with Initial Developer and Contributors to

12