Upstream/waveterm
1
0
Fork 0
mirror of https://github.com/wavetermdev/waveterm.git synced 2025-03-14 13:49:16 +01:00
Code Issues Packages Projects Releases Wiki Activity

add a defer/recover to scws WriteJson

Browse Source
This commit is contained in:
sawka 2023-11-10 13:36:37 -08:00
parent 5327258287
commit 7da7d06f09
1 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
wavesrv/pkg/scws/scws.go
View File

@ -128,11 +128,23 @@ func (ws *WSState) RunUpdates(updateCh chan interface{}) {
for update := range updateCh {
shell := ws.GetShell()
if shell != nil {
shell.WriteJson(update)
writeJsonProtected(shell, update)
}
}
}
func writeJsonProtected(shell *wsshell.WSShell, update any) {
defer func() {
r := recover()
if r == nil {
return
}
log.Printf("[error] in scws RunUpdates WriteJson: %v\n", r)
return
}()
shell.WriteJson(update)
}
func (ws *WSState) ReplaceShell(shell *wsshell.WSShell) {
ws.Lock.Lock()
defer ws.Lock.Unlock()