scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-09-07 00:55:55 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

changed my hold logic to work with platform

Browse source
This commit is contained in:
Todd Gruben 2014-08-13 15:38:00 +00:00
parent 83685c4e8c
commit 45cf21bcb2
2 changed files with 8 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
core/topn.go
View file

@ -104,11 +104,9 @@ func (self *Service) TopFillHandler(msg *db.Message) { //in order for this to ge
if err != nil {
log.Println("TopFileHandler:", err)
}
// sendmsg := new(db.Message)
// sendmsg.Data = query.BaseQueryResult{Id: &topfill.QueryId, Data: topn}
//sendmsg := db.Message{Data: &query.BaseQueryResult{Id: &topfill.QueryId, Data: topn}}
//self.Transport.Send(&sendmsg, &topfill.ReturnProcessId)
self.Hold.Set(&topfill.QueryId, topn, 30)
result_message := db.Message{Data: query.FillResult{&query.BaseQueryResult{Id: &topfill.QueryId, Data: topn}}}
self.Transport.Send(&result_message, &topfill.ReturnProcessId)
}
func SendRequest(process_id util.GUID, t *Task, service *Service) {

5
query/planner.go
View file

@ -366,6 +366,7 @@ func init() {
gob.Register(DifferenceQueryResult{})
gob.Register(CountQueryResult{})
gob.Register(TopNQueryResult{})
gob.Register(FillResult{})
gob.Register(SetQueryStep{})
gob.Register(GetQueryStep{})
@ -732,3 +733,7 @@ func (qt *RangeQueryTree) getLocation(d *db.Database) (*db.Location, error) {
}
return fragment.GetLocation(), nil
}
type FillResult struct {
*BaseQueryResult
}