diff options
| author | Chris Lu <chris.lu@gmail.com> | 2021-10-04 02:31:38 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2021-10-04 02:31:38 -0700 |
| commit | 947add39e6b2bca54ddc04fd33be28868cae8a0f (patch) | |
| tree | 8217d8cd4caad9516fe9421fd7f23cff44863d79 | |
| parent | 513fed323a86f30996adc8e66f6cf6641b40e77a (diff) | |
| download | seaweedfs-947add39e6b2bca54ddc04fd33be28868cae8a0f.tar.xz seaweedfs-947add39e6b2bca54ddc04fd33be28868cae8a0f.zip | |
clean up *SkipListElementReference loaded from Redis
| -rw-r--r-- | weed/filer/redis3/skiplist_element_store.go | 10 |
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 } |
