本文整理了Java中org.ovirt.engine.core.common.businessentities.gluster.GlusterBrickEntity.getBrickDirectory()
方法的一些代码示例,展示了GlusterBrickEntity.getBrickDirectory()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。GlusterBrickEntity.getBrickDirectory()
方法的具体详情如下:
包路径:org.ovirt.engine.core.common.businessentities.gluster.GlusterBrickEntity
类名称:GlusterBrickEntity
方法名:getBrickDirectory
暂无
代码示例来源:origin: oVirt/ovirt-engine
/**
* Checks if a brick with given server id and brick directory exists in the given collection of bricks, and returns
* it if found.
*/
public static GlusterBrickEntity findBrick(Collection<GlusterBrickEntity> bricks, Guid serverId, String brickDir) {
for (GlusterBrickEntity brick : bricks) {
if (brick.getServerId().equals(serverId)
&& brick.getBrickDirectory().equals(brickDir)) {
return brick;
}
}
return null;
}
}
代码示例来源:origin: oVirt/ovirt-engine
/**
* Checks if given brick <code>searchBrick</code> exists in the given collection of bricks, and returns it if found. Note that this method
* checks only two (and most important) attributes of the brick: server id and brick directory.
*
* @return the brick if found in the <code>bricks</code> collection, else null.
*/
public static GlusterBrickEntity findBrick(Collection<GlusterBrickEntity> bricks, GlusterBrickEntity searchBrick) {
return findBrick(bricks, searchBrick.getServerId(), searchBrick.getBrickDirectory());
}
代码示例来源: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
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
&& existingBrick.getBrickDirectory().equals(brickEntity.getBrickDirectory())) {
setMessage(ConstantsManager.getInstance().getConstants().duplicateBrickMsg());
return;
代码示例来源:origin: oVirt/ovirt-engine
@Test
public void testGetBrickByServerIdAndDirectory() {
GlusterBrickEntity brick =
dao.getBrickByServerIdAndDirectory(FixturesTool.GLUSTER_BRICK_SERVER1, FixturesTool.GLUSTER_BRICK_DIR1);
assertNotNull(brick);
assertEquals(FixturesTool.GLUSTER_BRICK_SERVER1, brick.getServerId());
assertEquals(FixturesTool.GLUSTER_BRICK_DIR1, brick.getBrickDirectory());
}
代码示例来源: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
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
@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 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
@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());
}
内容来源于网络,如有侵权,请联系作者删除!