51 lines
860 B
Go
51 lines
860 B
Go
|
package searchsvc
|
||
|
|
|
||
|
|
import (
|
||
|
|
"context"
|
||
|
|
|
||
|
|
"go.uber.org/zap"
|
||
|
|
)
|
||
|
|
|
||
|
|
func (exec *execCtx) executeOnContainer() {
|
||
|
|
if exec.isLocal() {
|
||
|
|
exec.log.Debug("return result directly")
|
||
|
|
return
|
||
|
|
}
|
||
|
|
|
||
|
|
exec.log.Debug("trying to execute in container...")
|
||
|
|
|
||
|
|
traverser, ok := exec.generateTraverser(exec.containerID())
|
||
|
|
if !ok {
|
||
|
|
return
|
||
|
|
}
|
||
|
|
|
||
|
|
ctx, cancel := context.WithCancel(exec.context())
|
||
|
|
defer cancel()
|
||
|
|
|
||
|
|
loop:
|
||
|
|
for {
|
||
|
|
addrs := traverser.Next()
|
||
|
|
if len(addrs) == 0 {
|
||
|
|
exec.log.Debug("no more nodes, abort placement iteration")
|
||
|
|
break
|
||
|
|
}
|
||
|
|
|
||
|
|
for i := range addrs {
|
||
|
|
select {
|
||
|
|
case <-ctx.Done():
|
||
|
|
exec.log.Debug("interrupt placement iteration by context",
|
||
|
|
zap.String("error", ctx.Err().Error()),
|
||
|
|
)
|
||
|
|
break loop
|
||
|
|
default:
|
||
|
|
}
|
||
|
|
|
||
|
|
// TODO: consider parallel execution
|
||
|
|
exec.processNode(ctx, addrs[i])
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
exec.status = statusOK
|
||
|
|
exec.err = nil
|
||
|
|
}
|