diff --git a/index/fragment_container.go b/index/fragment_container.go index e03e3a4cb..36d301ce6 100644 --- a/index/fragment_container.go +++ b/index/fragment_container.go @@ -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() + // } } } }