Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commit8a5e75f

Browse files
author
Sofia Kopikova
committed
Fix error 'Is another postmaster already running on port XXX'
Sometimes when we abnormally shutdown node its port stays busy. So Iadded retry attempts to start() function in case we encounter sucherror. Test for this case was added (test_the_same_port).
1 parent4c70b80 commit8a5e75f

File tree

2 files changed

+30
-8
lines changed

2 files changed

+30
-8
lines changed

‎testgres/node.py‎

Lines changed: 22 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -726,14 +726,28 @@ def start(self, params=[], wait=True):
726726
"start"
727727
]+params# yapf: disable
728728

729-
try:
730-
exit_status,out,error=execute_utility(_params,self.utils_log_file,verbose=True)
731-
iferrorand'does not exist'inerror:
732-
raiseException
733-
exceptExceptionase:
734-
msg='Cannot start node'
735-
files=self._collect_special_files()
736-
raise_from(StartNodeException(msg,files),e)
729+
startup_retries=5
730+
whileTrue:
731+
try:
732+
exit_status,out,error=execute_utility(_params,self.utils_log_file,verbose=True)
733+
iferrorand'does not exist'inerror:
734+
raiseException
735+
exceptExceptionase:
736+
files=self._collect_special_files()
737+
ifany(en(file)>1and'Is another postmaster already running on port'infileforfileinfiles):
738+
print("Detected an issue with connecting to port {0}. "
739+
"Trying another port after a 5-second sleep...".format(self.port))
740+
self.port=reserve_port()
741+
options= {}
742+
options['port']=str(self.port)
743+
self.set_auto_conf(options)
744+
startup_retries-=1
745+
time.sleep(5)
746+
continue
747+
748+
msg='Cannot start node'
749+
raise_from(StartNodeException(msg,files),e)
750+
break
737751
self._maybe_start_logger()
738752
self.is_started=True
739753
returnself

‎tests/test_simple.py‎

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1033,6 +1033,14 @@ def test_parse_pg_version(self):
10331033
# Macos
10341034
assertparse_pg_version("postgres (PostgreSQL) 14.9 (Homebrew)")=="14.9"
10351035

1036+
deftest_the_same_port(self):
1037+
withget_new_node()asnode:
1038+
node.init().start()
1039+
1040+
withget_new_node()asnode2:
1041+
node2.port=node.port
1042+
node2.init().start()
1043+
10361044

10371045
if__name__=='__main__':
10381046
ifos.environ.get('ALT_CONFIG'):

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp