Lower packet/frame logs to trace and player with closed connection (#527)
This commit is contained in:
+3
-3
@@ -85,7 +85,7 @@ func ReadPacket(reader *bufio.Reader, addr net.Addr, state State) (*Packet, erro
|
|||||||
logrus.
|
logrus.
|
||||||
WithField("client", addr).
|
WithField("client", addr).
|
||||||
WithField("packet", packet).
|
WithField("packet", packet).
|
||||||
Debug("Read packet")
|
Trace("Read packet")
|
||||||
return packet, nil
|
return packet, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -206,7 +206,7 @@ func ReadFrame(reader io.Reader, addr net.Addr) (*Frame, error) {
|
|||||||
logrus.
|
logrus.
|
||||||
WithField("client", addr).
|
WithField("client", addr).
|
||||||
WithField("length", frame.Length).
|
WithField("length", frame.Length).
|
||||||
Debug("Read frame length")
|
Trace("Read frame length")
|
||||||
|
|
||||||
frame.Payload = make([]byte, frame.Length)
|
frame.Payload = make([]byte, frame.Length)
|
||||||
total := 0
|
total := 0
|
||||||
@@ -223,7 +223,7 @@ func ReadFrame(reader io.Reader, addr net.Addr) (*Frame, error) {
|
|||||||
WithField("client", addr).
|
WithField("client", addr).
|
||||||
WithField("total", total).
|
WithField("total", total).
|
||||||
WithField("length", frame.Length).
|
WithField("length", frame.Length).
|
||||||
Debug("Reading frame content")
|
Trace("Reading frame content")
|
||||||
|
|
||||||
if n == 0 {
|
if n == 0 {
|
||||||
logrus.
|
logrus.
|
||||||
|
|||||||
@@ -526,6 +526,7 @@ func (c *Connector) cleanupBackendConnection(clientAddr net.Addr, serverAddress
|
|||||||
logrus.
|
logrus.
|
||||||
WithField("client", clientAddr).
|
WithField("client", clientAddr).
|
||||||
WithField("backendHostPort", backendHostPort).
|
WithField("backendHostPort", backendHostPort).
|
||||||
|
WithField("player", playerInfo).
|
||||||
WithField("connectionCount", c.activeConnections.GetCount(backendHostPort)).
|
WithField("connectionCount", c.activeConnections.GetCount(backendHostPort)).
|
||||||
Info("Closed connection to backend")
|
Info("Closed connection to backend")
|
||||||
if checkScaleDown && c.scaleActiveConnections.GetCount(scalingTarget) <= 0 {
|
if checkScaleDown && c.scaleActiveConnections.GetCount(scalingTarget) <= 0 {
|
||||||
|
|||||||
@@ -482,6 +482,9 @@ func (w *dockerWatcherImpl) listContainers(ctx context.Context) ([]*routableCont
|
|||||||
if !data.notRunning {
|
if !data.notRunning {
|
||||||
endpoint = fmt.Sprintf("%s:%d", data.ip, data.port)
|
endpoint = fmt.Sprintf("%s:%d", data.ip, data.port)
|
||||||
}
|
}
|
||||||
|
logrus.WithField("backendEndpoint", endpoint).
|
||||||
|
WithField("containerID", container.ID).
|
||||||
|
Debug("Found routable Docker container")
|
||||||
|
|
||||||
for _, host := range data.hosts {
|
for _, host := range data.hosts {
|
||||||
result = append(result, &routableContainer{
|
result = append(result, &routableContainer{
|
||||||
|
|||||||
Reference in New Issue
Block a user