Add Libc.mkfifo

base/libc.jl

@@ -10,6 +10,9 @@ import Core.Intrinsics: bitcast
 
 export FILE, TmStruct, strftime, strptime, getpid, gethostname, free, malloc, calloc, realloc,
  errno, strerror, flush_cstdio, systemsleep, time, transcode
+if Sys.isunix()
+ export mkfifo
+end
 if Sys.iswindows()
  export GetLastError, FormatMessage
 end
@@ -400,4 +403,22 @@ Interface to the C `srand(seed)` function.
 """
 srand(seed=floor(Int, time()) % Cuint) = ccall(:srand, Cvoid, (Cuint,), seed)
 
+if Sys.isunix()
+ @doc """
+ mkfifo(path::AbstractString, [mode::Integer]) -> path
+
+ Make a FIFO special file (a named pipe) at `path`. Return `path` as-is on success.
+ """ ->
+ function mkfifo(
+ path::AbstractString,
+ mode::Integer = Base.S_IRUSR | Base.S_IWUSR | Base.S_IRGRP | Base.S_IWGRP |
+ Base.S_IROTH | Base.S_IWOTH,
+ )
+ # Default `mode` is compatible with `mkfifo` CLI in coreutils.
+ ret = ccall(:mkfifo, Cint, (Cstring, Base.Cmode_t), path, mode)
+ systemerror("mkfifo", ret == -1)
+ return path
+ end
+end
+
 end # module

test/file.jl

@@ -1477,3 +1477,19 @@ end
  end
  end
 end
+
+@testset "mkfifo" begin
+ mktempdir() do dir
+ path = Libc.mkfifo(joinpath(dir, "fifo"))
+ @sync begin
+ cat_exec = `$(Base.julia_cmd()) --startup-file=no -e "write(stdout, read(ARGS[1]))"`
+ reader = @async read(`$cat_exec $path`, String)
+ @async write(path, "hello")
+ @test fetch(reader) == "hello"
+ end
+
+ existing_file = joinpath(dir, "existing")
+ write(existing_file, "")
+ @test_throws SystemError Libc.mkfifo(existing_file)
+ end
+end