talksik
43 lines
840 B
Go
43 lines
840 B
Go
package main
|
|
|
|
import (
|
|
"fmt"
|
|
"os"
|
|
"syscall"
|
|
)
|
|
|
|
// createNamedPipe creates a named pipe (FIFO)
|
|
func createNamedPipe(pipeName string) error {
|
|
err := syscall.Mkfifo(pipeName, 0666)
|
|
if err != nil && !os.IsExist(err) {
|
|
return err
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func main() {
|
|
// Create a named pipe (FIFO)
|
|
pipeName := "my_pipe"
|
|
err := createNamedPipe(pipeName)
|
|
if err != nil {
|
|
fmt.Println("Error creating named pipe:", err)
|
|
return
|
|
}
|
|
|
|
// Open the named pipe for writing
|
|
pipe, err := os.OpenFile(pipeName, os.O_WRONLY, os.ModeNamedPipe)
|
|
if err != nil {
|
|
fmt.Println("Error opening named pipe for writing:", err)
|
|
return
|
|
}
|
|
defer pipe.Close()
|
|
|
|
// Write data to the named pipe
|
|
message := "Hello from the writer program!"
|
|
_, err = pipe.WriteString(message)
|
|
if err != nil {
|
|
fmt.Println("Error writing to named pipe:", err)
|
|
return
|
|
}
|
|
}
|