match windows err

open-telemetry · Sep 19, 2024 · 1f718d1 · 1f718d1
1 parent 3c79af6
commit 1f718d1
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pkg/stanza/operator/input/windows/input.go b/pkg/stanza/operator/input/windows/input.go
@@ -216,7 +216,9 @@ func (i *Input) read(ctx context.Context) int {
 	events, err := i.subscription.Read(i.maxReads)
 	if err != nil {
 		i.Logger().Error("Failed to read events from subscription", zap.Error(err))
-		if i.isRemote() && (err.Error() == "The handle is invalid." || err.Error() == "subscription handle is not open") {
+		i.Logger().Info("Error is: ", zap.Error(err))
+		i.Logger().Info("windowserr is: ", zap.Error(windows.ERROR_INVALID_HANDLE))
+		if i.isRemote() && (errors.Is(err, windows.ERROR_INVALID_HANDLE) || err.Error() == "subscription handle is not open") {
 			i.Logger().Info("Resubscribing, closing remote subscription")
 			closeErr := i.subscription.Close()
 			if closeErr != nil {