Home
last modified time | relevance | path

Searched refs:delegated_jobs (Results 1 – 17 of 17) sorted by relevance

/dports/databases/percona57-server/percona-server-5.7.36-39/sql/
H A Drpl_mts_submode.cc319 delegated_jobs = 0; in Mts_submode_logical_clock()
685 delegated_jobs++; in schedule_next_event()
691 assert(delegated_jobs >= jobs_done); in schedule_next_event()
692 assert(is_error || (rli->gaq->len + jobs_done == 1 + delegated_jobs)); in schedule_next_event()
713 delegated_jobs= 1; in schedule_next_event()
728 assert(is_error || (rli->gaq->len + jobs_done == delegated_jobs)); in schedule_next_event()
976 DBUG_PRINT("info",("delegated %d, jobs_done %d", delegated_jobs, in wait_for_workers_to_finish()
982 while (delegated_jobs > jobs_done && !thd->killed && !is_error) in wait_for_workers_to_finish()
1012 " jobs", delegated_jobs, jobs_done)); in wait_for_workers_to_finish()
H A Drpl_mts_submode.h118 uint delegated_jobs; variable
170 delegated_jobs--; in withdraw_delegated_job()
/dports/databases/percona57-client/percona-server-5.7.36-39/sql/
H A Drpl_mts_submode.cc319 delegated_jobs = 0; in Mts_submode_logical_clock()
685 delegated_jobs++; in schedule_next_event()
691 assert(delegated_jobs >= jobs_done); in schedule_next_event()
692 assert(is_error || (rli->gaq->len + jobs_done == 1 + delegated_jobs)); in schedule_next_event()
713 delegated_jobs= 1; in schedule_next_event()
728 assert(is_error || (rli->gaq->len + jobs_done == delegated_jobs)); in schedule_next_event()
976 DBUG_PRINT("info",("delegated %d, jobs_done %d", delegated_jobs, in wait_for_workers_to_finish()
982 while (delegated_jobs > jobs_done && !thd->killed && !is_error) in wait_for_workers_to_finish()
1012 " jobs", delegated_jobs, jobs_done)); in wait_for_workers_to_finish()
H A Drpl_mts_submode.h118 uint delegated_jobs; variable
170 delegated_jobs--; in withdraw_delegated_job()
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/sql/
H A Drpl_mts_submode.cc319 delegated_jobs = 0; in Mts_submode_logical_clock()
685 delegated_jobs++; in schedule_next_event()
691 assert(delegated_jobs >= jobs_done); in schedule_next_event()
692 assert(is_error || (rli->gaq->len + jobs_done == 1 + delegated_jobs)); in schedule_next_event()
713 delegated_jobs= 1; in schedule_next_event()
728 assert(is_error || (rli->gaq->len + jobs_done == delegated_jobs)); in schedule_next_event()
976 DBUG_PRINT("info",("delegated %d, jobs_done %d", delegated_jobs, in wait_for_workers_to_finish()
982 while (delegated_jobs > jobs_done && !thd->killed && !is_error) in wait_for_workers_to_finish()
1012 " jobs", delegated_jobs, jobs_done)); in wait_for_workers_to_finish()
H A Drpl_mts_submode.h156 uint delegated_jobs; variable
208 delegated_jobs--; in withdraw_delegated_job()
/dports/databases/mysql57-client/mysql-5.7.36/sql/
H A Drpl_mts_submode.cc319 delegated_jobs = 0; in Mts_submode_logical_clock()
685 delegated_jobs++; in schedule_next_event()
691 assert(delegated_jobs >= jobs_done); in schedule_next_event()
692 assert(is_error || (rli->gaq->len + jobs_done == 1 + delegated_jobs)); in schedule_next_event()
713 delegated_jobs= 1; in schedule_next_event()
728 assert(is_error || (rli->gaq->len + jobs_done == delegated_jobs)); in schedule_next_event()
976 DBUG_PRINT("info",("delegated %d, jobs_done %d", delegated_jobs, in wait_for_workers_to_finish()
982 while (delegated_jobs > jobs_done && !thd->killed && !is_error) in wait_for_workers_to_finish()
1012 " jobs", delegated_jobs, jobs_done)); in wait_for_workers_to_finish()
H A Drpl_mts_submode.h118 uint delegated_jobs; variable
170 delegated_jobs--; in withdraw_delegated_job()
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/sql/
H A Drpl_mts_submode.cc319 delegated_jobs = 0; in Mts_submode_logical_clock()
685 delegated_jobs++; in schedule_next_event()
691 assert(delegated_jobs >= jobs_done); in schedule_next_event()
692 assert(is_error || (rli->gaq->len + jobs_done == 1 + delegated_jobs)); in schedule_next_event()
713 delegated_jobs= 1; in schedule_next_event()
728 assert(is_error || (rli->gaq->len + jobs_done == delegated_jobs)); in schedule_next_event()
976 DBUG_PRINT("info",("delegated %d, jobs_done %d", delegated_jobs, in wait_for_workers_to_finish()
982 while (delegated_jobs > jobs_done && !thd->killed && !is_error) in wait_for_workers_to_finish()
1012 " jobs", delegated_jobs, jobs_done)); in wait_for_workers_to_finish()
H A Drpl_mts_submode.h118 uint delegated_jobs; variable
170 delegated_jobs--; in withdraw_delegated_job()
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/sql/
H A Drpl_mts_submode.cc319 delegated_jobs = 0; in Mts_submode_logical_clock()
685 delegated_jobs++; in schedule_next_event()
691 DBUG_ASSERT(delegated_jobs >= jobs_done); in schedule_next_event()
692 DBUG_ASSERT(is_error || (rli->gaq->len + jobs_done == 1 + delegated_jobs)); in schedule_next_event()
713 delegated_jobs= 1; in schedule_next_event()
728 DBUG_ASSERT(is_error || (rli->gaq->len + jobs_done == delegated_jobs)); in schedule_next_event()
976 DBUG_PRINT("info",("delegated %d, jobs_done %d", delegated_jobs, in wait_for_workers_to_finish()
982 while (delegated_jobs > jobs_done && !thd->killed && !is_error) in wait_for_workers_to_finish()
1012 " jobs", delegated_jobs, jobs_done)); in wait_for_workers_to_finish()
H A Drpl_mts_submode.h118 uint delegated_jobs; variable
170 delegated_jobs--; in withdraw_delegated_job()
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/sql/
H A Drpl_mts_submode.cc428 delegated_jobs = 0; in Mts_submode_logical_clock()
765 delegated_jobs++; in schedule_next_event()
769 DBUG_ASSERT(delegated_jobs >= jobs_done); in schedule_next_event()
770 DBUG_ASSERT(is_error || (rli->gaq->len + jobs_done == 1 + delegated_jobs)); in schedule_next_event()
790 delegated_jobs = 1; in schedule_next_event()
805 DBUG_ASSERT(is_error || (rli->gaq->len + jobs_done == delegated_jobs)); in schedule_next_event()
1024 DBUG_PRINT("info", ("delegated %d, jobs_done %d", delegated_jobs, jobs_done)); in wait_for_workers_to_finish()
1028 while (delegated_jobs > jobs_done && !thd->killed && !is_error) { in wait_for_workers_to_finish()
1052 delegated_jobs, jobs_done)); in wait_for_workers_to_finish()
H A Drpl_mts_submode.h132 uint delegated_jobs; variable
182 void withdraw_delegated_job() { delegated_jobs--; } in withdraw_delegated_job()
/dports/print/a2ps/a2ps-4.13/src/
H A Dmain.c1157 int delegated_jobs = 0, native_jobs = 0; in main() local
1162 print (UNULL, &native_jobs, &delegated_jobs); in main()
1165 print ((uchar *) argv[argn], &native_jobs, &delegated_jobs); in main()
1170 if ((native_jobs == 0) && (delegated_jobs == 1)) in main()
1186 else if (native_jobs || delegated_jobs) in main()
H A Dgenerate.h29 void print PARAMS ((uchar * name, int * native_jobs, int * delegated_jobs));
H A Dgenerate.c275 print (uchar * filename, int * native_jobs, int * delegated_jobs) in print() argument
318 (*delegated_jobs)++; in print()