Merge pull request #259 from sipcapture/ping_asap

fix reconnect ping
sipcapture · Aug 15, 2023 · 67317e2 · 67317e2
2 parents 0499d48 + ce7ee6a
commit 67317e2
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 2 deletions.
diff --git a/main.go b/main.go
@@ -12,7 +12,7 @@ import (
 	"github.com/sipcapture/heplify/sniffer"
 )
 
-const version = "heplify 1.65.7"
+const version = "heplify 1.65.8"
 
 func createFlags() {
 

diff --git a/publish/hep.go b/publish/hep.go
@@ -58,7 +58,7 @@ func (h *HEPOutputer) ReConnect(n int) (err error) {
 		return err
 	}
 	h.client[n].writer.Reset(h.client[n].conn)
-	h.ReSendPingPacket()
+	//h.ReSendPingPacket()
 	return err
 }
 
@@ -124,6 +124,15 @@ func (h *HEPOutputer) Send(msg []byte) {
 					logp.Err("reconnect error: %v", err)
 					return
 				} else {
+					if h.msgPing != nil {
+						logp.Debug("collector", "send ping packet after disconnect")
+						h.client[n].writer.Write(h.msgPing)
+						err = h.client[n].writer.Flush()
+						if err != nil {
+							logp.Err("Bad during resend ping packet : %v", err)
+						}
+					}
+
 					h.client[n].writer.Write(msg)
 					err = h.client[n].writer.Flush()
 					if err != nil {