Commitf3947bf

Andrei Kruchinin

committed

Set worker status to Idle after applying

1 parentc68af32 commitf3947bfCopy full SHA for f3947bf

File tree

-3

lines changed

-3

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -1629,7 +1629,7 @@ MtmDDLResetApplyState()`
`1629`	`1629`	`DDLApplyInProgress= false;`
`1630`	`1630`	`/* the memory it points to is about to go away */`
`1631`	`1631`	`debug_query_string=NULL;`
`1632`		`-pgstat_report_activity(STATE_RUNNING,NULL);`
	`1632`	`+pgstat_report_activity(STATE_IDLE,"");`
`1633`	`1633`	`}`
`1634`	`1634`
`1635`	`1635`

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -385,7 +385,7 @@ process_remote_message(StringInfo s, MtmReceiverWorkerContext *rwctx)`
`385`	`385`	`MtmApplyDDLMessage(messageBody, false);`
`386`	`386`	`CommitTransactionCommand();`
`387`	`387`
`388`		`-pgstat_report_activity(STATE_RUNNING,NULL);`
	`388`	`+pgstat_report_activity(STATE_IDLE,"");`
`389`	`389`	`standalone= true;`
`390`	`390`	`break;`
`391`	`391`	`}`
`@@ -396,7 +396,7 @@ process_remote_message(StringInfo s, MtmReceiverWorkerContext *rwctx)`
`396`	`396`	`pfree(activity);`
`397`	`397`	`mtm_log(MtmApplyMessage,"executing tx DDL message %s",messageBody);`
`398`	`398`	`MtmApplyDDLMessage(messageBody, true);`
`399`		`-pgstat_report_activity(STATE_RUNNING,NULL);`
	`399`	`+pgstat_report_activity(STATE_IDLE,"");`
`400`	`400`	`break;`
`401`	`401`	`}`
`402`	`402`	`case'L':`

Comments

(0)