@@ -279,7 +279,7 @@ private func currentProcessIdentifier() -> ProcessIdentifier {
279279 #elseif canImport(Glibc) || canImport(Android) || canImport(Musl)
280280 return . init( value: ProcessInfo . processInfo. processIdentifier, processDescriptor: - 1 )
281281 #elseif os(Windows)
282- return . init( value: UInt32 ( ProcessInfo . processInfo. processIdentifier) , processDescriptor: UnsafeMutableRawPointer ( bitPattern : 0 ) ! , threadHandle: UnsafeMutableRawPointer ( bitPattern : 0 ) ! )
282+ return . init( value: UInt32 ( ProcessInfo . processInfo. processIdentifier) , processDescriptor: INVALID_HANDLE_VALUE , threadHandle: INVALID_HANDLE_VALUE )
283283 #endif
284284}
285285
@@ -448,6 +448,7 @@ extension PipeConfiguration {
448448 private func runPipeline( ) async throws -> CollectedResult < Output , Error > {
449449 // Create a pipe for standard error
450450 let sharedErrorPipe = try createPipe ( )
451+ // FIXME: Use _safelyClose() to fully close each end of the pipe on all platforms
451452
452453 return try await withThrowingTaskGroup ( of: CollectedPipeResult . self, returning: CollectedResult< Output, Error> . self ) { group in
453454 // Collect error output from all stages
@@ -466,6 +467,7 @@ extension PipeConfiguration {
466467 var pipes : [ ( readEnd: FileDescriptor , writeEnd: FileDescriptor ) ] = [ ]
467468 for _ in 0 ..< ( stages. count - 1 ) {
468469 try pipes. append ( createPipe ( ) )
470+ // FIXME: Use _safelyClose() to fully close each end of the pipe on all platforms
469471 }
470472
471473 let pipeResult = try await withThrowingTaskGroup ( of: PipelineTaskResult . self, returning: CollectedResult< Output, DiscardedOutput> . self ) { group in
0 commit comments