Function parseSync

libcontainer/sync.go:189–203

parseSync runs the given callback function on each syncT received from the child. It will return once io.EOF is returned from the given pipe.

(pipe *syncSocket, fn func(*syncT) error)

// parseSync runs the given callback function on each syncT received from the
// child. It will return once io.EOF is returned from the given pipe.
func parseSync(pipe *syncSocket, fn func(*syncT) error) error {
	for {
		sync, err := doReadSync(pipe)
		if err != nil {
			if errors.Is(err, io.EOF) {
				break
			}
			return err
		}
		if err := fn(&sync); err != nil {
			return err
		}
	}
	return nil
}