本文整理了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
[英]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);
}
内容来源于网络,如有侵权,请联系作者删除!