aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2021-10-04 02:31:38 -0700
committerChris Lu <chris.lu@gmail.com>2021-10-04 02:31:38 -0700
commit947add39e6b2bca54ddc04fd33be28868cae8a0f (patch)
tree8217d8cd4caad9516fe9421fd7f23cff44863d79
parent513fed323a86f30996adc8e66f6cf6641b40e77a (diff)
downloadseaweedfs-947add39e6b2bca54ddc04fd33be28868cae8a0f.tar.xz
seaweedfs-947add39e6b2bca54ddc04fd33be28868cae8a0f.zip
clean up *SkipListElementReference loaded from Redis
-rw-r--r--weed/filer/redis3/skiplist_element_store.go10
1 files changed, 10 insertions, 0 deletions
diff --git a/weed/filer/redis3/skiplist_element_store.go b/weed/filer/redis3/skiplist_element_store.go
index fa13d35e9..66a5408d6 100644
--- a/weed/filer/redis3/skiplist_element_store.go
+++ b/weed/filer/redis3/skiplist_element_store.go
@@ -48,5 +48,15 @@ func (m *SkipListElementStore) LoadElement(id int64) (*skiplist.SkipListElement,
}
t := &skiplist.SkipListElement{}
err = proto.Unmarshal([]byte(data), t)
+ if err == nil {
+ for i:=0;i<len(t.Next);i++{
+ if t.Next[i].IsNil() {
+ t.Next[i] = nil
+ }
+ }
+ if t.Prev.IsNil() {
+ t.Prev = nil
+ }
+ }
return t, err
}