Commit 222453f4 authored by 陈德海's avatar 陈德海

pass ci

parent e892e9e6
...@@ -21,9 +21,9 @@ type Queue struct { ...@@ -21,9 +21,9 @@ type Queue struct {
// NewQueue 创建队列 // NewQueue 创建队列
func NewQueue(subcfg subConfig) *Queue { func NewQueue(subcfg subConfig) *Queue {
return &Queue{ return &Queue{
txMap: make(map[string]*skiplist.SkipValue, subcfg.PoolCacheSize), make(map[string]*skiplist.SkipValue, subcfg.PoolCacheSize),
txList: skiplist.NewSkipList(&skiplist.SkipValue{-1, nil}), skiplist.NewSkipList(&skiplist.SkipValue{Score: -1, Value: nil}),
subConfig: subcfg, subcfg,
} }
} }
......
...@@ -22,7 +22,7 @@ type Queue struct { ...@@ -22,7 +22,7 @@ type Queue struct {
func NewQueue(subcfg subConfig) *Queue { func NewQueue(subcfg subConfig) *Queue {
return &Queue{ return &Queue{
txMap: make(map[string]*skiplist.SkipValue, subcfg.PoolCacheSize), txMap: make(map[string]*skiplist.SkipValue, subcfg.PoolCacheSize),
txList: skiplist.NewSkipList(&skiplist.SkipValue{-1, nil}), txList: skiplist.NewSkipList(&skiplist.SkipValue{Score: -1, Value: nil}),
subConfig: subcfg, subConfig: subcfg,
} }
} }
......
...@@ -39,14 +39,14 @@ type SkipList struct { ...@@ -39,14 +39,14 @@ type SkipList struct {
level int level int
} }
// SkipListIterator 跳跃表迭代器 // Iterator 跳跃表迭代器
type SkipListIterator struct { type Iterator struct {
list *SkipList list *SkipList
node *skipListNode node *skipListNode
} }
// First 获取第一个节点Value值 // First 获取第一个节点Value值
func (sli *SkipListIterator) First() *SkipValue { func (sli *Iterator) First() *SkipValue {
if sli.list.header.next[0] == nil { if sli.list.header.next[0] == nil {
return nil return nil
} }
...@@ -55,7 +55,7 @@ func (sli *SkipListIterator) First() *SkipValue { ...@@ -55,7 +55,7 @@ func (sli *SkipListIterator) First() *SkipValue {
} }
// Last 获取最后一个节点Value值 // Last 获取最后一个节点Value值
func (sli *SkipListIterator) Last() *SkipValue { func (sli *Iterator) Last() *SkipValue {
if sli.list.tail == nil { if sli.list.tail == nil {
return nil return nil
} }
...@@ -80,7 +80,7 @@ func (node *skipListNode) Next() *skipListNode { ...@@ -80,7 +80,7 @@ func (node *skipListNode) Next() *skipListNode {
} }
// Seek 迭代器在跳跃表中查找某个位置在传参后面或者与传参相等的SkipValue // Seek 迭代器在跳跃表中查找某个位置在传参后面或者与传参相等的SkipValue
func (sli *SkipListIterator) Seek(value *SkipValue) *SkipValue { func (sli *Iterator) Seek(value *SkipValue) *SkipValue {
x := sli.list.find(value) x := sli.list.find(value)
if x.next[0] == nil { if x.next[0] == nil {
return nil return nil
...@@ -117,8 +117,8 @@ func randomLevel() int { ...@@ -117,8 +117,8 @@ func randomLevel() int {
} }
// GetIterator 获取迭代器 // GetIterator 获取迭代器
func (sl *SkipList) GetIterator() *SkipListIterator { func (sl *SkipList) GetIterator() *Iterator {
it := &SkipListIterator{} it := &Iterator{}
it.list = sl it.list = sl
it.First() it.First()
return it return it
......
...@@ -6,11 +6,10 @@ import ( ...@@ -6,11 +6,10 @@ import (
"github.com/stretchr/testify/assert" "github.com/stretchr/testify/assert"
) )
var( var (
s1=&SkipValue{1,"111"} s1 = &SkipValue{1, "111"}
s2=&SkipValue{2,"222"} s2 = &SkipValue{2, "222"}
s3=&SkipValue{3,"333"} s3 = &SkipValue{3, "333"}
s4=&SkipValue{4,"444"}
) )
func TestInsert(t *testing.T) { func TestInsert(t *testing.T) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment