MyFavMirrors/minio
1
0
Fork 0
mirror of https://github.com/minio/minio.git synced 2024-12-25 22:55:54 -05:00
Code Issues Packages Projects Releases Wiki Activity

fix: incomingBytes() to update via handleMessages() (#18891)

Browse Source 
previous change #18880 was incomplete
This commit is contained in:
Harshavardhana 2024-01-28 14:35:53 -08:00 committed by GitHub
parent 944f3c1477
commit 7743d952dc
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/grid/connection.go
View File

@ -956,6 +956,10 @@ func (c *Connection) handleMessages(ctx context.Context, conn net.Conn) {
logger.LogIfNot(ctx, fmt.Errorf("ws read: %w", err), net.ErrClosed, io.EOF) logger.LogIfNot(ctx, fmt.Errorf("ws read: %w", err), net.ErrClosed, io.EOF)
return return
} }
if c.incomingBytes != nil {
c.incomingBytes(int64(len(msg)))
}
// Parse the received message // Parse the received message
var m message var m message
subID, remain, err := m.parse(msg) subID, remain, err := m.parse(msg)