()
| 335 | } |
| 336 | |
| 337 | func (t *tunneler) handle() { |
| 338 | for { |
| 339 | select { |
| 340 | case <-t.ctx.Done(): |
| 341 | t.logger.Debug(t.ctx, "tunneler exiting", slog.Error(t.ctx.Err())) |
| 342 | return |
| 343 | case tun := <-t.updates: |
| 344 | t.cache(tun) |
| 345 | t.workQ.enqueue(tun.tKey) |
| 346 | } |
| 347 | } |
| 348 | } |
| 349 | |
| 350 | func (t *tunneler) worker() { |
| 351 | defer t.workerWG.Done() |