Skip to content

Commit 412d1a2

Browse files
author
Simon Leung
committed
close channel properly during re-auth when connecting with noaa
[#92716720]
1 parent 93fc75a commit 412d1a2

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

cf/api/logs_noaa.go

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -124,12 +124,13 @@ func (l *logNoaaRepository) TailNoaaLogsFor(appGuid string, onConnect func(), on
124124
switch err.(type) {
125125
case nil: // do nothing
126126
case *noaa_errors.UnauthorizedError:
127-
if closeChan != nil {
127+
if !hasReauthed {
128128
l.tokenRefresher.RefreshAuthToken()
129-
close(closeChan)
130-
closeChan = nil
131-
go l.consumer.TailingLogs(appGuid, l.config.AccessToken(), logChan, errChan, make(chan struct{}))
129+
hasReauthed = true
130+
l.consumer.Close()
131+
go l.consumer.TailingLogs(appGuid, l.config.AccessToken(), logChan, errChan, closeChan)
132132
} else {
133+
close(closeChan)
133134
l.Close()
134135
return err
135136
}

0 commit comments

Comments
 (0)