Commit5e6f910

committed

add pg_ctl method to PostgresNode

1 parent725f342 commit5e6f910Copy full SHA for 5e6f910

File tree

+18

-0

lines changed

+18

-0

lines changed

Lines changed: 11 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -698,6 +698,17 @@ def reload(self, params=[]):`
`698`	`698`
`699`	`699`	`returnself`
`700`	`700`
	`701`	`+defpg_ctl(self,params):`
	`702`	`+"""`
	`703`	`+ Invoke pg_ctl with params.`
	`704`	`+`
	`705`	`+ Returns:`
	`706`	`+ Stdout + stderr of pg_ctl.`
	`707`	`+ """`
	`708`	`+`
	`709`	`+_params=params+ ["-D",self.data_dir,"-w"]`
	`710`	`+return_execute_utility("pg_ctl",_params,self.utils_logname)`
	`711`	`+`
`701`	`712`	`deffree_port(self):`
`702`	`713`	`"""`
`703`	`714`	`Reclaim port owned by this node.`

Lines changed: 7 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -382,6 +382,13 @@ def test_reload(self):`
`382`	`382`
`383`	`383`	`self.assertEqual(pid1,pid2)`
`384`	`384`
	`385`	`+deftest_pg_ctl(self):`
	`386`	`+withget_new_node('node')asnode:`
	`387`	`+node.init().start()`
	`388`	`+`
	`389`	`+status=node.pg_ctl(['status'])`
	`390`	`+self.assertTrue("server is running"instatus)`
	`391`	`+`
`385`	`392`	`deftest_ports_management(self):`
`386`	`393`	`# check that no ports have been bound yet`
`387`	`394`	`self.assertEqual(len(bound_ports),0)`

Comments

(0)