Skip to content

P
plugin
Commit 97bb538d authored by 陈德海's avatar 陈德海
Browse files
Options

pass ci

parent 222453f4
Hide whitespace changes
Inline Side-by-side
Showing with 6 additions and 6 deletions
plugin/mempool/price/cache.go
View file @ 97bb538d
...@@ -27,7 +27,7 @@ func NewQueue(subcfg subConfig) *Queue { ...@@ -27,7 +27,7 @@ func NewQueue(subcfg subConfig) *Queue {
} }
} }
func (cache *Queue) SkipValue(item *mempool.Item) (*skiplist.SkipValue, error) { func (cache *Queue) newSkipValue(item *mempool.Item) (*skiplist.SkipValue, error) {
//tx := item.value //tx := item.value
buf := bytes.NewBuffer(nil) buf := bytes.NewBuffer(nil)
enc := gob.NewEncoder(buf) enc := gob.NewEncoder(buf)
...@@ -68,7 +68,7 @@ func (cache *Queue) Push(item *mempool.Item) error { ...@@ -68,7 +68,7 @@ func (cache *Queue) Push(item *mempool.Item) error {
newEnterTime := types.Now().Unix() newEnterTime := types.Now().Unix()
resendItem := &mempool.Item{Value: item.Value, Priority: item.Value.Fee, EnterTime: newEnterTime} resendItem := &mempool.Item{Value: item.Value, Priority: item.Value.Fee, EnterTime: newEnterTime}
var err error var err error
sv, err := cache.SkipValue(resendItem) sv, err := cache.newSkipValue(resendItem)
if err != nil { if err != nil {
return err return err
} }
...@@ -80,7 +80,7 @@ func (cache *Queue) Push(item *mempool.Item) error { ...@@ -80,7 +80,7 @@ func (cache *Queue) Push(item *mempool.Item) error {
} }
it := &mempool.Item{Value: item.Value, Priority: item.Value.Fee, EnterTime: item.EnterTime} it := &mempool.Item{Value: item.Value, Priority: item.Value.Fee, EnterTime: item.EnterTime}
sv, err := cache.SkipValue(it) sv, err := cache.newSkipValue(it)
if err != nil { if err != nil {
return err return err
} }
......
plugin/mempool/score/cache.go
View file @ 97bb538d
...@@ -27,7 +27,7 @@ func NewQueue(subcfg subConfig) *Queue { ...@@ -27,7 +27,7 @@ func NewQueue(subcfg subConfig) *Queue {
} }
} }
func (cache *Queue) SkipValue(item *mempool.Item) (*skiplist.SkipValue, error) { func (cache *Queue) newSkipValue(item *mempool.Item) (*skiplist.SkipValue, error) {
//tx := item.value //tx := item.value
buf := bytes.NewBuffer(nil) buf := bytes.NewBuffer(nil)
enc := gob.NewEncoder(buf) enc := gob.NewEncoder(buf)
...@@ -69,7 +69,7 @@ func (cache *Queue) Push(item *mempool.Item) error { ...@@ -69,7 +69,7 @@ func (cache *Queue) Push(item *mempool.Item) error {
newEnterTime := types.Now().Unix() newEnterTime := types.Now().Unix()
resendItem := &mempool.Item{Value: item.Value, Priority: item.Value.Fee, EnterTime: newEnterTime} resendItem := &mempool.Item{Value: item.Value, Priority: item.Value.Fee, EnterTime: newEnterTime}
var err error var err error
sv, err := cache.SkipValue(resendItem) sv, err := cache.newSkipValue(resendItem)
if err != nil { if err != nil {
return err return err
} }
...@@ -81,7 +81,7 @@ func (cache *Queue) Push(item *mempool.Item) error { ...@@ -81,7 +81,7 @@ func (cache *Queue) Push(item *mempool.Item) error {
} }
it := &mempool.Item{Value: item.Value, Priority: item.Value.Fee, EnterTime: item.EnterTime} it := &mempool.Item{Value: item.Value, Priority: item.Value.Fee, EnterTime: item.EnterTime}
sv, err := cache.SkipValue(it) sv, err := cache.newSkipValue(it)
if err != nil { if err != nil {
return err return err
} }
......
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