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

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

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

GlusterBrickEntity.getStatus介绍

暂无

代码示例

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

public static int countDownBricks(GlusterVolumeEntity volume) {
  int downCount = 0;
  int upCount = 0;
  for (GlusterBrickEntity brick : volume.getBricks()) {
    if (brick.getStatus() == GlusterStatus.UP) {
      upCount++;
    } else {
      downCount++;
    }
    if (upCount > 0 && downCount > 0) {
      return downCount;
    }
  }
  return downCount;
}

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

private boolean isCreateSnapshotAvailable(GlusterVolumeEntity volume) {
  if (volume.getStatus() == GlusterStatus.UP) {
    List<GlusterBrickEntity> bricks = volume.getBricks();
    for (GlusterBrickEntity brick : bricks) {
      if (brick.getStatus() != GlusterStatus.UP) {
        return false;
      }
    }
    return true;
  } else {
    return false;
  }
}

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

@Test
public void testUpdateBrickStatuses() {
  GlusterBrickEntity existingBrick = dao.getById(FixturesTool.GLUSTER_BRICK_UUID1);
  GlusterBrickEntity existingBrick1 = dao.getById(FixturesTool.GLUSTER_BRICK_UUID2);
  assertNotNull(existingBrick);
  assertNotNull(existingBrick1);
  assertEquals(GlusterStatus.UP, existingBrick.getStatus());
  assertEquals(GlusterStatus.UP, existingBrick1.getStatus());
  List<GlusterBrickEntity> bricks = new ArrayList<>();
  bricks.add(existingBrick);
  bricks.add(existingBrick1);
  dao.updateBrickStatuses(bricks);
}

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

@Test
public void testUpdateBrickStatus() {
  GlusterBrickEntity existingBrick = dao.getById(FixturesTool.GLUSTER_BRICK_UUID1);
  assertNotNull(existingBrick);
  assertEquals(GlusterStatus.UP, existingBrick.getStatus());
  dao.updateBrickStatus(FixturesTool.GLUSTER_BRICK_UUID1, GlusterStatus.DOWN);
  existingBrick = dao.getById(FixturesTool.GLUSTER_BRICK_UUID1);
  assertNotNull(existingBrick);
  assertEquals(GlusterStatus.DOWN, existingBrick.getStatus());
}

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

private MapSqlParameterSource createBrickParams(GlusterBrickEntity brick) {
  return getCustomMapSqlParameterSource().addValue("id", brick.getId())
      .addValue("volume_id", brick.getVolumeId())
      .addValue("server_id", brick.getServerId())
      .addValue("brick_dir", brick.getBrickDirectory())
      .addValue("brick_order", (brick.getBrickOrder() == null) ? Integer.valueOf(0) : brick.getBrickOrder())
      .addValue("status", EnumUtils.nameOrNull(brick.getStatus()))
      .addValue("network_id", brick.getNetworkId())
      .addValue("is_arbiter", brick.getIsArbiter());
}

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

@Mapping(from = GlusterBrickEntity.class, to = GlusterBrick.class)
public static GlusterBrick map(GlusterBrickEntity fromBrick, GlusterBrick toBrick) {
  GlusterBrick brick = (toBrick == null) ? new GlusterBrick() : toBrick;
  if(fromBrick.getId() != null) {
    brick.setId(fromBrick.getId().toString());
  }
  if(fromBrick.getServerId() != null) {
    brick.setServerId(fromBrick.getServerId().toString());
  }
  if(StringUtils.isNotEmpty(fromBrick.getQualifiedName())) {
    brick.setName(fromBrick.getQualifiedName());
  }
  if(fromBrick.getBrickDirectory() != null) {
    brick.setBrickDir(fromBrick.getBrickDirectory());
  }
  if(fromBrick.getStatus() != null) {
    brick.setStatus(mapBrickStatus(fromBrick.getStatus()));
  }
  if(fromBrick.getVolumeId() != null) {
    brick.setGlusterVolume(new GlusterVolume());
    brick.getGlusterVolume().setId(fromBrick.getVolumeId().toString());
  }
  return brick;
}

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

@Override
public void replaceBrick(GlusterBrickEntity oldBrick, GlusterBrickEntity newBrick) {
  getCallsHandler().executeModification("UpdateGlusterVolumeBrick",
      getCustomMapSqlParameterSource().addValue("id", oldBrick.getId())
          .addValue("new_id", newBrick.getId())
          .addValue("new_server_id", newBrick.getServerId())
          .addValue("new_brick_dir", newBrick.getBrickDirectory())
          .addValue("new_status", EnumUtils.nameOrNull(newBrick.getStatus()))
          .addValue("new_network_id", newBrick.getNetworkId())
          .addValue("is_arbiter", newBrick.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

public void copyFrom(GlusterBrickEntity brick) {
  setId(brick.getId());
  setVolumeId(brick.getVolumeId());
  setServerId(brick.getServerId());
  setServerName(brick.getServerName());
  setBrickDirectory(brick.getBrickDirectory());
  setBrickOrder(brick.getBrickOrder());
  setUnSyncedEntries(brick.unSyncedEntries);
  setUnSyncedEntriesTrend(brick.getUnSyncedEntriesTrend());
  setStatus(brick.getStatus());
  setIsArbiter(brick.getIsArbiter());
}

代码示例来源: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 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());
}

相关文章