org.ovirt.engine.core.common.businessentities.gluster.GlusterBrickEntity.getAsyncTask()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(9.6k)|赞(0)|评价(0)|浏览(59)

本文整理了Java中org.ovirt.engine.core.common.businessentities.gluster.GlusterBrickEntity.getAsyncTask()方法的一些代码示例，展示了GlusterBrickEntity.getAsyncTask()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。GlusterBrickEntity.getAsyncTask()方法的具体详情如下：
包路径：org.ovirt.engine.core.common.businessentities.gluster.GlusterBrickEntity
类名称：GlusterBrickEntity
方法名：getAsyncTask

GlusterBrickEntity.getAsyncTask介绍

暂无

代码示例

代码示例来源：origin: oVirt/ovirt-engine

private void commitRemoveBricks() {
  if (getConfirmWindow() != null) {
    return;
  }
  ConfirmationModel model = new ConfirmationModel();
  setConfirmWindow(model);
  model.setTitle(ConstantsManager.getInstance().getConstants().commitRemoveBricksTitle());
  model.setMessage(ConstantsManager.getInstance().getConstants().commitRemoveBricksMessage());
  model.setHelpTag(HelpTag.volume_remove_bricks_commit);
  model.setHashName("volume_remove_bricks_commit"); //$NON-NLS-1$
  GlusterVolumeEntity volumeEntity = getVolumeEntity();
  GlusterAsyncTask volumeTask = volumeEntity.getAsyncTask();
  ArrayList<String> list = new ArrayList<>();
  for (GlusterBrickEntity brick : volumeEntity.getBricks()) {
    if (brick.getAsyncTask() != null && volumeTask != null && brick.getAsyncTask().getTaskId() != null
        && brick.getAsyncTask().getTaskId().equals(volumeTask.getTaskId())
        && volumeTask.getStatus() == JobExecutionStatus.FINISHED) {
      list.add(brick.getQualifiedName());
    }
  }
  model.setItems(list);
  UICommand okCommand = UICommand.createDefaultOkUiCommand("OnCommitRemoveBricks", this); //$NON-NLS-1$
  model.getCommands().add(okCommand);
  UICommand cancelCommand = UICommand.createCancelUiCommand("CancelConfirmation", this); //$NON-NLS-1$
  model.getCommands().add(cancelCommand);
}

代码示例来源：origin: oVirt/ovirt-engine

private void retainBricks() {
  if (getConfirmWindow() != null) {
    return;
  }
  ConfirmationModel model = new ConfirmationModel();
  setConfirmWindow(model);
  model.setTitle(ConstantsManager.getInstance().getConstants().retainBricksTitle());
  model.setMessage(ConstantsManager.getInstance().getConstants().retainBricksMessage());
  model.setHelpTag(HelpTag.volume_retain_brick);
  model.setHashName("volume_retain_brick"); //$NON-NLS-1$
  GlusterVolumeEntity volumeEntity = getVolumeEntity();
  GlusterAsyncTask volumeTask = volumeEntity.getAsyncTask();
  ArrayList<String> list = new ArrayList<>();
  for (GlusterBrickEntity brick : volumeEntity.getBricks()) {
    if (brick.getAsyncTask() != null && volumeTask != null && brick.getAsyncTask().getTaskId() != null
        && brick.getAsyncTask().getTaskId().equals(volumeTask.getTaskId())
        && volumeTask.getStatus() == JobExecutionStatus.FINISHED) {
      list.add(brick.getQualifiedName());
    }
  }
  model.setItems(list);
  UICommand okCommand = UICommand.createDefaultOkUiCommand("OnRetainBricks", this); //$NON-NLS-1$
  model.getCommands().add(okCommand);
  UICommand cancelCommand = new UICommand("CancelConfirmation", this); //$NON-NLS-1$
  cancelCommand.setTitle(ConstantsManager.getInstance().getConstants().close());
  cancelCommand.setIsCancel(true);
  model.getCommands().add(cancelCommand);
}

代码示例来源：origin: oVirt/ovirt-engine

if (volume.getAsyncTask() != null && volume.getAsyncTask().getTaskId() != null) {
  bricks.stream()
      .filter(brick -> brick.getAsyncTask() != null &&
                brick.getAsyncTask().getTaskId() != null &&
                brick.getAsyncTask().getTaskId().equals(volume.getAsyncTask().getTaskId()))
      .forEach(brick -> brick.setAsyncTask(volume.getAsyncTask()));

代码示例来源：origin: oVirt/ovirt-engine

private void stopRemoveBricks() {
  if (getConfirmWindow() != null) {
    return;
  }
  ConfirmationModel model = new ConfirmationModel();
  setConfirmWindow(model);
  model.setTitle(ConstantsManager.getInstance().getConstants().stopRemoveBricksTitle());
  model.setMessage(ConstantsManager.getInstance().getConstants().stopRemoveBricksMessage());
  model.setHelpTag(HelpTag.volume_remove_bricks_stop);
  model.setHashName("volume_remove_bricks_stop"); //$NON-NLS-1$
  GlusterVolumeEntity volumeEntity = getVolumeEntity();
  GlusterAsyncTask volumeTask = volumeEntity.getAsyncTask();
  ArrayList<String> list = new ArrayList<>();
  for (GlusterBrickEntity brick : volumeEntity.getBricks()) {
    if (brick.getAsyncTask() != null && volumeTask != null && brick.getAsyncTask().getTaskId() != null
        && brick.getAsyncTask().getTaskId().equals(volumeTask.getTaskId())
        && volumeTask.getStatus() == JobExecutionStatus.STARTED) {
      list.add(brick.getQualifiedName());
    }
  }
  model.setItems(list);
  UICommand okCommand = UICommand.createDefaultOkUiCommand("OnStopRemoveBricks", this); //$NON-NLS-1$
  model.getCommands().add(okCommand);
  UICommand cancelCommand = new UICommand("CancelConfirmation", this); //$NON-NLS-1$
  cancelCommand.setTitle(ConstantsManager.getInstance().getConstants().close());
  cancelCommand.setIsCancel(true);
  model.getCommands().add(cancelCommand);
}

代码示例来源：origin: oVirt/ovirt-engine

List<GlusterBrickEntity> bricks = new ArrayList<>();
for (GlusterBrickEntity brick: volume.getBricks()) {
  if (brick.getAsyncTask()!=null && brick.getAsyncTask().getTaskId()!=null) {
    bricks.add(brick);

代码示例来源：origin: oVirt/ovirt-engine

@Override
public MapSqlParameterMapper<GlusterBrickEntity> getBatchMapper() {
  return entity -> new MapSqlParameterSource()
      .addValue("volume_id", entity.getVolumeId())
      .addValue("server_id", entity.getServerId())
      .addValue("brick_dir", entity.getBrickDirectory())
      .addValue("status", entity.getStatus().name())
      .addValue("id", entity.getId().toString())
      .addValue("brick_order", entity.getBrickOrder())
      .addValue("network_id", entity.getNetworkId())
      .addValue("task_id",
          entity.getAsyncTask().getTaskId() != null ? entity.getAsyncTask()
              .getTaskId()
              .toString()
              : "")
      .addValue("unsynced_entries", entity.getUnSyncedEntries())
      .addValue("unsynced_entries_history",
          StringUtils.join(entity.getUnSyncedEntriesTrend(), ","))
      .addValue("is_arbiter", entity.getIsArbiter());
}

代码示例来源：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 testUpdateBrickTaskByHostIdBrickDir() {
  GlusterBrickEntity existingBrick = dao.getById(FixturesTool.GLUSTER_BRICK_UUID1);
  GlusterAsyncTask asyncTask = new GlusterAsyncTask();
  asyncTask.setTaskId(FixturesTool.GLUSTER_ASYNC_TASK_ID1);
  dao.updateBrickTaskByHostIdBrickDir(existingBrick.getServerId(),
      existingBrick.getBrickDirectory(),
      FixturesTool.GLUSTER_ASYNC_TASK_ID1);
  GlusterBrickEntity newEnity = dao.getById(FixturesTool.GLUSTER_BRICK_UUID1);
  assertEquals(FixturesTool.GLUSTER_ASYNC_TASK_ID1, newEnity.getAsyncTask().getTaskId());
}

代码示例来源：origin: oVirt/ovirt-engine

@Test
public void testUpdateBrickTask() {
  GlusterBrickEntity existingBrick = dao.getById(FixturesTool.GLUSTER_BRICK_UUID1);
  GlusterAsyncTask asyncTask = new GlusterAsyncTask();
  asyncTask.setTaskId(FixturesTool.GLUSTER_ASYNC_TASK_ID1);
  assertNotNull(existingBrick);
  assertEquals(GlusterStatus.UP, existingBrick.getStatus());
  dao.updateBrickTask(existingBrick.getId(), FixturesTool.GLUSTER_ASYNC_TASK_ID1);
  GlusterBrickEntity newEnity = dao.getById(FixturesTool.GLUSTER_BRICK_UUID1);
  assertEquals(FixturesTool.GLUSTER_ASYNC_TASK_ID1, newEnity.getAsyncTask().getTaskId());
}

代码示例来源：origin: oVirt/ovirt-engine

final ArrayList<GlusterBrickEntity> bricks = new ArrayList<>();
for (GlusterBrickEntity brick : volumeEntity.getBricks()) {
  if (brick.getAsyncTask() != null && brick.getAsyncTask().getTaskId() != null) {
    bricks.add(brick);

内容来源于网络，如有侵权，请联系作者删除！

GlusterBrickEntity

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    GlusterBrickEntity类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com