Commit8e8475a

Vladimir Ershov

committed

add indexes

1 parentec6d647 commit8e8475aCopy full SHA for 8e8475a

File tree

-3

lines changed

-3

lines changed

Lines changed: 2 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -26,6 +26,7 @@ CREATE TABLE at_jobs_submitted(`
`26`	`26`	`submit_timetimestamp with time zone default now()`
`27`	`27`	`);`
`28`	`28`	`CREATEINDEXON at_jobs_submitted(at,submit_time);`
	`29`	`+CREATEINDEXON at_jobs_submitted (last_start_available, node);`
`29`	`30`
`30`	`31`	`CREATETABLEat_jobs_process(`
`31`	`32`	`start_timetimestamp with time zone default now()`
`@@ -66,6 +67,7 @@ CREATE TABLE cron(`
`66`	`67`	`reasontext,`
`67`	`68`	`_next_exec_timetimestamp with time zone`
`68`	`69`	`);`
	`70`	`+createindexon cron (node);`
`69`	`71`
`70`	`72`	`CREATETABLEat(`
`71`	`73`	`start_attimestamp with time zone,`

Lines changed: 5 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -1492,6 +1492,7 @@ void manager_worker_main(Datum arg)`
`1492`	`1492`	`ctx=initialize_scheduler_manager_context(database,seg);`
`1493`	`1493`	`clean_at_table(ctx);`
`1494`	`1494`	`set_slots_stat_report(ctx);`
	`1495`	`+SetConfigOption("enable_seqscan","off",PGC_USERSET,PGC_S_SESSION);`
`1495`	`1496`
`1496`	`1497`	`while(!got_sigterm)`
`1497`	`1498`	`{`
`@@ -1509,7 +1510,7 @@ void manager_worker_main(Datum arg)`
`1509`	`1510`	`if(!got_sighup&& !got_sigterm)`
`1510`	`1511`	`{`
`1511`	`1512`	`terminate_main_loop=0;`
`1512`		`-while(1)`
	`1513`	`+while(!got_sighup&& !got_sigterm)`
`1513`	`1514`	`{`
`1514`	`1515`	`wait=0;`
`1515`	`1516`	`if(check_parent_stop_signal(ctx))`
`@@ -1521,11 +1522,12 @@ void manager_worker_main(Datum arg)`
`1521`	`1522`	`wait+=scheduler_start_jobs(ctx,CronJob);`
`1522`	`1523`	`scheduler_check_slots(ctx,&(ctx->at));`
`1523`	`1524`	`scheduler_check_slots(ctx,&(ctx->cron));`
`1524`		`-set_slots_stat_report(ctx);`
	`1525`	`+scheduler_make_atcron_record(ctx);`
	`1526`	`+/* set_slots_stat_report(ctx); */`
`1525`	`1527`	`if(wait==0)break;`
`1526`	`1528`	`}`
`1527`	`1529`	`if(terminate_main_loop)break;`
`1528`		`-scheduler_make_atcron_record(ctx);`
	`1530`	`+set_slots_stat_report(ctx);`
`1529`	`1531`	`/* if there are any expired jobs to get rid of */`
`1530`	`1532`	`scheduler_vanish_expired_jobs(ctx,AtJob);`
`1531`	`1533`	`scheduler_vanish_expired_jobs(ctx,CronJob);`

Comments

(0)