Input operator should stop without errors even if start was not calle…

…d or failed

pkg/stanza/operator/input/windows/input.go

@@ -154,7 +154,16 @@ func (i *Input) Start(persister operator.Persister) error {
 
 // Stop will stop reading events from a subscription.
 func (i *Input) Stop() error {
+	if i.cancel == nil {
+		// Nothing to do: either already stopped or never started.
+		return nil
+	}
+
 	i.cancel()
+	i.cancel = nil
+
+	// Warning: all calls made below must be safe to be done even if Start() was not called or failed.
+
 	i.wg.Wait()
 
 	if err := i.subscription.Close(); err != nil {

pkg/stanza/operator/input/windows/input_test.go

@@ -24,6 +24,12 @@ func newTestInput() *Input {
 	})
 }
 
+// TestInputCreate_Stop ensures the input correctly shuts down even if it was never started.
+func TestInputCreate_Stop(t *testing.T) {
+	input := newTestInput()
+	assert.NoError(t, input.Stop())
+}
+
 // TestInputStart_LocalSubscriptionError ensures the input correctly handles local subscription errors.
 func TestInputStart_LocalSubscriptionError(t *testing.T) {
 	persister := testutil.NewMockPersister("")