saltstack/salt
1
0
Fork 0
mirror of https://github.com/saltstack/salt.git synced 2025-04-17 10:10:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

Clean up log levels in tcp and ws transports

Browse source
This commit is contained in:
Daniel A. Wozniak 2024-04-09 15:05:46 -07:00 • committed by Daniel Wozniak
parent 1e9e8d6a11
commit d79e345067
2 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
changelog/66179.fixed.md
View file

@ -1 +1 @@
Change log level of publisher binding from error to debug.
Log "Publish server binding pub to" messages to debug instead of error level.

8
salt/transport/ws.py
View file

@ -131,7 +131,7 @@ class PublishClient(salt.transport.base.PublishClient):
url = "https://ipc.saltproject.io/ws"
else:
url = "http://ipc.saltproject.io/ws"
log.error("pub client connect %r %r", url, ctx)
log.debug("pub client connect %r %r", url, ctx)
ws = await asyncio.wait_for(session.ws_connect(url, ssl=ctx), 3)
except Exception as exc: # pylint: disable=broad-except
log.warning(
@ -397,7 +397,7 @@ class PublishServer(salt.transport.base.DaemonizedPublishServer):
else:
if cert:
name = salt.transport.base.common_name(cert)
log.error("Request client cert %r", name)
log.debug("Request client cert %r", name)
ws = aiohttp.web.WebSocketResponse()
await ws.prepare(request)
self.clients.add(ws)
@ -512,7 +512,7 @@ class RequestServer(salt.transport.base.DaemonizedRequestServer):
else:
if cert:
name = salt.transport.base.common_name(cert)
log.error("Request client cert %r", name)
log.debug("Request client cert %r", name)
ws = aiohttp.web.WebSocketResponse()
await ws.prepare(request)
async for msg in ws:
@ -550,7 +550,7 @@ class RequestClient(salt.transport.base.RequestClient):
ctx = tornado.netutil.ssl_options_to_context(self.ssl, server_side=False)
self.session = aiohttp.ClientSession()
URL = self.get_master_uri(self.opts)
log.error("Connect to %s %s", URL, ctx)
log.debug("Connect to %s %s", URL, ctx)
self.ws = await self.session.ws_connect(URL, ssl=ctx)
async def send(self, load, timeout=60):