Skip to content

Commit

Permalink
Use forked skiplist impl. (#64)
Browse files Browse the repository at this point in the history
  • Loading branch information
notbdu committed Jan 10, 2019
1 parent 30a48ff commit 1991c4e
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 7 deletions.
10 changes: 5 additions & 5 deletions glide.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

4 changes: 2 additions & 2 deletions storage/shard.go
Original file line number Diff line number Diff line change
Expand Up @@ -13,8 +13,8 @@ import (
"github.com/m3db/m3x/context"
xerrors "github.com/m3db/m3x/errors"
xlog "github.com/m3db/m3x/log"
skiplist "github.com/notbdu/fast-skiplist"
"github.com/pborman/uuid"
skiplist "github.com/sean-public/fast-skiplist"
)

const (
Expand Down Expand Up @@ -159,7 +159,7 @@ func (s *dbShard) QueryRaw(
// TODO(xichen): Find the first element whose max time is greater than or equal
// to start time nanos. This is currently not implemented by the skiplist API.
var sealed []sealedFlushingSegment
geElem := s.sealedByMaxTimeAsc.Get(float64(startNanosInclusive))
geElem := s.sealedByMaxTimeAsc.GetGreaterThanOrEqualTo(float64(startNanosInclusive))
for elem := geElem; elem != nil; elem = elem.Next() {
// Increment accessor count of the immutable segment so it cannot be
// closed before the read finishes.
Expand Down

0 comments on commit 1991c4e

Please sign in to comment.