| 271 | } |
| 272 | |
| 273 | func (s *Store) startFileLOCKED() (*FileRef, File, error) { |
| 274 | fname, file, err := s.createNextFileLOCKED() |
| 275 | if err != nil { |
| 276 | return nil, nil, err |
| 277 | } |
| 278 | |
| 279 | if err = s.persistHeader(file); err != nil { |
| 280 | file.Close() |
| 281 | |
| 282 | os.Remove(path.Join(s.dir, fname)) |
| 283 | |
| 284 | return nil, nil, err |
| 285 | } |
| 286 | |
| 287 | fref := &FileRef{file: file, refs: 1} |
| 288 | s.fileRefMap[fname] = fref |
| 289 | |
| 290 | return fref, file, nil |
| 291 | } |
| 292 | |
| 293 | func (s *Store) createNextFileLOCKED() (string, File, error) { |
| 294 | // File to be opened in RDWR mode here because this is either |