From 3cffcb2ed845f653c04a18bc4746742435e99300 Mon Sep 17 00:00:00 2001 From: Todd Gruben Date: Mon, 21 Apr 2014 11:19:09 -0500 Subject: [PATCH] low traffic rank --- core/service.go | 2 +- index/brand.go | 7 +++++-- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/core/service.go b/core/service.go index 2d8e5c0c4..c3b51d80c 100644 --- a/core/service.go +++ b/core/service.go @@ -48,7 +48,7 @@ func NewService() *Service { service.WebService = NewWebService(service) service.Index = index.NewFragmentContainer() service.Hold = hold.NewHolder() - service.version = "0.0.24" + service.version = "0.0.25" service.name = "Cruncher" service.PrepareLogging() fmt.Printf("Pilosa %s\n", service.version) diff --git a/index/brand.go b/index/brand.go index b6d8ffe2d..6940da3a5 100644 --- a/index/brand.go +++ b/index/brand.go @@ -139,6 +139,7 @@ func (self *Brand) Rank() { } //dump(self.rankings, 10) + self.rank_count = 0 delta := time.Since(start) util.SendTimer("brand_Rank", delta.Nanoseconds()) self.rank_time = start @@ -188,7 +189,9 @@ func (self *Brand) Store(bitmap_id uint64, bm IBitmap, filter uint64) { } func (self *Brand) TopN(src_bitmap IBitmap, n int, categories []uint64) []Pair { - if self.rank_count > 0 { + if len(self.rankings) < 50 { + self.Rank() + } else if self.rank_count > 0 { last := time.Since(self.rank_time) * time.Second if last > 60 { self.Rank() @@ -202,7 +205,7 @@ func (self *Brand) TopN(src_bitmap IBitmap, n int, categories []uint64) []Pair { } test := self.TopNCat(src_bitmap, n, is) - log.Println("TOPN:", test) + log.Println("TOPN:", test, len(self.rankings)) return test } func dump(r RankList, n int) {