/unit/src/ |
H A D | nxt_work_queue.c | 135 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 D | nxt_work_queue.h | 51 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 D | nxt_thread_pool.c | 42 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 D | nxt_buf.c | 15 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 D | nxt_thread.c | 117 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 D | nxt_thread_pool.h | 23 nxt_work_t work; member 41 nxt_work_t *work);
|
H A D | nxt_mp.c | 321 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 D | nxt_job.c | 116 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 D | nxt_port.c | 548 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 D | nxt_job.h | 50 nxt_work_t work; member
|
H A D | nxt_router.c | 3194 job->work.obj = NULL; in nxt_router_engine_quit() 3195 job->work.data = NULL; in nxt_router_engine_quit() 3344 for (work = jobs; work != NULL; work = next) { in nxt_router_engine_post() 3345 next = work->next; in nxt_router_engine_post() 3346 work->next = NULL; in nxt_router_engine_post() 3425 work->task = link->work.task; in nxt_router_thread_start() 3426 work->obj = work; in nxt_router_thread_start() 3427 work->data = port; in nxt_router_thread_start() 3429 nxt_event_engine_post(link->work.task->thread->engine, work); in nxt_router_thread_start() 3487 job->work.next = NULL; in nxt_router_listen_socket_create() [all …]
|
H A D | nxt_event_conn_job_sendfile.c | 155 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 D | nxt_thread.h | 85 nxt_work_t work; member
|
H A D | nxt_signal.c | 140 link->work.data = engine; in nxt_signal_thread_start()
|
H A D | nxt_router.h | 92 nxt_work_t work; member
|
H A D | nxt_event_engine.c | 250 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 D | nxt_thread_time.c | 92 link->work.data = (void *) (uintptr_t) interval; in nxt_time_thread_start()
|
H A D | nxt_event_engine.h | 501 nxt_work_t *work);
|
/unit/ |
H A D | LICENSE | 36 "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 D | CHANGES | 20 *) Bugfix: Ruby Sinatra applications don't work without custom logging. 34 *) Bugfix: ECMAScript modules did not work with the recent Node.js 414 *) Bugfix: negative address matching in router might work improperly in 466 *) Bugfix: threads in Python applications might not work correctly. 468 *) Bugfix: Ruby on Rails applications might not work on Ruby 2.6. 554 did not work. 612 Control API did not work. 658 *) Bugfix: module discovery did not work on 64-bit big-endian systems 682 *) Bugfix: Go applications did not work when Unit was built with musl C 708 *) Bugfix: "header_read_timeout" might not work properly. [all …]
|
H A D | CONTRIBUTING.md | 86 …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 D | LocalStrings.properties | 3 # this work for additional information regarding copyright ownership.
|
/unit/src/java/nginx/unit/websocket/pojo/ |
H A D | LocalStrings.properties | 3 # this work for additional information regarding copyright ownership.
|
/unit/pkg/deb/debian.module/ |
H A D | copyright.unit-jsc-common | 321 "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 D | COPYRIGHT.unit-jsc-common | 321 "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
|