Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

fix load error of susChkSrv.py #234

Merged
merged 1 commit into from
Feb 2, 2024
Merged

fix load error of susChkSrv.py #234

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
50 changes: 25 additions & 25 deletions srHook/susChkSrv.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -84,7 +84,7 @@ def __init__(self, *args, **kwargs):
super().__init__(*args, **kwargs)
method = "init"
episode = getEpisode()
logTimestamp(method, episode, "init called")
self.logTimestamp(method, episode, "init called")

# read settings from global.ini
# read sustkover_timeout
Expand All @@ -98,12 +98,12 @@ def __init__(self, *args, **kwargs):
"firstStopThenKill"])
if not isValidAction:
msg = f"Invalid action_on_lost {self.action_on_lost}. Fallback to 'ignore'"
logTimestamp(method, episode, msg)
self.logTimestamp(method, episode, msg)
self.tracer.info(msg)
self.action_on_lost = "ignore_fallback"
else:
msg = "action_on_lost not configured. Fallback to 'ignore'"
logTimestamp(method, episode, msg)
self.logTimestamp(method, episode, msg)
self.tracer.info(msg)
self.action_on_lost = "ignore_default"
if self.config.hasKey("kill_signal"):
Expand All @@ -114,7 +114,7 @@ def __init__(self, *args, **kwargs):
msg = (f"{self.__class__.__name__}.{method}() version {SRHookVersion}, parameter"
f" info: action_on_lost={self.action_on_lost} stop_timeout={self.stop_timeout}"
f" kill_signal={self.killSignal}")
logTimestamp(method, episode, msg)
self.logTimestamp(method, episode, msg)
self.tracer.info(msg)
# TODO: use action specific init messages (e.g. for stop also report stop_timeout)
self.takeover_active = False
Expand Down Expand Up @@ -156,9 +156,9 @@ def srServiceStateChanged(self, ParamDict, **kwargs):
msg1 = f"{SRHookName} version {SRHookVersion}. Method {method} method called."
msg2 = f"{SRHookName} {method} method called with Dict={ParamDict}"
msg3 = f"{SRHookName} {method} method called with SAPSYSTEMNAME={mySID}"
logTimestamp(method, episode, msg1)
logTimestamp(method, episode, msg2)
logTimestamp(method, episode, msg3)
self.logTimestamp(method, episode, msg1)
self.logTimestamp(method, episode, msg2)
self.logTimestamp(method, episode, msg3)
self.tracer.info(msg1)
self.tracer.info(msg2)
self.tracer.info(msg3)
Expand All @@ -175,7 +175,7 @@ def srServiceStateChanged(self, ParamDict, **kwargs):
databaseStatus = ParamDict['database_status']
msg = (f"srv:{service}-{port}-{status}-{previousStatus}"
f" db:{databaseName}-{databaseId}-{databaseStatus} daem:{daemonStatus}")
logTimestamp(method, episode, msg)
self.logTimestamp(method, episode, msg)
self.tracer.info(msg)

# analysis, if the event looks like an dying indexserver (LOST)
Expand All @@ -200,54 +200,54 @@ def srServiceStateChanged(self, ParamDict, **kwargs):
#
if (isIndexserver and serviceRestart and daemonActive and databaseActive):
msg = f"LOST: indexserver event looks like a lost indexserver (status={status})"
logTimestamp(method, episode, msg)
self.logTimestamp(method, episode, msg)
self.tracer.info(msg)
isLostIndexserver = True
eventKnown = True
if (isIndexserver and serviceActive and daemonActive and databaseActive):
if self.takeover_active:
msg = "TAKEOVER: indexserver event looks like a takeover event"
logTimestamp(method, episode, msg)
self.logTimestamp(method, episode, msg)
self.tracer.info(msg)
else:
msg = ("LOST: indexserver event looks like a lost indexserver"
" (indexserver started)")
logTimestamp(method, episode, msg)
self.logTimestamp(method, episode, msg)
self.tracer.info(msg)
eventKnown = True
# TODO: this event (LOST/started) seems also to come, if a sr_takeover is been
# processed (using preTakeover() and postTakeover() to mark this event?)
if (isIndexserver and serviceStopping and daemonStop):
msg = "STOP: indexserver event looks like graceful instance stop"
logTimestamp(method, episode, msg)
self.logTimestamp(method, episode, msg)
self.tracer.info(msg)
eventKnown = True
if (isIndexserver and serviceDown and daemonStop):
msg = ("STOP: indexserver event looks like graceful instance stop"
" (indexserver stopped)")
self.tracer.info(msg)
logTimestamp(method, episode, msg)
self.logTimestamp(method, episode, msg)
eventKnown = True
if (isIndexserver and serviceStopping and daemonActive and databaseStop):
msg = "STOP: indexserver event looks like graceful tenant stop"
logTimestamp(method, episode, msg)
self.logTimestamp(method, episode, msg)
self.tracer.info(msg)
eventKnown = True
if (isIndexserver and serviceDown and daemonActive and databaseStop):
msg = ("STOP: indexserver event looks like graceful tenant stop"
" (indexserver stopped)")
logTimestamp(method, episode, msg)
self.logTimestamp(method, episode, msg)
self.tracer.info(msg)
eventKnown = True
if (isIndexserver and serviceRestart and daemonStarting and databaseActive):
msg = "START: indexserver event looks like graceful tenant start"
logTimestamp(method, episode, msg)
self.logTimestamp(method, episode, msg)
self.tracer.info(msg)
eventKnown = True
if (isIndexserver and serviceActive and daemonStarting and databaseActive):
msg = ("START: indexserver event looks like graceful tenant start"
" (indexserver started)")
logTimestamp(method, episode, msg)
self.logTimestamp(method, episode, msg)
self.tracer.info(msg)
eventKnown = True
if (isIndexserver and not eventKnown):
Expand All @@ -256,7 +256,7 @@ def srServiceStateChanged(self, ParamDict, **kwargs):
f" daemonActive={daemonActive}, daemonStop={daemonStop},"
f" daemonStarting={daemonStarting},"
f" databaseActive={databaseActive}, databaseStop={databaseStop}")
logTimestamp(method, episode, msg)
self.logTimestamp(method, episode, msg)
self.tracer.info(msg)
# event on secondary, if HA1 tenant is stopped on primary
# DBG: version=0.2.7,serviceRestart=True, serviceStop=True, serviceDown=False,
Expand All @@ -272,19 +272,19 @@ def srServiceStateChanged(self, ParamDict, **kwargs):
# pylint: disable-next=line-too-long
if (isLostIndexserver and (self.action_on_lost in ["ignore", "ignore_fallback", "ignore_default"])):
msg = f"LOST: event ignored. action_on_lost={self.action_on_lost}"
logTimestamp(method, episode, msg)
self.logTimestamp(method, episode, msg)
self.tracer.info(msg)
if (isLostIndexserver and self.action_on_lost == "fence"):
msg = f"LOST: fence node. action_on_lost={self.action_on_lost}"
logTimestamp(method, episode, msg)
self.logTimestamp(method, episode, msg)
self.tracer.info(msg)
tout_cmd = ""
action_cmd = f"sudo /usr/bin/SAPHanaSR-hookHelper --sid={mySID} --case=fenceMe"
os.WEXITSTATUS(os.system(f"sleep 5; {tout_cmd} {action_cmd}"))
if (isLostIndexserver and self.action_on_lost == "kill"):
msg = (f"LOST: kill instance. action_on_lost={self.action_on_lost}"
f" signal={self.killSignal}")
logTimestamp(method, episode, msg)
self.logTimestamp(method, episode, msg)
self.tracer.info(msg)
tout_cmd = ""
action_cmd = f"HDB kill-{self.killSignal}"
Expand All @@ -293,12 +293,12 @@ def srServiceStateChanged(self, ParamDict, **kwargs):
os.WEXITSTATUS(os.system(f"sleep 5; {tout_cmd} {action_cmd}"))
# the following message will most-likely also be lost, if we use signal 9
msg = f"LOST: killed instance. action_on_lost={self.action_on_lost}"
logTimestamp(method, episode, msg)
self.logTimestamp(method, episode, msg)
# DONE: hardcoded 5 here to be moved to a self.sleep_before_action
# (or however it will be named)
if (isLostIndexserver and self.action_on_lost == "stop"):
msg = f"LOST: stop instance. action_on_lost={self.action_on_lost}"
logTimestamp(method, episode, msg)
self.logTimestamp(method, episode, msg)
self.tracer.info(msg)
tout_cmd = f"timeout {self.stop_timeout}"
# action_cmd = "HDB stop"
Expand All @@ -310,7 +310,7 @@ def srServiceStateChanged(self, ParamDict, **kwargs):
# this code could be removed at any time without notice
# the code does not promise that it will be part of any product later
msg = f"LOST: firstStopThenKill instance. action_on_lost={self.action_on_lost}"
logTimestamp(method, episode, msg)
self.logTimestamp(method, episode, msg)
self.tracer.info(msg)
action_cmd = (f"/usr/bin/SAPHanaSR-hookHelper --sid={mySID}"
f" --ino={self.ino} --case=firstStopThenKill")
Expand All @@ -321,7 +321,7 @@ def srServiceStateChanged(self, ParamDict, **kwargs):
# the code does not promise that it will be part of any product later
msg = (f"LOST: set cluster attribute. action_on_lost={self.action_on_lost}"
" is currently not implemented")
logTimestamp(method, episode, msg)
self.logTimestamp(method, episode, msg)
self.tracer.info(msg)
# TODO add attribute code here
return 0
Expand Down
Loading