Method Close

pkg/splitwriter/split_writer.go:80–128

()

}

func (w *splitWriter) Close() error {
	if err := w.f.Close(); err != nil {
		return err
	}

	stat, err := os.Stat(w.fname)
	if err != nil {
		return err
	}

	cursize := stat.Size()
	fname := w.fname

	for {
		if cursize <= w.maxsize {
			// All good: splitting not needed
			break
		}

		// Split needed, reopen the file and look for the split point.
		f, err := os.OpenFile(fname, os.O_RDWR, 0)
		if err != nil {
			return err
		}

		off, err := w.findSplitPoint(f)
		if err != nil {
			return err
		}
		if off == 0 {
			// Nothing to do since f can't be split.
			f.Close()
			break
		}

		f, err = doSplit(f, off)
		if err != nil {
			return fmt.Errorf("splitWriter: doSplit: %v", err)
		}

		// Update for the next iteration
		fname = f.Name()
		cursize -= off
		if err := f.Close(); err != nil {
			return err
		}
	}
	return nil
}

// findSplitPoint searches for a suitable split point in f, which is the offset
// of the last line feed which is prior to the split size.