closer; improved readyToClose (#132)

openziti · Aug 27, 2021 · 9aae041 · 9aae041
1 parent dae294b
commit 9aae041
Showing 1 changed file with 18 additions and 0 deletions.
diff --git a/closer.go b/closer.go
@@ -40,4 +40,22 @@ func (c *closer) emergencyStop() {
 	}
 }
 
+func (c *closer) timeout() {
+	logrus.Info("timeout")
+
+	c.txp.close()
+	c.rxp.Close()
+
+	if c.closeHook != nil {
+		c.closeHook()
+	}
+}
+
+func (c *closer) run() {
+}
+
+func (c *closer) readyToClose() bool {
+	return (c.txCloseSeq != notClosed && c.rxCloseSeq != notClosed) || time.Since(c.lastEvent).Milliseconds() > int64(c.txp.alg.Profile().ConnectionTimeout)
+}
+
 const notClosed = int32(-99)