Function new

pkg/fifosync/fifo_unix.go:66–87

New creates a new FIFO if it does not already exist. Use AsTrigger or AsWaiter to convert the new FIFO to a Trigger or Waiter.

(name string, mode uint32)

// New creates a new FIFO if it does not already exist. Use AsTrigger or AsWaiter to convert the new FIFO to a Trigger
// or Waiter.
func new(name string, mode uint32) (*fifo, error) {
	s, err := os.Stat(name)
	exist := true
	if err != nil {
		if !errors.Is(err, os.ErrNotExist) {
			return nil, fmt.Errorf("fifo: failed to stat %q: %w", name, err)
		}
		exist = false
	}
	if s != nil && s.Mode()&os.ModeNamedPipe == 0 {
		return nil, fmt.Errorf("fifo: not a named pipe: %q", name)
	}
	if !exist {
		err = unix.Mkfifo(name, mode)
		if err != nil && !errors.Is(err, unix.EEXIST) {
			return nil, fmt.Errorf("fifo: failed to create %q: %w", name, err)
		}
	}
	return &fifo{
		name: name,
	}, nil
}

func (f *fifo) Name() string {
	return f.name