utest/ramdisk/ramdisk.cpp

685 bool create_vmo_helper(int fd, test_vmo_object_t* obj, size_t kBlockSize) {
686     obj->vmo_size = kBlockSize + (rand() % 5) * kBlockSize;
687     ASSERT_EQ(zx_vmo_create(obj->vmo_size, 0, &obj->vmo), ZX_OK,
690     obj->buf.reset(new (&ac) uint8_t[obj->vmo_size]);
692     fill_random(obj->buf.get(), obj->vmo_size);
693     ASSERT_EQ(zx_vmo_write(obj->vmo, obj->buf.get(), 0, obj->vmo_size),
698     ASSERT_EQ(zx_handle_duplicate(obj->vmo, ZX_RIGHT_SAME_RIGHTS, &xfer_vmo), ZX_OK,
700     ASSERT_EQ(ioctl_block_attach_vmo(fd, &xfer_vmo, &obj->vmoid), expected,
709 bool write_striped_vmo_helper(const block_client::Client* client, test_vmo_object_t* obj, size_t i,
712     size_t blocks = obj->vmo_size / kBlockSize;
718         requests[b].vmoid      = obj->vmoid;
730 bool read_striped_vmo_helper(const block_client::Client* client, test_vmo_object_t* obj, size_t i,
734     fbl::unique_ptr<uint8_t[]> out(new (&ac) uint8_t[obj->vmo_size]());
736     ASSERT_EQ(zx_vmo_write(obj->vmo, out.get(), 0, obj->vmo_size), ZX_OK);
739     size_t blocks = obj->vmo_size / kBlockSize;
744         requests[b].vmoid      = obj->vmoid;
755     ASSERT_EQ(zx_vmo_read(obj->vmo, out.get(), 0, obj->vmo_size), ZX_OK);
756     ASSERT_EQ(memcmp(obj->buf.get(), out.get(), obj->vmo_size), 0,
762 bool close_vmo_helper(const block_client::Client* client, test_vmo_object_t* obj, groupid_t group) {
765     request.vmoid = obj->vmoid;
768     ASSERT_EQ(zx_handle_close(obj->vmo), ZX_OK);
811     test_vmo_object_t* obj;
822     test_vmo_object_t* obj = fifoarg->obj;
830     ASSERT_TRUE(create_vmo_helper(fd, obj, kBlockSize));
831     ASSERT_TRUE(write_striped_vmo_helper(client, obj, i, objs, group, kBlockSize));
832     ASSERT_TRUE(read_striped_vmo_helper(client, obj, i, objs, group, kBlockSize));
833     ASSERT_TRUE(close_vmo_helper(client, obj, group));
868         thread_args[i].obj = &objs[i];
958     test_vmo_object_t obj;
959     ASSERT_TRUE(create_vmo_helper(ramdisk->fd(), &obj, kBlockSize));
971             requests[b].vmoid      = obj.vmoid;
998     test_vmo_object_t obj;
999     ASSERT_TRUE(create_vmo_helper(ramdisk->fd(), &obj, kBlockSize));
1011         requests[b].vmoid      = obj.vmoid;
1059     test_vmo_object_t obj;
1060     ASSERT_TRUE(create_vmo_helper(ramdisk->fd(), &obj, kBufferSize));
1068     ASSERT_EQ(zx_vmo_read(obj.vmo, originalbuf.get(), 0, kBufferSize), ZX_OK);
1074         requests[i].vmoid      = obj.vmoid;
1089         ASSERT_EQ(zx_vmo_write(obj.vmo, tmpbuf.get(), 0, kBufferSize), ZX_OK);
1096             requests[i].vmoid      = obj.vmoid;
1109         ASSERT_EQ(zx_vmo_read(obj.vmo, tmpbuf.get(), 0, kBufferSize), ZX_OK);
1140     test_vmo_object_t obj;
1141     ASSERT_TRUE(create_vmo_helper(ramdisk->fd(), &obj, kBlockSize));
1146     request.vmoid      = static_cast<vmoid_t>(obj.vmoid + 5);
1176     test_vmo_object_t obj;
1177     ASSERT_TRUE(create_vmo_helper(ramdisk->fd(), &obj, kBlockSize * 2));
1181     request.vmoid      = static_cast<vmoid_t>(obj.vmoid);
1214     test_vmo_object_t obj;
1215     ASSERT_TRUE(create_vmo_helper(ramdisk->fd(), &obj, kBlockSize * 2));
1219     request.vmoid      = static_cast<vmoid_t>(obj.vmoid);
1273     test_vmo_object_t obj;
1274     obj.vmo_size = kBlockSize;
1275     ASSERT_EQ(zx_vmo_create(obj.vmo_size, 0, &obj.vmo), ZX_OK,
1278     obj.buf.reset(new (&ac) uint8_t[obj.vmo_size]);
1280     fill_random(obj.buf.get(), obj.vmo_size);
1281     ASSERT_EQ(zx_vmo_write(obj.vmo, obj.buf.get(), 0, obj.vmo_size),
1284     ASSERT_EQ(zx_handle_duplicate(obj.vmo, ZX_RIGHT_SAME_RIGHTS, &xfer_vmo), ZX_OK,
1287     ASSERT_EQ(ioctl_block_attach_vmo(ramdisk->fd(), &xfer_vmo, &obj.vmoid), expected,
1293     request.vmoid      = static_cast<vmoid_t>(obj.vmoid);