Skip to content

Commit

Permalink
changes some debug markers to DISSHU
Browse files Browse the repository at this point in the history
  • Loading branch information
David Erb committed May 10, 2023
1 parent f8abd15 commit f90b699
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 7 deletions.
4 changes: 2 additions & 2 deletions src/dls_servbase_api/aiohttp_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -294,7 +294,7 @@ async def client_shutdown(self):
await self._client_session.get(f"{self.__client_netloc}/shutdown")

logger.debug(
f"[PIDAL] client has requested {callsign(self)} server shutdown"
f"[DISSHU] client has requested {callsign(self)} server shutdown"
)

max_seconds = 5.0
Expand All @@ -316,7 +316,7 @@ async def client_shutdown(self):
)

logger.debug(
f"[PIDAL] waiting for {callsign(self)} server shutdown, napping {nap_seconds}"
f"[DISSHU] waiting for {callsign(self)} server shutdown, napping {nap_seconds}"
)

# Small sleep after sending shutdown command lets the server really shut down.
Expand Down
10 changes: 5 additions & 5 deletions src/dls_servbase_lib/base_aiohttp.py
Original file line number Diff line number Diff line change
Expand Up @@ -123,7 +123,7 @@ async def start_process(self):
target=self.prepare_to_activate_process,
)
self.__process2.start()
logger.debug(f"[PIDAL] {callsign(self)} pid {self.__process2.pid} is started")
logger.debug(f"[DISSHU] {callsign(self)} pid {self.__process2.pid} is started")
# TODO: Make maximum wait time for start_process event to be configurable.
timeout = 30.0
naptime = 0.25
Expand Down Expand Up @@ -158,7 +158,7 @@ async def is_process_alive(self):

# state = "alive" if is_alive else "dead"

# logger.debug(f"[PIDAL] {callsign(self)} pid {self.__process2.pid} is {state}")
# logger.debug(f"[DISSHU] {callsign(self)} pid {self.__process2.pid} is {state}")

return is_alive

Expand Down Expand Up @@ -242,7 +242,7 @@ def activate_process_base(self):
except Exception as exception:
logger.exception("exception in process", exc_info=exception)

logger.debug(f"[PIDAL] {callsign(self)} pid {os.getpid()} has quit")
logger.debug(f"[DISSHU] {callsign(self)} pid {os.getpid()} has quit")

# ----------------------------------------------------------------------------------------
async def start_thread(self):
Expand Down Expand Up @@ -340,7 +340,7 @@ async def base_direct_shutdown(self):
# If we were started via process, we will need to stop our own event loop.
if self.owned_event_loop2 is not None:
logger.debug(
f"[NEWSHUT] directly shutting down {callsign(self)} owned event loop on pid {os.getpid()}"
f"[DISSHU] directly shutting down {callsign(self)} owned event loop on pid {os.getpid()}"
)

try:
Expand All @@ -351,7 +351,7 @@ async def base_direct_shutdown(self):

elif self.__app_runner is not None:
logger.debug(
f"[NEWSHUT] directly shutting down {callsign(self)} by awaiting self.__app_runner.cleanup()"
f"[DISSHU] directly shutting down {callsign(self)} by awaiting self.__app_runner.cleanup()"
)
await self.__app_runner.cleanup()

Expand Down

0 comments on commit f90b699

Please sign in to comment.