apps/openlan
1
0
Fork 0
mirror of https://github.com/luscis/openlan.git synced 2025-10-05 16:47:11 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: fallback is nil.
Some checks failed
Coverage CI / build (push) Has been cancelled
Details
CodeQL / Analyze (go) (push) Has been cancelled
Details
Ubuntu CI / build (push) Has been cancelled
Details

Browse Source
This commit is contained in:
Daniel Ding
2025-06-26 19:06:09 +08:00
parent 28d6dbd0e7
commit 154c7b5f7b
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
pkg/access/worker.go
View File

@@ -191,7 +191,6 @@ func NewWorker(cfg *config.Access) *Worker {
ticker: time.NewTicker(2 * time.Second), ticker: time.NewTicker(2 * time.Second),
nameCache: make(map[string]string), nameCache: make(map[string]string),
addrCache: make(map[string]string), addrCache: make(map[string]string),
sosWorker: make([]*SocketWorker, 2),
} }
} }
@@ -206,11 +205,11 @@ func (w *Worker) Initialize() {
w.out.Info("Worker.Initialize") w.out.Info("Worker.Initialize")
client := GetSocketClient(w.cfg, "") client := GetSocketClient(w.cfg, "")
w.conWorker = NewSocketWorker(client, w.cfg) w.conWorker = NewSocketWorker(client, w.cfg)
w.sosWorker = append(w.sosWorker, w.conWorker)
if w.cfg.Fallback != "" { if w.cfg.Fallback != "" {
back := GetSocketClient(w.cfg, w.cfg.Fallback) back := GetSocketClient(w.cfg, w.cfg.Fallback)
w.sosWorker[1] = NewSocketWorker(back, w.cfg) w.sosWorker = append(w.sosWorker, NewSocketWorker(back, w.cfg))
} }
w.sosWorker[0] = w.conWorker
tapCfg := GetTapCfg(w.cfg) tapCfg := GetTapCfg(w.cfg)
// register listener // register listener