From c87f3f8632cd52e14a4b2bf87d249a15b7a16be8 Mon Sep 17 00:00:00 2001 From: Todd Gruben Date: Fri, 23 Jan 2015 17:54:34 +0000 Subject: [PATCH] removed executor timing for no longer applicable --- core/http.go | 3 --- dispatch/dispatch.go | 3 ++- 2 files changed, 2 insertions(+), 4 deletions(-) diff --git a/core/http.go b/core/http.go index 76cddd44c..6425d3707 100644 --- a/core/http.go +++ b/core/http.go @@ -459,7 +459,6 @@ func (self *WebService) HandleSetBit(w http.ResponseWriter, r *http.Request) { t = float64(obj["filter"].(float64)) filter := uint64(t) for bitmap_id := range bitmaps(frame, obj) { - start := time.Now() database := self.service.Cluster.GetOrCreateDatabase(dbs) frag, err := database.GetFragmentFromProfile(frame, profile_id) @@ -481,8 +480,6 @@ func (self *WebService) HandleSetBit(w http.ResponseWriter, r *http.Request) { //result, err := self.service.Executor.RunPQL(db, pql) //pql := fmt.Sprintf("set(%d, %s, %d, %d)", bitmap_id, frame, filter, profile_id) - delta := time.Since(start) - util.SendTimer("executor_setbit", delta.Nanoseconds()) if err != nil { log.Println("Error running set_bit", dbs, frame, profile_id) diff --git a/dispatch/dispatch.go b/dispatch/dispatch.go index 8eddf415d..300080ddc 100644 --- a/dispatch/dispatch.go +++ b/dispatch/dispatch.go @@ -22,6 +22,8 @@ func (self *Dispatch) Close() { log.Println("Shutting down Dispatcher") } +// The Local Route + func (self *Dispatch) Run() { log.Println("Dispatch Run...") for { @@ -38,7 +40,6 @@ func (self *Dispatch) Run() { //jbundle := core.SBResult{v.Bitmap_id, ''v.Frame, v.Filter, v.Profile_id, result} bundle := core.SBResult{v.Bitmap_id, v.Frame, v.Filter, v.Profile_id, result} results = append(results, bundle) - } response := db.Message{Data: core.BitsResponse{Id: &data.QueryId, Items: results}} self.service.Transport.Send(&response, &data.ReturnProcessId)