@@ -130,7 +130,7 @@ func (v *Virter) VMRun(vmConfig VMConfig) error {
130
130
}
131
131
// end checks
132
132
133
- log .Print ("Create host key" )
133
+ log .Debug ("Create host key" )
134
134
hostkey , err := sshkeys .NewRSAHostKey ()
135
135
if err != nil {
136
136
return fmt .Errorf ("could not create new host key: %w" , err )
@@ -148,26 +148,26 @@ func (v *Virter) VMRun(vmConfig VMConfig) error {
148
148
149
149
log .Debugf ("Using domain XML: %s" , vmXML )
150
150
151
- log .Print ("Define VM" )
151
+ log .Debug ("Define VM" )
152
152
d , err := v .libvirt .DomainDefineXML (vmXML )
153
153
if err != nil {
154
154
return fmt .Errorf ("could not define domain: %w" , err )
155
155
}
156
156
157
- log .Print ("Create boot volume" )
157
+ log .Debug ("Create boot volume" )
158
158
_ , err = v .ImageSpawn (vmConfig .Name , v .provisionStoragePool , vmConfig .Image , vmConfig .BootCapacityKiB )
159
159
if err != nil {
160
160
return err
161
161
}
162
162
163
- log .Print ("Create cloud-init volume" )
163
+ log .Debug ("Create cloud-init volume" )
164
164
_ , err = v .createCIData (vmConfig , hostkey )
165
165
if err != nil {
166
166
return err
167
167
}
168
168
169
169
for _ , d := range vmConfig .Disks {
170
- log .Printf ( "Create volume '%s' " , d .GetName ())
170
+ log .WithField ( "name " , d .GetName ()). Debug ( "Create volume" )
171
171
pool , err := v .lookupPool (d .GetPool ())
172
172
if err != nil {
173
173
return fmt .Errorf ("failed to lookup libvirt pool %s: %w" , d .GetPool (), err )
@@ -188,7 +188,7 @@ func (v *Virter) VMRun(vmConfig VMConfig) error {
188
188
}
189
189
}
190
190
191
- log .Print ("Start VM" )
191
+ log .Debug ("Start VM" )
192
192
err = v .libvirt .DomainCreate (d )
193
193
if err != nil {
194
194
return fmt .Errorf ("could not create (start) domain: %w" , err )
@@ -245,7 +245,7 @@ func (v *Virter) WaitVmReady(ctx context.Context, shellClientBuilder ShellClient
245
245
return nil
246
246
}
247
247
248
- log .Print ("Wait for VM to get ready" )
248
+ log .Debug ("Wait for VM to get ready" )
249
249
250
250
// Using ActualTime breaks the expectation of the unit tests
251
251
// that this code does not sleep, but we work around that by
@@ -254,7 +254,7 @@ func (v *Virter) WaitVmReady(ctx context.Context, shellClientBuilder ShellClient
254
254
return fmt .Errorf ("VM not ready: %w" , err )
255
255
}
256
256
257
- log .Print ("Successfully connected to ready VM" )
257
+ log .Debug ("Successfully connected to ready VM" )
258
258
return nil
259
259
}
260
260
@@ -283,7 +283,7 @@ func (v *Virter) VMRm(vmName string, removeDHCPEntries bool, removeBoot bool) er
283
283
// it is active (running). And only if it is persistent, otherwise the
284
284
// domain is gone and we cannot query what resources it depended on.
285
285
if active > 0 && persistent > 0 {
286
- log .Print ("Stop VM" )
286
+ log .Debug ("Stop VM" )
287
287
err = v .libvirt .DomainDestroy (domain )
288
288
if err != nil {
289
289
return fmt .Errorf ("could not destroy domain: %w" , err )
@@ -318,14 +318,14 @@ func (v *Virter) VMRm(vmName string, removeDHCPEntries bool, removeBoot bool) er
318
318
}
319
319
320
320
if persistent > 0 {
321
- log .Print ("Undefine VM" )
321
+ log .Debug ("Undefine VM" )
322
322
err = v .libvirt .DomainUndefineFlags (domain , libvirt .DomainUndefineNvram )
323
323
if err != nil {
324
324
return fmt .Errorf ("could not undefine domain: %w" , err )
325
325
}
326
326
} else if active > 0 {
327
327
// Stop the VM if we did not stop it previously.
328
- log .Print ("Stop VM" )
328
+ log .Debug ("Stop VM" )
329
329
err = v .libvirt .DomainDestroy (domain )
330
330
if err != nil {
331
331
return fmt .Errorf ("could not destroy domain: %w" , err )
@@ -370,7 +370,7 @@ func (v *Virter) rmSnapshots(domain libvirt.Domain) error {
370
370
}
371
371
372
372
for _ , snapshot := range snapshots {
373
- log .Printf ( "Delete snapshot %v " , snapshot .Name )
373
+ log .WithField ( "name " , snapshot .Name ). Debug ( "Delete snapshot" )
374
374
err = v .libvirt .DomainSnapshotDelete (snapshot , 0 )
375
375
if err != nil {
376
376
return fmt .Errorf ("could not delete snapshot: %w" , err )
@@ -443,14 +443,14 @@ func (v *Virter) vmShutdown(ctx context.Context, afterNotifier AfterNotifier, sh
443
443
}
444
444
445
445
if active != 0 {
446
- log .Printf ("Shut down VM" )
446
+ log .Debug ("Shut down VM" )
447
447
448
448
err = v .libvirt .DomainShutdown (domain )
449
449
if err != nil {
450
450
return fmt .Errorf ("could not shut down domain: %w" , err )
451
451
}
452
452
453
- log .Printf ("Wait for VM to stop" )
453
+ log .Debug ("Wait for VM to stop" )
454
454
}
455
455
456
456
timeout := afterNotifier .After (shutdownTimeout )
@@ -703,7 +703,7 @@ func (v *Virter) VMExecRsync(ctx context.Context, copier netcopy.NetworkCopier,
703
703
g , ctx := errgroup .WithContext (ctx )
704
704
for _ , vmName := range vmNames {
705
705
vmName := vmName
706
- log .Printf (`Copying files via rsync: %s to %s on %s` , rsyncStep .Source , rsyncStep .Dest , vmName )
706
+ log .Debugf (`Copying files via rsync: %s to %s on %s` , rsyncStep .Source , rsyncStep .Dest , vmName )
707
707
g .Go (func () error {
708
708
dest := fmt .Sprintf ("%s:%s" , vmName , rsyncStep .Dest )
709
709
return v .VMExecCopy (ctx , copier , files , dest )
0 commit comments