removed executor timing for no longer applicable

This commit is contained in:
Todd Gruben 2015-01-23 17:54:34 +00:00
parent 8e796a5edf
commit c87f3f8632
2 changed files with 2 additions and 4 deletions

View file

@ -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)

View file

@ -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)