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

band aid

Browse source
This commit is contained in:
Todd Gruben 2014-10-10 17:06:40 +00:00
parent 72b1048134
commit 938995fe36
1 changed files with 11 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
index/fragment_container.go
View file

@ -467,19 +467,19 @@ func (self *Fragment) processCommand(req Command) {
func (self *Fragment) ServeFragment(loadChan chan Command) {
for {
select {
// case req := <-self.requestChan:
// self.processCommand(req)
// default:
// select {
case req := <-self.requestChan:
self.processCommand(req)
default:
select {
case req := <-self.requestChan:
self.processCommand(req)
case req := <-loadChan:
self.processCommand(req)
case wg := <-self.exit:
log.Println("Fragment Shutdown")
self.Persist()
wg.Done()
}
case req := <-loadChan:
self.processCommand(req)
case wg := <-self.exit:
log.Println("Fragment Shutdown")
self.Persist()
wg.Done()
// }
}
}
}