skip to content

detached a5ac8f2

fix(kv): preserve write error wrapping

commit: a5ac8f2141c08ce6228e3e52d6ea48d14a8c9d44
author: brice · 3mo ago · 2026-07-03 21:32 UTC
parent: b5b098c
signature: GPG VerifiedCD88F9E564E0102646FB6077A1A07C7C7C3E349D · arch-gpg Verified for the committer email

1 file · +2 -2

M pkg/kv/kv.go +2 -2


@@ -210,11 +210,11 @@ func (s *Store) appendRecord(op byte, key, val []byte) error {
210	210		}
211	211		if tErr := s.file.Truncate(pos); tErr != nil {
212	212		s.closed = true
213		-	return fmt.Errorf("write failed (%v) and recovery truncate failed: %w", writeErr, tErr)
	213	+	return fmt.Errorf("write failed (%w) and recovery truncate failed: %w", writeErr, tErr)
214	214		}
215	215		if _, sErr := s.file.Seek(pos, io.SeekStart); sErr != nil {
216	216		s.closed = true
217		-	return fmt.Errorf("write failed (%v) and recovery seek failed: %w", writeErr, sErr)
	217	+	return fmt.Errorf("write failed (%w) and recovery seek failed: %w", writeErr, sErr)
218	218		}
219	219		return writeErr
220	220		}


@@ -210,11 +210,11 @@ func (s *Store) appendRecord(op byte, key, val []byte) error {
210		}	210		}
211		if tErr := s.file.Truncate(pos); tErr != nil {	211		if tErr := s.file.Truncate(pos); tErr != nil {
212		s.closed = true	212		s.closed = true
213	-	return fmt.Errorf("write failed (%v) and recovery truncate failed: %w", writeErr, tErr)	213	+	return fmt.Errorf("write failed (%w) and recovery truncate failed: %w", writeErr, tErr)
214		}	214		}
215		if _, sErr := s.file.Seek(pos, io.SeekStart); sErr != nil {	215		if _, sErr := s.file.Seek(pos, io.SeekStart); sErr != nil {
216		s.closed = true	216		s.closed = true
217	-	return fmt.Errorf("write failed (%v) and recovery seek failed: %w", writeErr, sErr)	217	+	return fmt.Errorf("write failed (%w) and recovery seek failed: %w", writeErr, sErr)
218		}	218		}
219		return writeErr	219		return writeErr
220		}	220		}