Lines Matching defs:job

117 void job_txn_add_job(JobTxn *txn, Job *job)  in job_txn_add_job()
130 static void job_txn_del_job(Job *job) in job_txn_del_job()
139 static int job_txn_apply(Job *job, int fn(Job *)) in job_txn_apply() argument
174 bool job_is_internal(Job *job) in job_is_internal()
179 static void job_state_transition(Job *job, JobStatus s1) in job_state_transition()
194 int job_apply_verb(Job *job, JobVerb verb, Error **errp) in job_apply_verb()
208 JobType job_type(const Job *job) in job_type()
213 const char *job_type_str(const Job *job) in job_type_str()
218 bool job_is_cancelled(Job *job) in job_is_cancelled()
223 bool job_is_ready(Job *job) in job_is_ready()
245 bool job_is_completed(Job *job) in job_is_completed()
267 static bool job_started(Job *job) in job_started()
272 static bool job_should_pause(Job *job) in job_should_pause()
277 Job *job_next(Job *job) in job_next()
287 Job *job; in job_get() local
300 Job *job = opaque; in job_sleep_timer_cb() local
309 Job *job; in job_create() local
367 void job_ref(Job *job) in job_ref()
372 void job_unref(Job *job) in job_unref()
391 void job_progress_update(Job *job, uint64_t done) in job_progress_update()
396 void job_progress_set_remaining(Job *job, uint64_t remaining) in job_progress_set_remaining()
401 void job_progress_increase_remaining(Job *job, uint64_t delta) in job_progress_increase_remaining()
406 void job_event_cancelled(Job *job) in job_event_cancelled()
411 void job_event_completed(Job *job) in job_event_completed()
416 static void job_event_pending(Job *job) in job_event_pending()
421 static void job_event_ready(Job *job) in job_event_ready()
426 static void job_event_idle(Job *job) in job_event_idle()
431 void job_enter_cond(Job *job, bool(*fn)(Job *job)) in job_enter_cond()
458 void job_enter(Job *job) in job_enter()
469 static void coroutine_fn job_do_yield(Job *job, uint64_t ns) in job_do_yield()
484 void coroutine_fn job_pause_point(Job *job) in job_pause_point()
515 void job_yield(Job *job) in job_yield()
531 void coroutine_fn job_sleep_ns(Job *job, int64_t ns) in job_sleep_ns()
548 static bool job_timer_not_pending(Job *job) in job_timer_not_pending()
553 void job_pause(Job *job) in job_pause()
558 void job_resume(Job *job) in job_resume()
570 void job_user_pause(Job *job, Error **errp) in job_user_pause()
583 bool job_user_paused(Job *job) in job_user_paused()
588 void job_user_resume(Job *job, Error **errp) in job_user_resume()
605 static void job_do_dismiss(Job *job) in job_do_dismiss()
620 Job *job = *jobptr; in job_dismiss() local
631 void job_early_fail(Job *job) in job_early_fail()
637 static void job_conclude(Job *job) in job_conclude()
645 static void job_update_rc(Job *job) in job_update_rc()
658 static void job_commit(Job *job) in job_commit()
666 static void job_abort(Job *job) in job_abort()
674 static void job_clean(Job *job) in job_clean()
681 static int job_finalize_single(Job *job) in job_finalize_single()
713 static void job_cancel_async(Job *job, bool force) in job_cancel_async()
729 static void job_completed_txn_abort(Job *job) in job_completed_txn_abort()
778 static int job_prepare(Job *job) in job_prepare()
787 static int job_needs_finalize(Job *job) in job_needs_finalize()
792 static void job_do_finalize(Job *job) in job_do_finalize()
806 void job_finalize(Job *job, Error **errp) in job_finalize()
815 static int job_transition_to_pending(Job *job) in job_transition_to_pending()
824 void job_transition_to_ready(Job *job) in job_transition_to_ready()
830 static void job_completed_txn_success(Job *job) in job_completed_txn_success()
856 static void job_completed(Job *job) in job_completed()
872 Job *job = (Job *)opaque; in job_exit() local
904 Job *job = opaque; in job_co_entry() local
914 void job_start(Job *job) in job_start()
926 void job_cancel(Job *job, bool force) in job_cancel()
942 void job_user_cancel(Job *job, bool force, Error **errp) in job_user_cancel()
953 static void job_cancel_err(Job *job, Error **errp) in job_cancel_err()
958 int job_cancel_sync(Job *job) in job_cancel_sync()
965 Job *job; in job_cancel_sync_all() local
976 int job_complete_sync(Job *job, Error **errp) in job_complete_sync()
981 void job_complete(Job *job, Error **errp) in job_complete()
997 int job_finish_sync(Job *job, void (*finish)(Job *, Error **errp), Error **errp) in job_finish_sync() argument