Lines Matching defs:job

153 static void job_txn_add_job_locked(JobTxn *txn, Job *job)  in job_txn_add_job_locked()
167 static void job_txn_del_job_locked(Job *job) in job_txn_del_job_locked()
177 static int job_txn_apply_locked(Job *job, int fn(Job *)) in job_txn_apply_locked() argument
202 bool job_is_internal(Job *job) in job_is_internal()
208 static void job_state_transition_locked(Job *job, JobStatus s1) in job_state_transition_locked()
223 int job_apply_verb_locked(Job *job, JobVerb verb, Error **errp) in job_apply_verb_locked()
237 JobType job_type(const Job *job) in job_type()
242 const char *job_type_str(const Job *job) in job_type_str()
247 bool job_is_cancelled_locked(Job *job) in job_is_cancelled_locked()
254 bool job_is_paused(Job *job) in job_is_paused()
260 bool job_is_cancelled(Job *job) in job_is_cancelled()
267 static bool job_cancel_requested_locked(Job *job) in job_cancel_requested_locked()
272 bool job_cancel_requested(Job *job) in job_cancel_requested()
278 bool job_is_ready_locked(Job *job) in job_is_ready_locked()
300 bool job_is_ready(Job *job) in job_is_ready()
306 bool job_is_completed_locked(Job *job) in job_is_completed_locked()
328 static bool job_is_completed(Job *job) in job_is_completed()
334 static bool job_started_locked(Job *job) in job_started_locked()
340 static bool job_should_pause_locked(Job *job) in job_should_pause_locked()
345 Job *job_next_locked(Job *job) in job_next_locked()
353 Job *job_next(Job *job) in job_next()
361 Job *job; in job_get_locked() local
372 void job_set_aio_context(Job *job, AioContext *ctx) in job_set_aio_context()
386 Job *job = opaque; in job_sleep_timer_cb() local
395 Job *job; in job_create() local
458 void job_ref_locked(Job *job) in job_ref_locked()
463 void job_unref_locked(Job *job) in job_unref_locked()
487 void job_progress_update(Job *job, uint64_t done) in job_progress_update()
492 void job_progress_set_remaining(Job *job, uint64_t remaining) in job_progress_set_remaining()
497 void job_progress_increase_remaining(Job *job, uint64_t delta) in job_progress_increase_remaining()
506 static void job_event_cancelled_locked(Job *job) in job_event_cancelled_locked()
515 static void job_event_completed_locked(Job *job) in job_event_completed_locked()
521 static void job_event_pending_locked(Job *job) in job_event_pending_locked()
527 static void job_event_ready_locked(Job *job) in job_event_ready_locked()
533 static void job_event_idle_locked(Job *job) in job_event_idle_locked()
538 void job_enter_cond_locked(Job *job, bool(*fn)(Job *job)) in job_enter_cond_locked()
563 void job_enter(Job *job) in job_enter()
578 static void coroutine_fn job_do_yield_locked(Job *job, uint64_t ns) in job_do_yield_locked()
609 static void coroutine_fn job_pause_point_locked(Job *job) in job_pause_point_locked()
644 void coroutine_fn job_pause_point(Job *job) in job_pause_point()
650 void coroutine_fn job_yield(Job *job) in job_yield()
667 void coroutine_fn job_sleep_ns(Job *job, int64_t ns) in job_sleep_ns()
685 static bool job_timer_not_pending_locked(Job *job) in job_timer_not_pending_locked()
690 void job_pause_locked(Job *job) in job_pause_locked()
698 void job_pause(Job *job) in job_pause()
704 void job_resume_locked(Job *job) in job_resume_locked()
716 void job_resume(Job *job) in job_resume()
722 void job_user_pause_locked(Job *job, Error **errp) in job_user_pause_locked()
735 bool job_user_paused_locked(Job *job) in job_user_paused_locked()
740 void job_user_resume_locked(Job *job, Error **errp) in job_user_resume_locked()
761 static void job_do_dismiss_locked(Job *job) in job_do_dismiss_locked()
776 Job *job = *jobptr; in job_dismiss_locked() local
787 void job_early_fail(Job *job) in job_early_fail()
795 static void job_conclude_locked(Job *job) in job_conclude_locked()
804 static void job_update_rc_locked(Job *job) in job_update_rc_locked()
817 static void job_commit(Job *job) in job_commit()
826 static void job_abort(Job *job) in job_abort()
835 static void job_clean(Job *job) in job_clean()
846 static int job_finalize_single_locked(Job *job) in job_finalize_single_locked()
888 static void job_cancel_async_locked(Job *job, bool force) in job_cancel_async_locked()
929 static void job_completed_txn_abort_locked(Job *job) in job_completed_txn_abort_locked()
972 static int job_prepare_locked(Job *job) in job_prepare_locked()
990 static int job_needs_finalize_locked(Job *job) in job_needs_finalize_locked()
996 static void job_do_finalize_locked(Job *job) in job_do_finalize_locked()
1010 void job_finalize_locked(Job *job, Error **errp) in job_finalize_locked()
1020 static int job_transition_to_pending_locked(Job *job) in job_transition_to_pending_locked()
1029 void job_transition_to_ready(Job *job) in job_transition_to_ready()
1037 static void job_completed_txn_success_locked(Job *job) in job_completed_txn_success_locked()
1064 static void job_completed_locked(Job *job) in job_completed_locked()
1083 Job *job = (Job *)opaque; in job_exit() local
1104 Job *job = opaque; in job_co_entry() local
1121 void job_start(Job *job) in job_start()
1137 void job_cancel_locked(Job *job, bool force) in job_cancel_locked()
1165 void job_user_cancel_locked(Job *job, bool force, Error **errp) in job_user_cancel_locked()
1179 static void job_cancel_err_locked(Job *job, Error **errp) in job_cancel_err_locked()
1188 static void job_force_cancel_err_locked(Job *job, Error **errp) in job_force_cancel_err_locked()
1193 int job_cancel_sync_locked(Job *job, bool force) in job_cancel_sync_locked()
1202 int job_cancel_sync(Job *job, bool force) in job_cancel_sync()
1210 Job *job; in job_cancel_sync_all() local
1218 int job_complete_sync_locked(Job *job, Error **errp) in job_complete_sync_locked()
1223 void job_complete_locked(Job *job, Error **errp) in job_complete_locked()
1242 int job_finish_sync_locked(Job *job, in job_finish_sync_locked()