Lines Matching refs:job

1161     nxt_joint_job_t  *job;  in nxt_router_conf_wait()  local
1163 job = obj; in nxt_router_conf_wait()
1165 nxt_router_conf_ready(task, job->tmcf); in nxt_router_conf_wait()
3082 nxt_joint_job_t *job; in nxt_router_engine_joints_create() local
3091 job = nxt_mp_get(tmcf->mem_pool, sizeof(nxt_joint_job_t)); in nxt_router_engine_joints_create()
3092 if (nxt_slow_path(job == NULL)) { in nxt_router_engine_joints_create()
3096 job->work.next = recf->jobs; in nxt_router_engine_joints_create()
3097 recf->jobs = &job->work; in nxt_router_engine_joints_create()
3099 job->task = tmcf->engine->task; in nxt_router_engine_joints_create()
3100 job->work.handler = handler; in nxt_router_engine_joints_create()
3101 job->work.task = &job->task; in nxt_router_engine_joints_create()
3102 job->work.obj = job; in nxt_router_engine_joints_create()
3103 job->tmcf = tmcf; in nxt_router_engine_joints_create()
3113 job->work.data = joint; in nxt_router_engine_joints_create()
3137 nxt_joint_job_t *job; in nxt_router_engine_quit() local
3139 job = nxt_mp_get(tmcf->mem_pool, sizeof(nxt_joint_job_t)); in nxt_router_engine_quit()
3140 if (nxt_slow_path(job == NULL)) { in nxt_router_engine_quit()
3144 job->work.next = recf->jobs; in nxt_router_engine_quit()
3145 recf->jobs = &job->work; in nxt_router_engine_quit()
3147 job->task = tmcf->engine->task; in nxt_router_engine_quit()
3148 job->work.handler = nxt_router_worker_thread_quit; in nxt_router_engine_quit()
3149 job->work.task = &job->task; in nxt_router_engine_quit()
3150 job->work.obj = NULL; in nxt_router_engine_quit()
3151 job->work.data = NULL; in nxt_router_engine_quit()
3152 job->tmcf = NULL; in nxt_router_engine_quit()
3162 nxt_joint_job_t *job; in nxt_router_engine_joints_delete() local
3169 job = nxt_mp_get(tmcf->mem_pool, sizeof(nxt_joint_job_t)); in nxt_router_engine_joints_delete()
3170 if (nxt_slow_path(job == NULL)) { in nxt_router_engine_joints_delete()
3174 job->work.next = recf->jobs; in nxt_router_engine_joints_delete()
3175 recf->jobs = &job->work; in nxt_router_engine_joints_delete()
3177 job->task = tmcf->engine->task; in nxt_router_engine_joints_delete()
3178 job->work.handler = nxt_router_listen_socket_delete; in nxt_router_engine_joints_delete()
3179 job->work.task = &job->task; in nxt_router_engine_joints_delete()
3180 job->work.obj = job; in nxt_router_engine_joints_delete()
3181 job->work.data = nxt_queue_link_data(qlk, nxt_socket_conf_t, link); in nxt_router_engine_joints_delete()
3182 job->tmcf = tmcf; in nxt_router_engine_joints_delete()
3414 nxt_joint_job_t *job; in nxt_router_listen_socket_create() local
3421 job = obj; in nxt_router_listen_socket_create()
3443 job->work.next = NULL; in nxt_router_listen_socket_create()
3444 job->work.handler = nxt_router_conf_wait; in nxt_router_listen_socket_create()
3446 nxt_event_engine_post(job->tmcf->engine, &job->work); in nxt_router_listen_socket_create()
3478 nxt_joint_job_t *job; in nxt_router_listen_socket_update() local
3483 job = obj; in nxt_router_listen_socket_update()
3497 job->work.next = NULL; in nxt_router_listen_socket_update()
3498 job->work.handler = nxt_router_conf_wait; in nxt_router_listen_socket_update()
3500 nxt_event_engine_post(job->tmcf->engine, &job->work); in nxt_router_listen_socket_update()
3561 nxt_joint_job_t *job; in nxt_router_listen_socket_close() local
3581 job = joint->close_job; in nxt_router_listen_socket_close()
3582 job->work.next = NULL; in nxt_router_listen_socket_close()
3583 job->work.handler = nxt_router_conf_wait; in nxt_router_listen_socket_close()
3585 nxt_event_engine_post(job->tmcf->engine, &job->work); in nxt_router_listen_socket_close()