mirrors/opensnitch
1
0
Fork 0
mirror of https://github.com/evilsocket/opensnitch.git synced 2025-03-04 00:24:40 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

loggers, remote_syslog: check if we're connected

Browse source 
when writing, check if we're connected, or reconnecting.
This commit is contained in:
Gustavo Iñiguez Goia 2024-05-15 00:06:26 +02:00
parent efc05663eb
commit 84361449f2
Failed to generate hash of commit
1 changed files with 13 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
daemon/log/loggers/remote_syslog.go
View file

@ -168,17 +168,22 @@ func (s *RemoteSyslog) Write(msg string) {
// and have a continuous stream of events. Otherwise it'd stop working.
// I haven't figured out yet why these write errors ocurr.
s.mu.RLock()
defer s.mu.RUnlock()
if s.netConn == nil {
s.ReOpen()
return
}
s.netConn.SetWriteDeadline(deadline)
_, err := s.netConn.Write([]byte(msg))
s.mu.RUnlock()
if err == nil {
return
}
if err != nil {
log.Debug("[%s] %s write error: %v", s.Name, s.cfg.Protocol, err.(net.Error))
atomic.AddUint32(&s.errors, 1)
if atomic.LoadUint32(&s.errors) > maxAllowedErrors {
s.ReOpen()
return
}
log.Debug("[%s] %s write error: %v", s.Name, s.cfg.Protocol, err.(net.Error))
atomic.AddUint32(&s.errors, 1)
if atomic.LoadUint32(&s.errors) > maxAllowedErrors {
s.ReOpen()
return
}
}