From c52e2c2e8f53a6f8f9fe7b77ea7effef640643f7 Mon Sep 17 00:00:00 2001 From: "Timothy St. Clair" Date: Mon, 2 Oct 2017 12:33:34 -0500 Subject: [PATCH] Fixes #75 - Cleanup stale file handle Signed-off-by: Timothy St. Clair --- pkg/worker/worker.go | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/pkg/worker/worker.go b/pkg/worker/worker.go index 77df51293..153467a6d 100644 --- a/pkg/worker/worker.go +++ b/pkg/worker/worker.go @@ -36,6 +36,7 @@ import ( func GatherResults(waitfile string, url string) error { var inputFileName []byte var err error + var outfile *os.File // just loop looking for a file. done := false @@ -60,9 +61,16 @@ func GatherResults(waitfile string, url string) error { url += "." + filenameParts[1] } + defer func() { + if outfile != nil { + outfile.Close() + } + }() + // transmit back the results file. return DoRequest(url, func() (io.Reader, error) { - outfile, err := os.Open(s) + outfile, err = os.Open(s) return outfile, errors.WithStack(err) }) + }