printing client stats every other second only if the connection count has changed or when SIGUSR1 or SIGINFO recieved

5 files changed, 10 insertions, 10 deletions

diff --git a/cmd/dcat/main.go b/cmd/dcat/main.go
index e0931d8..f0ea946 100644
--- a/cmd/dcat/main.go
+++ b/cmd/dcat/main.go
@@ -9,6 +9,7 @@ import (
 	"github.com/mimecast/dtail/internal/color"
 	"github.com/mimecast/dtail/internal/config"
 	"github.com/mimecast/dtail/internal/io/logger"
+	"github.com/mimecast/dtail/internal/io/signal"
 	"github.com/mimecast/dtail/internal/user"
 	"github.com/mimecast/dtail/internal/version"
 )
@@ -54,7 +55,7 @@ func main() {
 		panic(err)
 	}
 
-	status := client.Start(ctx)
+	status := client.Start(ctx, signal.StatsCh(ctx))
 	logger.Flush()
 	os.Exit(status)
 }
diff --git a/cmd/dgrep/main.go b/cmd/dgrep/main.go
index e58ea8f..d1fdc21 100644
--- a/cmd/dgrep/main.go
+++ b/cmd/dgrep/main.go
@@ -9,6 +9,7 @@ import (
 	"github.com/mimecast/dtail/internal/color"
 	"github.com/mimecast/dtail/internal/config"
 	"github.com/mimecast/dtail/internal/io/logger"
+	"github.com/mimecast/dtail/internal/io/signal"
 	"github.com/mimecast/dtail/internal/user"
 	"github.com/mimecast/dtail/internal/version"
 )
@@ -62,7 +63,7 @@ func main() {
 		panic(err)
 	}
 
-	status := client.Start(ctx)
+	status := client.Start(ctx, signal.StatsCh(ctx))
 	logger.Flush()
 	os.Exit(status)
 }
diff --git a/cmd/dmap/main.go b/cmd/dmap/main.go
index 470ce76..279b343 100644
--- a/cmd/dmap/main.go
+++ b/cmd/dmap/main.go
@@ -9,6 +9,7 @@ import (
 	"github.com/mimecast/dtail/internal/color"
 	"github.com/mimecast/dtail/internal/config"
 	"github.com/mimecast/dtail/internal/io/logger"
+	"github.com/mimecast/dtail/internal/io/signal"
 	"github.com/mimecast/dtail/internal/omode"
 	"github.com/mimecast/dtail/internal/user"
 	"github.com/mimecast/dtail/internal/version"
@@ -61,7 +62,7 @@ func main() {
 		panic(err)
 	}
 
-	status := client.Start(ctx)
+	status := client.Start(ctx, signal.StatsCh(ctx))
 	logger.Flush()
 	os.Exit(status)
 }
diff --git a/cmd/drun/main.go b/cmd/drun/main.go
index c948c0f..ffdf7bf 100644
--- a/cmd/drun/main.go
+++ b/cmd/drun/main.go
@@ -11,6 +11,7 @@ import (
 	"github.com/mimecast/dtail/internal/color"
 	"github.com/mimecast/dtail/internal/config"
 	"github.com/mimecast/dtail/internal/io/logger"
+	"github.com/mimecast/dtail/internal/io/signal"
 	"github.com/mimecast/dtail/internal/user"
 	"github.com/mimecast/dtail/internal/version"
 )
@@ -63,7 +64,7 @@ func main() {
 		panic(err)
 	}
 
-	status := client.Start(ctx)
+	status := client.Start(ctx, signal.StatsCh(ctx))
 	logger.Flush()
 	os.Exit(status)
 }
diff --git a/cmd/dtail/main.go b/cmd/dtail/main.go
index 1be2a29..ff9028b 100644
--- a/cmd/dtail/main.go
+++ b/cmd/dtail/main.go
@@ -14,6 +14,7 @@ import (
 	"github.com/mimecast/dtail/internal/color"
 	"github.com/mimecast/dtail/internal/config"
 	"github.com/mimecast/dtail/internal/io/logger"
+	"github.com/mimecast/dtail/internal/io/signal"
 	"github.com/mimecast/dtail/internal/omode"
 	"github.com/mimecast/dtail/internal/user"
 	"github.com/mimecast/dtail/internal/version"
@@ -105,12 +106,7 @@ func main() {
 		}
 	}
 
-	/*
-		sigCh := make(chan os.Signal)
-		signal.Notify(sigCh, os.Interrupt, syscall.SIGINFO)
-	*/
-
-	status := client.Start(ctx)
+	status := client.Start(ctx, signal.StatsCh(ctx))
 	logger.Flush()
 	os.Exit(status)
 }