Method Close

vfs.go:1366–1420

()

}

func (f *VFSFile) Close() error {
	f.logger.Debug("closing file")

	// Stop sync loop and ticker if running (need mutex for syncStop)
	f.mu.Lock()
	if f.syncStop != nil {
		close(f.syncStop)
		f.syncStop = nil
	}
	if f.syncTicker != nil {
		f.syncTicker.Stop()
	}
	f.mu.Unlock()

	// Stop compaction monitors if running
	if f.compactionCancel != nil {
		f.compactionCancel()
		f.compactionWg.Wait()
	}

	// Final sync of dirty pages before closing
	f.mu.Lock()
	if f.writeEnabled && len(f.dirty) > 0 {
		if err := f.syncToRemoteWithLock(); err != nil {
			f.logger.Error("failed to sync on close", "error", err)
		}
	}
	f.mu.Unlock()

	f.cancel()
	f.wg.Wait()

	// Close and remove buffer file if open
	if f.bufferFile != nil {
		f.bufferFile.Close()
		os.Remove(f.bufferPath)
	}

	// Close and remove hydration file
	if f.hydrator != nil {
		if err := f.hydrator.Close(); err != nil {
			f.logger.Warn("failed to close hydration file", "error", err)
		}
	}

	if f.writeEnabled && f.vfs != nil {
		f.vfs.writeMu.Lock()
		if f.vfs.writeFile == f {
			f.vfs.writeFile = nil
		}
		f.vfs.writeMu.Unlock()
	}

	return nil
}

func (f *VFSFile) ReadAt(p []byte, off int64) (n int, err error) {
	f.logger.Debug("reading at", "off", off, "len", len(p))