ulib/blktest/blktest.cpp

309 bool create_vmo_helper(int fd, test_vmo_object_t* obj, size_t kBlockSize) {
310     obj->vmo_size = kBlockSize + (rand() % 5) * kBlockSize;
311     ASSERT_EQ(zx_vmo_create(obj->vmo_size, 0, &obj->vmo), ZX_OK,
314     obj->buf.reset(new (&ac) uint8_t[obj->vmo_size]);
316     fill_random(obj->buf.get(), obj->vmo_size);
317     ASSERT_EQ(zx_vmo_write(obj->vmo, obj->buf.get(), 0, obj->vmo_size),
322     ASSERT_EQ(zx_handle_duplicate(obj->vmo, ZX_RIGHT_SAME_RIGHTS, &xfer_vmo), ZX_OK,
324     ASSERT_EQ(ioctl_block_attach_vmo(fd, &xfer_vmo, &obj->vmoid), expected,
333 bool write_striped_vmo_helper(fifo_client_t* client, test_vmo_object_t* obj, size_t i, size_t objs,
336     size_t blocks = obj->vmo_size / kBlockSize;
342         requests[b].vmoid      = obj->vmoid;
354 bool read_striped_vmo_helper(fifo_client_t* client, test_vmo_object_t* obj, size_t i, size_t objs,
358     fbl::unique_ptr<uint8_t[]> out(new (&ac) uint8_t[obj->vmo_size]());
360     ASSERT_EQ(zx_vmo_write(obj->vmo, out.get(), 0, obj->vmo_size),
364     size_t blocks = obj->vmo_size / kBlockSize;
369         requests[b].vmoid      = obj->vmoid;
380     ASSERT_EQ(zx_vmo_read(obj->vmo, out.get(), 0, obj->vmo_size),
382     ASSERT_EQ(memcmp(obj->buf.get(), out.get(), obj->vmo_size), 0,
388 bool close_vmo_helper(fifo_client_t* client, test_vmo_object_t* obj, groupid_t group) {
391     request.vmoid = obj->vmoid;
394     ASSERT_EQ(zx_handle_close(obj->vmo), ZX_OK, "");
437     test_vmo_object_t* obj;
448     test_vmo_object_t* obj = fifoarg->obj;
456     ASSERT_TRUE(create_vmo_helper(fd, obj, kBlockSize), "");
457     ASSERT_TRUE(write_striped_vmo_helper(client, obj, i, objs, group, kBlockSize), "");
458     ASSERT_TRUE(read_striped_vmo_helper(client, obj, i, objs, group, kBlockSize), "");
459     ASSERT_TRUE(close_vmo_helper(client, obj, group), "");
490         thread_args[i].obj = &objs[i];
594     test_vmo_object_t obj;
595     ASSERT_TRUE(create_vmo_helper(fd, &obj, kBlockSize), "");
600     request.vmoid      = static_cast<vmoid_t>(obj.vmoid + 5);
631     test_vmo_object_t obj;
632     ASSERT_TRUE(create_vmo_helper(fd, &obj, kBlockSize * 2), "");
636     request.vmoid      = static_cast<vmoid_t>(obj.vmoid);
669     test_vmo_object_t obj;
670     ASSERT_TRUE(create_vmo_helper(fd, &obj, kBlockSize * 2), "");
674     request.vmoid      = static_cast<vmoid_t>(obj.vmoid);
731     test_vmo_object_t obj;
732     obj.vmo_size = kBlockSize;
733     ASSERT_EQ(zx_vmo_create(obj.vmo_size, 0, &obj.vmo), ZX_OK,
736     obj.buf.reset(new (&ac) uint8_t[obj.vmo_size]);
738     fill_random(obj.buf.get(), obj.vmo_size);
739     ASSERT_EQ(zx_vmo_write(obj.vmo, obj.buf.get(), 0, obj.vmo_size),
742     ASSERT_EQ(zx_handle_duplicate(obj.vmo, ZX_RIGHT_SAME_RIGHTS, &xfer_vmo), ZX_OK,
745     ASSERT_EQ(ioctl_block_attach_vmo(fd, &xfer_vmo, &obj.vmoid), expected,
750     const uint64_t length = 1 + (fbl::round_up(obj.vmo_size,
755     request.vmoid      = static_cast<vmoid_t>(obj.vmoid);