github/ocf
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge pull request #275 from imjfckm/fix-secure-erase-tests

Browse Source 
Fix secure erase tests
This commit is contained in:
Adam Rutkowski 2019-09-19 11:12:14 +02:00 committed by GitHub
commit f988141289
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 41 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

63
tests/functional/tests/security/test_secure_erase.py
View File

@ -86,10 +86,14 @@ def test_secure_erase_simple_io_read_misses(cache_mode):
core = Core.using_device(core_device) core = Core.using_device(core_device)
cache.add_core(core) cache.add_core(core)
write_data = Data.from_string("This is test data") write_data = DataCopyTracer(S.from_sector(1))
io = core.new_io( io = core.new_io(
cache.get_default_queue(), S.from_sector(1).B, write_data.size, cache.get_default_queue(),
IoDir.WRITE, 0, 0 S.from_sector(1).B,
write_data.size,
IoDir.WRITE,
0,
0,
) )
io.set_data(write_data) io.set_data(write_data)
@ -100,10 +104,14 @@ def test_secure_erase_simple_io_read_misses(cache_mode):
cmpls = [] cmpls = []
for i in range(100): for i in range(100):
read_data = Data(500) read_data = DataCopyTracer(S.from_sector(1))
io = core.new_io( io = core.new_io(
cache.get_default_queue(), (i * 1259) % int(core_device.size), cache.get_default_queue(),
read_data.size, IoDir.READ, 0, 0 i * S.from_sector(1).B,
read_data.size,
IoDir.READ,
0,
0,
) )
io.set_data(read_data) io.set_data(read_data)
@ -115,9 +123,9 @@ def test_secure_erase_simple_io_read_misses(cache_mode):
for c in cmpls: for c in cmpls:
c.wait() c.wait()
write_data = Data.from_string("TEST DATA" * 100) write_data = DataCopyTracer.from_string("TEST DATA" * 100)
io = core.new_io( io = core.new_io(
cache.get_default_queue(), 500, write_data.size, IoDir.WRITE, 0, 0 cache.get_default_queue(), S.from_sector(1), write_data.size, IoDir.WRITE, 0, 0
) )
io.set_data(write_data) io.set_data(write_data)
@ -147,6 +155,12 @@ def test_secure_erase_simple_io_cleaning():
""" """
Perform simple IO which will trigger WB cleaning. Track all the data from Perform simple IO which will trigger WB cleaning. Track all the data from
cleaner (locked) and make sure they are erased and unlocked after use. cleaner (locked) and make sure they are erased and unlocked after use.
1. Start cache in WB mode
2. Write single sector at LBA 0
3. Read whole cache line at LBA 0
4. Assert that 3. triggered cleaning
5. Check if all locked Data copies were erased and unlocked
""" """
ctx = OcfCtx( ctx = OcfCtx(
OcfLib.getInstance(), OcfLib.getInstance(),
@ -166,22 +180,27 @@ def test_secure_erase_simple_io_cleaning():
core = Core.using_device(core_device) core = Core.using_device(core_device)
cache.add_core(core) cache.add_core(core)
cmpls = [] read_data = Data(S.from_sector(1).B)
for i in range(10000): io = core.new_io(
read_data = Data(S.from_KiB(120)) cache.get_default_queue(), S.from_sector(1).B, read_data.size, IoDir.WRITE, 0, 0
io = core.new_io( )
cache.get_default_queue(), (i * 1259) % int(core_device.size), io.set_data(read_data)
read_data.size, IoDir.WRITE, 0, 0
)
io.set_data(read_data)
cmpl = OcfCompletion([("err", c_int)]) cmpl = OcfCompletion([("err", c_int)])
io.callback = cmpl.callback io.callback = cmpl.callback
cmpls.append(cmpl) io.submit()
io.submit() cmpl.wait()
for c in cmpls: read_data = Data(S.from_sector(8).B)
c.wait() io = core.new_io(
cache.get_default_queue(), S.from_sector(1).B, read_data.size, IoDir.READ, 0, 0
)
io.set_data(read_data)
cmpl = OcfCompletion([("err", c_int)])
io.callback = cmpl.callback
io.submit()
cmpl.wait()
stats = cache.get_stats() stats = cache.get_stats()