本文整理了Java中org.ovirt.engine.core.common.businessentities.gluster.GlusterBrickEntity.setAsyncTask()
方法的一些代码示例,展示了GlusterBrickEntity.setAsyncTask()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。GlusterBrickEntity.setAsyncTask()
方法的具体详情如下:
包路径:org.ovirt.engine.core.common.businessentities.gluster.GlusterBrickEntity
类名称:GlusterBrickEntity
方法名:setAsyncTask
暂无
代码示例来源:origin: oVirt/ovirt-engine
brick.getAsyncTask().getTaskId() != null &&
brick.getAsyncTask().getTaskId().equals(volume.getAsyncTask().getTaskId()))
.forEach(brick -> brick.setAsyncTask(volume.getAsyncTask()));
代码示例来源:origin: oVirt/ovirt-engine
@Test
public void testUpdateBrickTasksInBatch() {
GlusterBrickEntity existingBrick1 = dao.getById(FixturesTool.GLUSTER_BRICK_UUID1);
GlusterBrickEntity existingBrick2 = dao.getById(FixturesTool.GLUSTER_BRICK_UUID2);
GlusterAsyncTask asyncTask = new GlusterAsyncTask();
asyncTask.setTaskId(FixturesTool.GLUSTER_ASYNC_TASK_ID1);
assertNotNull(existingBrick1);
assertNotNull(existingBrick2);
assertEquals(GlusterStatus.UP, existingBrick1.getStatus());
assertEquals(GlusterStatus.UP, existingBrick2.getStatus());
existingBrick1.setAsyncTask(asyncTask);
existingBrick2.setAsyncTask(asyncTask);
List<GlusterBrickEntity> bricks = new ArrayList<>();
bricks.add(existingBrick1);
bricks.add(existingBrick2);
dao.updateBrickTasksInBatch(bricks);
GlusterBrickEntity newEnity1 = dao.getById(FixturesTool.GLUSTER_BRICK_UUID1);
GlusterBrickEntity newEnity2 = dao.getById(FixturesTool.GLUSTER_BRICK_UUID2);
assertEquals(FixturesTool.GLUSTER_ASYNC_TASK_ID1, newEnity1.getAsyncTask().getTaskId());
assertEquals(FixturesTool.GLUSTER_ASYNC_TASK_ID1, newEnity2.getAsyncTask().getTaskId());
}
代码示例来源:origin: oVirt/ovirt-engine
@Test
public void testUpdateAllBrickTasksByHostIdBrickDir() {
GlusterBrickEntity existingBrick = dao.getById(FixturesTool.GLUSTER_BRICK_UUID1);
GlusterBrickEntity existingBrick2 = dao.getById(FixturesTool.GLUSTER_BRICK_UUID2);
GlusterAsyncTask asyncTask = new GlusterAsyncTask();
asyncTask.setTaskId(FixturesTool.GLUSTER_ASYNC_TASK_ID1);
GlusterBrickEntity updateBrick = new GlusterBrickEntity();
updateBrick.setBrickDirectory(existingBrick.getBrickDirectory());
updateBrick.setServerId(existingBrick.getServerId());
updateBrick.setAsyncTask(asyncTask);
GlusterBrickEntity updateBrick2 = new GlusterBrickEntity();
updateBrick2.setBrickDirectory(existingBrick2.getBrickDirectory());
updateBrick2.setServerId(existingBrick2.getServerId());
updateBrick2.setAsyncTask(asyncTask);
List<GlusterBrickEntity> bricks = new ArrayList<>();
bricks.add(updateBrick);
bricks.add(updateBrick2);
dao.updateAllBrickTasksByHostIdBrickDirInBatch(bricks);
GlusterBrickEntity newEntity1 = dao.getById(FixturesTool.GLUSTER_BRICK_UUID1);
GlusterBrickEntity newEntity2 = dao.getById(FixturesTool.GLUSTER_BRICK_UUID1);
assertEquals(FixturesTool.GLUSTER_ASYNC_TASK_ID1, newEntity1.getAsyncTask().getTaskId());
assertEquals(FixturesTool.GLUSTER_ASYNC_TASK_ID1, newEntity2.getAsyncTask().getTaskId());
}
代码示例来源:origin: oVirt/ovirt-engine
@Test
public void testReplaceBrick() {
GlusterBrickEntity firstBrick = dao.getById(FixturesTool.GLUSTER_BRICK_UUID1);
assertNotNull(firstBrick);
GlusterBrickEntity newBrick = new GlusterBrickEntity();
newBrick.setVolumeId(FixturesTool.GLUSTER_VOLUME_UUID1);
newBrick.setServerId(FixturesTool.GLUSTER_SERVER_UUID3);
newBrick.setServerName(FixturesTool.GLUSTER_SERVER_NAME3);
newBrick.setBrickDirectory(BRICK_EXPORT_DIR);
GlusterAsyncTask asyncTask = new GlusterAsyncTask();
asyncTask.setTaskId(FixturesTool.GLUSTER_ASYNC_TASK_ID1);
newBrick.setAsyncTask(asyncTask);
newBrick.setStatus(GlusterStatus.UP);
newBrick.setBrickOrder(0);
assertNull(dao.getById(newBrick.getId()));
dao.replaceBrick(firstBrick, newBrick);
assertNull(dao.getById(FixturesTool.GLUSTER_BRICK_UUID1));
GlusterBrickEntity retrievedBrick = dao.getById(newBrick.getId());
assertNotNull(retrievedBrick);
assertEquals(newBrick, retrievedBrick);
}
内容来源于网络,如有侵权,请联系作者删除!