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

remove some comments

Browse source
This commit is contained in:
travisturner 2014-01-03 17:17:50 -06:00
parent 7fc18eca93
commit 06cfd62025
3 changed files with 4 additions and 22 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
db/topology.go
View file

@ -16,19 +16,11 @@ var SliceDoesNotExistError = errors.New("Slice does not exist.")
var FragmentDoesNotExistError = errors.New("Fragment does not exist.")
var FrameSliceIntersectDoesNotExistError = errors.New("FrameSliceIntersect does not exist.")
/*
type Location struct {
Ip string
Port int
}
*/
type Location struct {
ProcessId *uuid.UUID
FragmentId util.SUUID
}
type ProcessId *uuid.UUID
type Process struct {
id *uuid.UUID
host string

2
dispatch/dispatch.go
View file

@ -32,7 +32,7 @@ func (self *Dispatch) Run() {
switch message.Data.(type) {
case query.GetQueryStep, query.SetQueryStep:
fmt.Println("GET/SET QUERYSTEP")
self.service.Executor.NewJob(message)
go self.service.Executor.NewJob(message)
default:
fmt.Println("unknown")
}

16
executor/executor.go
View file

@ -23,7 +23,6 @@ type Executor struct {
service *core.Service
inbox chan *db.Message
qs_chan chan *query.QueryStep
hold map[*uuid.UUID]chan *query.QueryResults
}
func (self *Executor) Init() error {
@ -36,11 +35,8 @@ func (self *Executor) Close() {
}
func (self *Executor) NewJob(job *db.Message) {
//j := Job{qp, results}
//self.inbox <- &j
spew.Dump("NewJob")
spew.Dump(job.Data)
// TODO: switch on job.Data type
switch job.Data.(type) {
case query.GetQueryStep:
@ -65,8 +61,9 @@ func (self *Executor) NewJob(job *db.Message) {
spew.Dump(err)
}
spew.Dump(count)
spew.Dump(qs.Id)
//self.Set(job.Data.Id, query_results)
//self.Set(qs.Id, count)
case query.SetQueryStep:
fmt.Println("SET QUERYSTEP")
//self.Get()
@ -76,13 +73,6 @@ func (self *Executor) NewJob(job *db.Message) {
}
}
/*
func (self *Executor) NewJob(qp *query.QueryPlan, results chan *query.QueryResults) {
j := Job{qp, results}
self.inbox <- &j
}
*/
func (self *Executor) NewQS(qs *query.QueryStep) {
self.qs_chan <- qs
}
@ -168,5 +158,5 @@ func (self *Executor) Run() {
}
func NewExecutor(service *core.Service) *Executor {
return &Executor{service, make(chan *db.Message), make(chan *query.QueryStep), make(map[*uuid.UUID]chan *query.QueryResults)}
return &Executor{service, make(chan *db.Message), make(chan *query.QueryStep)}
}