Commit1bd538f

committed

Add older names support for pids

1 parent3a24554 commit1bd538fCopy full SHA for 1bd538f

File tree

+25

-1

lines changed

+25

-1

lines changed

Lines changed: 25 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -458,6 +458,21 @@ def get_child_processes(self):`
`458`	`458`	`defget_auxiliary_pids(self):`
`459`	`459`	`''' Returns dict with pids of auxiliary processes '''`
`460`	`460`
	`461`	`+alternative_names= {`
	`462`	`+ProcessType.LogicalReplicationLauncher: [`
	`463`	`+'postgres: bgworker: logical replication launcher'`
	`464`	`+ ],`
	`465`	`+ProcessType.BackgroundWriter: [`
	`466`	`+'postgres: writer',`
	`467`	`+ ],`
	`468`	`+ProcessType.WalWriter: [`
	`469`	`+'postgres: wal writer',`
	`470`	`+ ],`
	`471`	`+ProcessType.WalReceiver: [`
	`472`	`+'postgres: wal receiver',`
	`473`	`+ ],`
	`474`	`+ }`
	`475`	`+`
`461`	`476`	`children=self.get_child_processes()`
`462`	`477`	`ifchildrenisNone:`
`463`	`478`	`returnNone`
`@@ -467,11 +482,20 @@ def get_auxiliary_pids(self):`
`467`	`482`	`line=child.cmdline()[0]`
`468`	`483`	`forptypeinProcessType:`
`469`	`484`	`ifptype==ProcessType.WalSender \`
`470`		`-andline.startswith(ptype.value):`
	`485`	`+and (line.startswith(ptype.value)or`
	`486`	`+line.startswith('postgres: wal sender')):`
`471`	`487`	`result.setdefault(ptype, [])`
`472`	`488`	`result[ptype].append(child.pid)`
	`489`	`+break`
`473`	`490`	`elifline.startswith(ptype.value):`
`474`	`491`	`result[ptype]=child.pid`
	`492`	`+break`
	`493`	`+elifptypeinalternative_names:`
	`494`	`+names=alternative_names[ptype]`
	`495`	`+fornameinnames:`
	`496`	`+ifline.startswith(name):`
	`497`	`+result[ptype]=child.pid`
	`498`	`+break`
`475`	`499`
`476`	`500`	`returnresult`
`477`	`501`

Comments

(0)