Method newMapFile

worker/restore_map.go:156–162

()

}

func (m *mapper) newMapFile() (*os.File, error) {
	fileNum := atomic.AddUint32(&m.nextId, 1)
	filename := filepath.Join(m.mapDir, fmt.Sprintf("%06d.map", fileNum))
	x.Check(os.MkdirAll(filepath.Dir(filename), 0750))

	return os.OpenFile(filename, os.O_WRONLY|os.O_CREATE|os.O_TRUNC, 0600)
}

func (m *mapper) writeToDisk(buf *z.Buffer) error {
	defer func() {