Commit6ce5c19

committed

chore: reposition close of update channel

1 parent3e50965 commit6ce5c19Copy full SHA for 6ce5c19

File tree

-5

lines changed

-5

lines changed

Lines changed: 1 addition & 5 deletions

Original file line number	Diff line number	Diff line change
`@@ -570,11 +570,6 @@ func (api API) watchContainers(rw http.ResponseWriter, r http.Request) {`
`570`	`570`	`deferencoder.Close(websocket.StatusNormalClosure)`
`571`	`571`
`572`	`572`	`updateCh:=make(chanstruct{},1)`
`573`		`-deferfunc() {`
`574`		`-api.mu.Lock()`
`575`		`-close(updateCh)`
`576`		`-api.mu.Unlock()`
`577`		`-}()`
`578`	`573`
`579`	`574`	`api.mu.Lock()`
`580`	`575`	`api.updateChans=append(api.updateChans,updateCh)`
`@@ -585,6 +580,7 @@ func (api API) watchContainers(rw http.ResponseWriter, r http.Request) {`
`585`	`580`	`api.updateChans=slices.DeleteFunc(api.updateChans,func(chchanstruct{})bool {`
`586`	`581`	`returnch==updateCh`
`587`	`582`	`})`
	`583`	`+close(updateCh)`
`588`	`584`	`api.mu.Unlock()`
`589`	`585`	`}()`
`590`	`586`

Comments

(0)