Lines Matching refs:job
1297 nxt_joint_job_t *job; in nxt_router_conf_wait() local
1299 job = obj; in nxt_router_conf_wait()
1301 nxt_router_conf_ready(task, job->tmcf); in nxt_router_conf_wait()
3339 nxt_joint_job_t *job; in nxt_router_engine_joints_create() local
3348 job = nxt_mp_get(tmcf->mem_pool, sizeof(nxt_joint_job_t)); in nxt_router_engine_joints_create()
3349 if (nxt_slow_path(job == NULL)) { in nxt_router_engine_joints_create()
3353 job->work.next = recf->jobs; in nxt_router_engine_joints_create()
3354 recf->jobs = &job->work; in nxt_router_engine_joints_create()
3356 job->task = tmcf->engine->task; in nxt_router_engine_joints_create()
3357 job->work.handler = handler; in nxt_router_engine_joints_create()
3358 job->work.task = &job->task; in nxt_router_engine_joints_create()
3359 job->work.obj = job; in nxt_router_engine_joints_create()
3360 job->tmcf = tmcf; in nxt_router_engine_joints_create()
3370 job->work.data = joint; in nxt_router_engine_joints_create()
3394 nxt_joint_job_t *job; in nxt_router_engine_quit() local
3396 job = nxt_mp_get(tmcf->mem_pool, sizeof(nxt_joint_job_t)); in nxt_router_engine_quit()
3397 if (nxt_slow_path(job == NULL)) { in nxt_router_engine_quit()
3401 job->work.next = recf->jobs; in nxt_router_engine_quit()
3402 recf->jobs = &job->work; in nxt_router_engine_quit()
3404 job->task = tmcf->engine->task; in nxt_router_engine_quit()
3405 job->work.handler = nxt_router_worker_thread_quit; in nxt_router_engine_quit()
3406 job->work.task = &job->task; in nxt_router_engine_quit()
3407 job->work.obj = NULL; in nxt_router_engine_quit()
3408 job->work.data = NULL; in nxt_router_engine_quit()
3409 job->tmcf = NULL; in nxt_router_engine_quit()
3419 nxt_joint_job_t *job; in nxt_router_engine_joints_delete() local
3426 job = nxt_mp_get(tmcf->mem_pool, sizeof(nxt_joint_job_t)); in nxt_router_engine_joints_delete()
3427 if (nxt_slow_path(job == NULL)) { in nxt_router_engine_joints_delete()
3431 job->work.next = recf->jobs; in nxt_router_engine_joints_delete()
3432 recf->jobs = &job->work; in nxt_router_engine_joints_delete()
3434 job->task = tmcf->engine->task; in nxt_router_engine_joints_delete()
3435 job->work.handler = nxt_router_listen_socket_delete; in nxt_router_engine_joints_delete()
3436 job->work.task = &job->task; in nxt_router_engine_joints_delete()
3437 job->work.obj = job; in nxt_router_engine_joints_delete()
3438 job->work.data = nxt_queue_link_data(qlk, nxt_socket_conf_t, link); in nxt_router_engine_joints_delete()
3439 job->tmcf = tmcf; in nxt_router_engine_joints_delete()
3671 nxt_joint_job_t *job; in nxt_router_listen_socket_create() local
3678 job = obj; in nxt_router_listen_socket_create()
3700 job->work.next = NULL; in nxt_router_listen_socket_create()
3701 job->work.handler = nxt_router_conf_wait; in nxt_router_listen_socket_create()
3703 nxt_event_engine_post(job->tmcf->engine, &job->work); in nxt_router_listen_socket_create()
3735 nxt_joint_job_t *job; in nxt_router_listen_socket_update() local
3740 job = obj; in nxt_router_listen_socket_update()
3754 job->work.next = NULL; in nxt_router_listen_socket_update()
3755 job->work.handler = nxt_router_conf_wait; in nxt_router_listen_socket_update()
3757 nxt_event_engine_post(job->tmcf->engine, &job->work); in nxt_router_listen_socket_update()
3818 nxt_joint_job_t *job; in nxt_router_listen_socket_close() local
3838 job = joint->close_job; in nxt_router_listen_socket_close()
3839 job->work.next = NULL; in nxt_router_listen_socket_close()
3840 job->work.handler = nxt_router_conf_wait; in nxt_router_listen_socket_close()
3842 nxt_event_engine_post(job->tmcf->engine, &job->work); in nxt_router_listen_socket_close()