Issue jstarks#7: Add retries on busy pipe instances

axxelG · Nov 17, 2020 · 8e19a09 · 8e19a09
1 parent 4997d3b
commit 8e19a09
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/npiperelay.go b/npiperelay.go
@@ -36,6 +36,13 @@ func dialPipe(p string, poll bool) (*overlappedFile, error) {
 			time.Sleep(200 * time.Millisecond)
 			continue
 		}
+		if err.Error() == "All pipe instances are busy." {
+			if *verbose {
+				log.Printf("All pipe instances are busy. Waiting 200 milliseconds to retry")
+			}
+			time.Sleep(200 * time.Millisecond)
+			continue
+		}
 		return nil, &os.PathError{Path: p, Op: "open", Err: err}
 	}
 }