Method Run

internal/runtime/vm/vm.go:1052–1060

Run starts the VM and processes lines coming in on the input channel. When the channel is closed, and the VM has finished processing the VM is shut down and the loader signalled via the given waitgroup.

(lines <-chan *logline.LogLine, wg *sync.WaitGroup)

// the channel is closed, and the VM has finished processing the VM is shut
// down and the loader signalled via the given waitgroup.
func (v *VM) Run(lines <-chan *logline.LogLine, wg *sync.WaitGroup) {
	defer wg.Done()
	glog.V(1).Infof("started VM %q", v.name)
	ctx := context.TODO()
	for line := range lines {
		v.ProcessLogLine(ctx, line)
	}
	glog.Infof("VM %q finished", v.name)
}