From c31f8116ba717400106295a9de3fab80c1f3f97b Mon Sep 17 00:00:00 2001
From: Sven Rebhan <36194019+srebhan@users.noreply.github.com>
Date: Tue, 29 Nov 2022 14:06:55 +0100
Subject: [PATCH] fix(inputs.directory_monitor): Close input file before
 removal (#12294)

---
 plugins/inputs/directory_monitor/directory_monitor.go | 11 ++++++++---
 1 file changed, 8 insertions(+), 3 deletions(-)

diff --git a/plugins/inputs/directory_monitor/directory_monitor.go b/plugins/inputs/directory_monitor/directory_monitor.go
index 16e87ef59..f388c1912 100644
--- a/plugins/inputs/directory_monitor/directory_monitor.go
+++ b/plugins/inputs/directory_monitor/directory_monitor.go
@@ -335,7 +335,6 @@ func (monitor *DirectoryMonitor) moveFile(srcPath string, dstBaseDir string) {
 	if err != nil {
 		monitor.Log.Errorf("Could not open input file: %s", err)
 	}
-	defer inputFile.Close()
 
 	outputFile, err := os.Create(dstPath)
 	if err != nil {
@@ -348,8 +347,14 @@ func (monitor *DirectoryMonitor) moveFile(srcPath string, dstBaseDir string) {
 		monitor.Log.Errorf("Writing to output file failed: %s", err)
 	}
 
-	err = os.Remove(srcPath)
-	if err != nil {
+	// We need to close the file for remove on Windows as we otherwise
+	// will run into a "being used by another process" error
+	// (see https://github.com/influxdata/telegraf/issues/12287)
+	if err := inputFile.Close(); err != nil {
+		monitor.Log.Errorf("Could not close input file: %s", err)
+	}
+
+	if err := os.Remove(srcPath); err != nil {
 		monitor.Log.Errorf("Failed removing original file: %s", err)
 	}
 }