diff --git a/internal/worker/vmmanager/synthetic/synthetic.go b/internal/worker/vmmanager/synthetic/synthetic.go index dcd021a..5f41a17 100644 --- a/internal/worker/vmmanager/synthetic/synthetic.go +++ b/internal/worker/vmmanager/synthetic/synthetic.go @@ -124,9 +124,9 @@ func (vm *VM) Start(eventStreamer *client.EventStreamer) { } func (vm *VM) Suspend() <-chan error { + vm.EndpointSet().Stop() vm.HostProcessSet().Stop() - vm.EndpointSet().Stop() errChan := make(chan error, 1) errChan <- nil @@ -141,9 +141,9 @@ func (vm *VM) IP(ctx context.Context) (string, error) { } func (vm *VM) Stop() <-chan error { + vm.EndpointSet().Stop() vm.HostProcessSet().Stop() - vm.EndpointSet().Stop() errChan := make(chan error, 1) errChan <- nil diff --git a/internal/worker/vmmanager/tart/tart.go b/internal/worker/vmmanager/tart/tart.go index b0e157c..c230653 100644 --- a/internal/worker/vmmanager/tart/tart.go +++ b/internal/worker/vmmanager/tart/tart.go @@ -433,9 +433,9 @@ func (vm *VM) IP(ctx context.Context) (string, error) { } func (vm *VM) Suspend() <-chan error { + vm.EndpointSet().Stop() vm.HostProcessSet().Stop() - vm.EndpointSet().Stop() errCh := make(chan error, 1) select { @@ -468,9 +468,9 @@ func (vm *VM) Suspend() <-chan error { } func (vm *VM) Stop() <-chan error { + vm.EndpointSet().Stop() vm.HostProcessSet().Stop() - vm.EndpointSet().Stop() vm.stopMtx.Lock() defer vm.stopMtx.Unlock() if vm.stopDone != nil {