github/kubeshark
1
0
Fork 0
mirror of https://github.com/kubeshark/kubeshark.git synced 2025-07-18 18:32:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

Format socket ID as int in logs. (#143)

Browse Source
This commit is contained in:
nimrod-up9 2021-07-27 14:49:08 +03:00 committed by GitHub
parent 0566f63d72
commit 1ef17542dd
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
agent/pkg/api/socket_server_handlers.go
View File

@ -27,9 +27,9 @@ func init() {
func (h *RoutesEventHandlers) WebSocketConnect(socketId int, isTapper bool) { func (h *RoutesEventHandlers) WebSocketConnect(socketId int, isTapper bool) {
if isTapper { if isTapper {
rlog.Infof("Websocket Connection event - Tapper connected: %s", socketId) rlog.Infof("Websocket event - Tapper connected, socket ID: %d", socketId)
} else { } else {
rlog.Infof("Websocket Connection event - Browser socket connected: %s", socketId) rlog.Infof("Websocket event - Browser socket connected, socket ID: %d", socketId)
socketListLock.Lock() socketListLock.Lock()
browserClientSocketUUIDs = append(browserClientSocketUUIDs, socketId) browserClientSocketUUIDs = append(browserClientSocketUUIDs, socketId)
socketListLock.Unlock() socketListLock.Unlock()
@ -38,9 +38,9 @@ func (h *RoutesEventHandlers) WebSocketConnect(socketId int, isTapper bool) {
func (h *RoutesEventHandlers) WebSocketDisconnect(socketId int, isTapper bool) { func (h *RoutesEventHandlers) WebSocketDisconnect(socketId int, isTapper bool) {
if isTapper { if isTapper {
rlog.Infof("Disconnection event - Tapper connected: %s", socketId) rlog.Infof("Websocket event - Tapper disconnected, socket ID: %d", socketId)
} else { } else {
rlog.Infof("Disconnection event - Browser socket connected: %s", socketId) rlog.Infof("Websocket event - Browser socket disconnected, socket ID: %d", socketId)
socketListLock.Lock() socketListLock.Lock()
removeSocketUUIDFromBrowserSlice(socketId) removeSocketUUIDFromBrowserSlice(socketId)
socketListLock.Unlock() socketListLock.Unlock()
@ -52,7 +52,7 @@ func broadcastToBrowserClients(message []byte) {
go func(socketId int) { go func(socketId int) {
err := routes.SendToSocket(socketId, message) err := routes.SendToSocket(socketId, message)
if err != nil { if err != nil {
fmt.Printf("error sending message to socket id %d: %v", socketId, err) fmt.Printf("error sending message to socket ID %d: %v", socketId, err)
} }
}(socketId) }(socketId)