extern/zrok
1
1
Fork 0
mirror of https://github.com/openziti/zrok.git synced 2025-01-11 00:18:43 +01:00
Code Issues Packages Projects Releases Wiki Activity

comments

Browse Source
This commit is contained in:
Michael Quigley 2022-10-04 13:45:41 -04:00
parent 9f567513f5
commit d31753c05a
No known key found for this signature in database
GPG Key ID: 9B60314A9DD20A62
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
cmd/zrokloop/loop.go
View File

@ -77,6 +77,7 @@ func newLooper(id int, r *run) *looper {
}
func (l *looper) run() {
// Startup
logrus.Infof("starting #%d", l.id)
defer close(l.done)
defer logrus.Infof("stopping #%d", l.id)
@ -108,8 +109,10 @@ func (l *looper) run() {
logrus.Infof("looper #%d, service: %v, frontend: %v", l.id, tunnelResp.Payload.Service, tunnelResp.Payload.ProxyEndpoint)
go l.serviceListener(zif, tunnelResp.Payload.Service)
// Dwell
time.Sleep(time.Duration(l.r.dwellSeconds) * time.Second)
// Iterations
for i := 0; i < l.r.iterations; i++ {
if i > 0 && i%l.r.statusEvery == 0 {
logrus.Infof("looper #%d: iteration #%d", l.id, i)
@ -137,6 +140,7 @@ func (l *looper) run() {
}
logrus.Infof("looper #%d: complete", l.id)
// Shutdown
if l.listener != nil {
if err := l.listener.Close(); err != nil {
logrus.Errorf("looper #%d error closing listener: %v", l.id, err)