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

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

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

GlusterBrickEntity.getId介绍

[英]Generates the id if not present. Volume brick doesn't have an id in GlusterFS, and hence is generated on the backend side.
[中]如果不存在,则生成id。卷块在GlusterFS中没有id,因此在后端生成。

代码示例

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

/**
 * Generates the id if not present. Volume brick doesn't have an id in
 * GlusterFS, and hence is generated on the backend side.
 * @return id of the brick
 */
@Override
public Guid getId() {
  return getId(true);
}

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

@Override
public Object getQueryableId() {
  return getId();
}

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

/**
 * Update status of all bricks of the given volume to the new status
 */
public void updateBricksStatuses(Guid volumeId, GlusterStatus newStatus) {
  for (GlusterBrickEntity brick : glusterBrickDao.getBricksOfVolume(volumeId)) {
    glusterBrickDao.updateBrickStatus(brick.getId(), newStatus);
  }
}

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

public GlusterBrickEntity getBrickWithId(Guid brickId) {
  for(GlusterBrickEntity brick : getBricks()) {
    if (brick.getId().equals(brickId)) {
      return brick;
    }
  }
  return null;
}

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

@Test
public void testGetBrickByQualifiedName() {
  List<GlusterBrickEntity> bricks = new ArrayList<>();
  bricks.add(brick1);
  bricks.add(brick2);
  bricks.add(brick3);
  GlusterBrickEntity brick = GlusterCoreUtil.getBrickByQualifiedName(bricks, SERVER_1 + ":" + DIR_1);
  assertNotNull(brick);
  assertEquals(brick1.getId(), brick.getId());
}

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

private void populateBrickDetails(GlusterBrickEntity brick) {
  if (brick != null) {
    BrickProperties brickProperties = fetchBrickProperties(brick.getId());
    if (brickProperties != null) {
      BrickDetails brickDetails = new BrickDetails();
      brickDetails.setBrickProperties(brickProperties);
      brick.setBrickDetails(brickDetails);
    }
  }
}

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

@Test
public void testRemoveMultiple() {
  List<GlusterBrickEntity> bricks = dao.getBricksOfVolume(FixturesTool.GLUSTER_VOLUME_UUID1);
  assertEquals(2, bricks.size());
  List<Guid> idsToRemove = new ArrayList<>();
  idsToRemove.add(bricks.get(0).getId());
  idsToRemove.add(bricks.get(1).getId());
  dao.removeAll(idsToRemove);
  bricks = dao.getBricksOfVolume(FixturesTool.GLUSTER_VOLUME_UUID1);
  assertTrue(bricks.isEmpty());
}

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

protected GlusterBrickEntity getBrickEntity(int index, boolean hasDetails) {
  GlusterBrickEntity entity = mock(GlusterBrickEntity.class);
  when(entity.getId()).thenReturn(GUIDS[index]);
  when(entity.getServerId()).thenReturn(serverId);
  when(entity.getBrickDirectory()).thenReturn(GlusterTestHelper.brickDir);
  when(entity.getQualifiedName()).thenReturn(GlusterTestHelper.brickName);
  when(entity.getVolumeId()).thenReturn(volumeId);
  if (hasDetails) {
    BrickDetails brickDetails = mock(BrickDetails.class);
    BrickProperties brickProps = mock(BrickProperties.class);
    MemoryStatus memStatus = mock(MemoryStatus.class);
    MallInfo mallInfo = mock(MallInfo.class);
    when(mallInfo.getArena()).thenReturn(888);
    when(brickProps.getMntOptions()).thenReturn(GlusterTestHelper.BRICK_MNT_OPT);
    when(brickProps.getPort()).thenReturn(GlusterTestHelper.BRICK_PORT);
    when(brickDetails.getMemoryStatus()).thenReturn(memStatus);
    when(memStatus.getMallInfo()).thenReturn(mallInfo);
    when(brickDetails.getBrickProperties()).thenReturn(brickProps);
    when(entity.getBrickDetails()).thenReturn(brickDetails);
  }
  return entity;
}

代码示例来源: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 testGetAllByClusterAndNetworkId() {
    dao.updateBrickNetworkId(FixturesTool.GLUSTER_BRICK_UUID1, FixturesTool.NETWORK_ENGINE);
    List<GlusterBrickEntity> bricks =
        dao.getAllByClusterAndNetworkId(FixturesTool.GLUSTER_CLUSTER_ID, FixturesTool.NETWORK_ENGINE);
    assertNotNull(bricks);
    assertEquals(1, bricks.size());
    assertEquals(FixturesTool.GLUSTER_BRICK_UUID1, bricks.get(0).getId());
  }
}

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

@Override
public GlusterBrickEntity lookupEntity(Guid id) throws BackendFailureException {
  GlusterBrickEntity brickEntity = getEntity(GlusterBrickEntity.class,
      QueryType.GetGlusterBrickById,
      new IdQueryParameters(id),
      null,
      true);
  GlusterVolumeEntity volumeEntity = getEntity(GlusterVolumeEntity.class,
      QueryType.GetGlusterVolumeById,
      new IdQueryParameters(brickEntity.getVolumeId()),
      null,
      true);
  GlusterVolumeAdvancedDetails detailsEntity = getEntity(GlusterVolumeAdvancedDetails.class,
      QueryType.GetGlusterVolumeAdvancedDetails,
      new GlusterVolumeAdvancedDetailsParameters(volumeEntity.getClusterId(),
                            volumeEntity.getId(),
                            brickEntity.getId(), true),
      null,
      true);
  brickEntity.setBrickDetails(detailsEntity.getBrickDetails().get(0));
  return brickEntity;
}

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

protected GlusterBrick populateAdvancedDetails(GlusterBrick model, GlusterBrickEntity entity) {
  GlusterVolumeEntity volumeEntity = getEntity(GlusterVolumeEntity.class,
                         QueryType.GetGlusterVolumeById,
                         new IdQueryParameters(entity.getVolumeId()),
                         null,
                         true);
  GlusterVolumeAdvancedDetails detailsEntity = getEntity(GlusterVolumeAdvancedDetails.class,
                      QueryType.GetGlusterVolumeAdvancedDetails,
                      new GlusterVolumeAdvancedDetailsParameters(volumeEntity.getClusterId(),
                                            volumeEntity.getId(),
                                            entity.getId(), true),
                      null,
                      true);
  model = getMapper(GlusterVolumeAdvancedDetails.class, GlusterBrick.class)
                          .map(detailsEntity, model);
  return model;
}

代码示例来源: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

}, true), volumeEntity.getClusterId(), volumeEntity.getId(), brickEntity.getId());

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

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

@Test
public void testSaveAndGetById() {
  GlusterBrickEntity brickToAdd = new GlusterBrickEntity();
  brickToAdd.setVolumeId(FixturesTool.GLUSTER_VOLUME_UUID1);
  brickToAdd.setServerId(FixturesTool.GLUSTER_SERVER_UUID3);
  brickToAdd.setServerName(FixturesTool.GLUSTER_SERVER_NAME3);
  brickToAdd.setBrickDirectory(BRICK_EXPORT_DIR);
  brickToAdd.setStatus(GlusterStatus.UP);
  brickToAdd.setBrickOrder(0);
  dao.save(brickToAdd);
  GlusterBrickEntity retrievedBrick = dao.getById(brickToAdd.getId());
  assertNotNull(retrievedBrick);
  assertEquals(brickToAdd, retrievedBrick);
}

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

相关文章