@@ -161,12 +161,11 @@ def snapshot_create_producer(
161
161
return value
162
162
163
163
164
- def snapshot_resume_producer (logger , vm_builder , snapshot , snapshot_type , use_ramdisk ):
164
+ def snapshot_resume_producer (logger , vm_builder , snapshot , use_ramdisk ):
165
165
"""Produce results for snapshot resume tests."""
166
166
microvm , metrics_fifo = vm_builder .build_from_snapshot (
167
167
snapshot ,
168
168
resume = True ,
169
- diff_snapshots = snapshot_type == SnapshotType .DIFF ,
170
169
use_ramdisk = use_ramdisk ,
171
170
)
172
171
@@ -205,7 +204,6 @@ def test_older_snapshot_resume_latency(
205
204
restore in current version.
206
205
"""
207
206
logger = logging .getLogger ("old_snapshot_load" )
208
- snapshot_type = SnapshotType .FULL
209
207
jailer = firecracker_release .jailer ()
210
208
fc_version = firecracker_release .base_name ()[1 :]
211
209
logger .info ("Firecracker version: %s" , fc_version )
@@ -229,26 +227,21 @@ def test_older_snapshot_resume_latency(
229
227
disks = [vm .rootfs_file ]
230
228
# Create a snapshot builder from a microvm.
231
229
snapshot_builder = SnapshotBuilder (vm )
232
- snapshot = snapshot_builder .create (
233
- disks , rootfs .ssh_key (), snapshot_type , net_ifaces = [iface ]
234
- )
230
+ snapshot = snapshot_builder .create (disks , rootfs .ssh_key (), net_ifaces = [iface ])
235
231
vm .kill ()
236
232
237
233
st_core .name = "older_snapshot_resume_latency"
238
234
st_core .iterations = SAMPLE_COUNT
239
235
st_core .custom ["guest_config" ] = microvm_cfg .strip (".json" )
240
236
st_core .custom ["io_engine" ] = io_engine
241
- st_core .custom ["snapshot_type" ] = (
242
- "FULL" if snapshot_type == SnapshotType .FULL else "DIFF"
243
- )
237
+ st_core .custom ["snapshot_type" ] = "FULL"
244
238
245
239
prod = producer .LambdaProducer (
246
240
func = snapshot_resume_producer ,
247
241
func_kwargs = {
248
242
"logger" : logger ,
249
243
"vm_builder" : MicrovmBuilder (bin_cloner_path ),
250
244
"snapshot" : snapshot ,
251
- "snapshot_type" : snapshot_type ,
252
245
"use_ramdisk" : False ,
253
246
},
254
247
)
@@ -363,13 +356,11 @@ def test_snapshot_create_latency(
363
356
364
357
365
358
@pytest .mark .parametrize ("guest_mem_mib" , [256 , 512 ])
366
- @pytest .mark .parametrize ("snapshot_type" , [SnapshotType .FULL , SnapshotType .DIFF ])
367
359
def test_snapshot_resume_latency (
368
360
microvm_factory ,
369
361
guest_kernel ,
370
362
rootfs ,
371
363
guest_mem_mib ,
372
- snapshot_type ,
373
364
io_engine ,
374
365
st_core ,
375
366
bin_cloner_path ,
@@ -384,7 +375,6 @@ def test_snapshot_resume_latency(
384
375
TODO: Multiple microvm sizes must be tested in the async pipeline.
385
376
"""
386
377
logger = logging .getLogger ("snapshot_load" )
387
- diff_snapshots = snapshot_type == SnapshotType .DIFF
388
378
vcpus = 2
389
379
microvm_cfg = f"{ vcpus } vcpu_{ guest_mem_mib } mb.json"
390
380
vm = microvm_factory .build (guest_kernel , rootfs , monitor_memory = False )
@@ -393,7 +383,6 @@ def test_snapshot_resume_latency(
393
383
vcpu_count = vcpus ,
394
384
mem_size_mib = guest_mem_mib ,
395
385
use_initrd = True ,
396
- track_dirty_pages = diff_snapshots ,
397
386
rootfs_io_engine = io_engine ,
398
387
)
399
388
iface = NetIfaceConfig ()
@@ -403,30 +392,26 @@ def test_snapshot_resume_latency(
403
392
exit_code , _ , _ = vm .ssh .execute_command ("ls" )
404
393
assert exit_code == 0
405
394
406
- logger .info ("Create %s" , snapshot_type )
407
395
# Create a snapshot builder from a microvm.
408
396
snapshot_builder = SnapshotBuilder (vm )
409
397
disks = [vm .rootfs_file ]
410
398
snapshot = snapshot_builder .create (
411
- disks , rootfs .ssh_key (), snapshot_type , use_ramdisk = True , net_ifaces = [iface ]
399
+ disks , rootfs .ssh_key (), use_ramdisk = True , net_ifaces = [iface ]
412
400
)
413
401
vm .kill ()
414
402
415
403
st_core .name = "snapshot_resume_latency"
416
404
st_core .iterations = SAMPLE_COUNT
417
405
st_core .custom ["guest_config" ] = microvm_cfg .strip (".json" )
418
406
st_core .custom ["io_engine" ] = io_engine
419
- st_core .custom ["snapshot_type" ] = (
420
- "FULL" if snapshot_type == SnapshotType .FULL else "DIFF"
421
- )
407
+ st_core .custom ["snapshot_type" ] = "FULL"
422
408
423
409
prod = producer .LambdaProducer (
424
410
func = snapshot_resume_producer ,
425
411
func_kwargs = {
426
412
"logger" : logger ,
427
413
"vm_builder" : MicrovmBuilder (bin_cloner_path ),
428
414
"snapshot" : snapshot ,
429
- "snapshot_type" : snapshot_type ,
430
415
"use_ramdisk" : True ,
431
416
},
432
417
)
0 commit comments