Fixed lint

streamnative · Sep 21, 2024 · a914802 · a914802
1 parent b6ea79e
commit a914802
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/server/wal/wal_ro_segment.go b/server/wal/wal_ro_segment.go
@@ -293,7 +293,7 @@ func (r *readOnlySegmentsGroup) PollHighestSegment() (common.RefCount[ReadOnlySe
 	defer r.Unlock()
 
 	if r.allSegments.Empty() {
-		return nil, nil // nolint: nilnil
+		return nil, nil //nolint: nilnil
 	}
 
 	offset, _ := r.allSegments.Max()

diff --git a/server/wal/wal_rw_segment.go b/server/wal/wal_rw_segment.go
@@ -70,8 +70,8 @@ func newReadWriteSegment(basePath string, baseOffset int64, segmentSize uint32)
 		segmentSize: segmentSize,
 	}
 
-	if pooledBuffer, ok := bufferPool.Get().([]byte); ok {
-		ms.writingIdx = pooledBuffer[:0]
+	if pooledBuffer, ok := bufferPool.Get().(*[]byte); ok {
+		ms.writingIdx = (*pooledBuffer)[:0]
 	} else {
 		// Start with empty slice, though with some initial capacity
 		ms.writingIdx = make([]byte, 0, initialIndexBufferCapacity)
@@ -196,7 +196,7 @@ func (ms *readWriteSegment) Close() error {
 		ms.writeIndex(),
 	)
 
-	bufferPool.Put(ms.writingIdx)
+	bufferPool.Put(&ms.writingIdx)
 	return err
 }