mirror of https://github.com/jetkvm/kvm.git
Read rx logger under lock.
This commit is contained in:
parent
43c1468bcb
commit
7689f2ec49
|
|
@ -71,10 +71,11 @@ func (l *LLDP) setUpPacketSourceUnderLock(tPacket *afpacket.TPacket, logger *zer
|
||||||
return gopacket.NewPacketSource(tPacket, layers.LayerTypeEthernet), nil
|
return gopacket.NewPacketSource(tPacket, layers.LayerTypeEthernet), nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (l *LLDP) doCapture(logger *zerolog.Logger) {
|
func (l *LLDP) doCapture() {
|
||||||
l.mu.Lock()
|
l.mu.Lock()
|
||||||
l.Rx.Running = true
|
l.Rx.Running = true
|
||||||
ctx := l.Rx.Ctx
|
ctx := l.Rx.Ctx
|
||||||
|
logger := l.Rx.Logger
|
||||||
l.mu.Unlock()
|
l.mu.Unlock()
|
||||||
|
|
||||||
defer func() {
|
defer func() {
|
||||||
|
|
@ -179,8 +180,7 @@ func (l *LLDP) startCapture() error {
|
||||||
}
|
}
|
||||||
|
|
||||||
if startRunning {
|
if startRunning {
|
||||||
logger := l.Rx.Logger
|
go l.doCapture()
|
||||||
go l.doCapture(logger)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue