Move warm VM log statement

synadia-io · Feb 8, 2024 · 8d662cd · 8d662cd
1 parent debaedc
commit 8d662cd
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 6 deletions.
diff --git a/internal/node/machine_mgr.go b/internal/node/machine_mgr.go
@@ -128,13 +128,12 @@ func (m *MachineManager) Start() {
 			}
 
 			go m.awaitHandshake(vm.vmmID)
-			m.log.Info("Adding new VM to warm pool", slog.Any("ip", vm.ip), slog.String("vmid", vm.vmmID))
 
 			m.allVMs[vm.vmmID] = vm
 			m.t.vmCounter.Add(m.ctx, 1)
 
-			// If the pool is full, this line will block until a slot is available.
-			m.warmVMs <- vm
+			m.log.Info("Adding new VM to warm pool", slog.Any("ip", vm.ip), slog.String("vmid", vm.vmmID))
+			m.warmVMs <- vm // If the pool is full, this line will block until a slot is available.
 		}
 	}
 }
@@ -408,4 +407,3 @@ func (m *MachineManager) publishMachineStopped(vm *runningFirecracker) error {
 func (m *MachineManager) stopping() bool {
 	return (atomic.LoadUint32(&m.closing) > 0)
 }
-
diff --git a/internal/node/nodeproxy.go b/internal/node/nodeproxy.go
@@ -78,4 +78,3 @@ func (m *MachineManagerProxy) VMs() map[string]*runningFirecracker {
 func (m *MachineManagerProxy) PoolVMs() chan *runningFirecracker {
 	return m.m.warmVMs
 }
-
diff --git a/internal/node/running_vm.go b/internal/node/running_vm.go
@@ -240,4 +240,3 @@ func getSocketPath(vmmID string) string {
 
 	return filepath.Join(dir, filename)
 }
-