Commit0967057

committed

TestTestgresCommon.test_unix_sockets is added

1 parentc5ad907 commit0967057Copy full SHA for 0967057

File tree

+20

-28

lines changed

+20

-28

lines changed

Lines changed: 20 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -1121,6 +1121,26 @@ def test_pgbench(self, node_svc: PostgresNodeService):`
`1121`	`1121`	`out=proc.communicate()[0]`
`1122`	`1122`	`assert (b'tps = 'inout)`
`1123`	`1123`
	`1124`	`+deftest_unix_sockets(self,node_svc:PostgresNodeService):`
	`1125`	`+assertisinstance(node_svc,PostgresNodeService)`
	`1126`	`+`
	`1127`	`+with__class__.helper__get_node(node_svc)asnode:`
	`1128`	`+node.init(unix_sockets=False,allow_streaming=True)`
	`1129`	`+node.start()`
	`1130`	`+`
	`1131`	`+res_exec=node.execute('select 1')`
	`1132`	`+assert (res_exec== [(1,)])`
	`1133`	`+res_psql=node.safe_psql('select 1')`
	`1134`	`+assert (res_psql==b'1\n')`
	`1135`	`+`
	`1136`	`+withnode.replicate()asr:`
	`1137`	`+asserttype(r)==PostgresNode# noqa: E721`
	`1138`	`+r.start()`
	`1139`	`+res_exec=r.execute('select 1')`
	`1140`	`+assert (res_exec== [(1,)])`
	`1141`	`+res_psql=r.safe_psql('select 1')`
	`1142`	`+assert (res_psql==b'1\n')`
	`1143`	`+`
`1124`	`1144`	`@staticmethod`
`1125`	`1145`	`defhelper__get_node(node_svc:PostgresNodeService,name=None):`
`1126`	`1146`	`assertisinstance(node_svc,PostgresNodeService)`

Lines changed: 0 additions & 12 deletions

Original file line number	Diff line number	Diff line change
`@@ -156,18 +156,6 @@ def test_config_stack(self):`
`156`	`156`
`157`	`157`	`assert (TestgresConfig.cached_initdb_dir==d0)`
`158`	`158`
`159`		`-deftest_unix_sockets(self):`
`160`		`-withget_new_node()asnode:`
`161`		`-node.init(unix_sockets=False,allow_streaming=True)`
`162`		`-node.start()`
`163`		`-`
`164`		`-node.execute('select 1')`
`165`		`-node.safe_psql('select 1')`
`166`		`-`
`167`		`-withnode.replicate().start()asr:`
`168`		`-r.execute('select 1')`
`169`		`-r.safe_psql('select 1')`
`170`		`-`
`171`	`159`	`deftest_ports_management(self):`
`172`	`160`	`assertbound_portsisnotNone`
`173`	`161`	`asserttype(bound_ports)==set# noqa: E721`

Lines changed: 0 additions & 16 deletions

Original file line number	Diff line number	Diff line change
`@@ -224,22 +224,6 @@ def test_config_stack(self):`
`224`	`224`
`225`	`225`	`assert (TestgresConfig.cached_initdb_dir==d0)`
`226`	`226`
`227`		`-deftest_unix_sockets(self):`
`228`		`-with__class__.helper__get_node()asnode:`
`229`		`-node.init(unix_sockets=False,allow_streaming=True)`
`230`		`-node.start()`
`231`		`-`
`232`		`-res_exec=node.execute('select 1')`
`233`		`-res_psql=node.safe_psql('select 1')`
`234`		`-assert (res_exec== [(1,)])`
`235`		`-assert (res_psql==b'1\n')`
`236`		`-`
`237`		`-withnode.replicate().start()asr:`
`238`		`-res_exec=r.execute('select 1')`
`239`		`-res_psql=r.safe_psql('select 1')`
`240`		`-assert (res_exec== [(1,)])`
`241`		`-assert (res_psql==b'1\n')`
`242`		`-`
`243`	`227`	`@staticmethod`
`244`	`228`	`defhelper__get_node(name=None):`
`245`	`229`	`svc=PostgresNodeServices.sm_remote`

Comments

(0)