本文整理了Java中org.ovirt.engine.core.common.businessentities.gluster.GlusterBrickEntity.getUnSyncedEntriesTrend()
方法的一些代码示例,展示了GlusterBrickEntity.getUnSyncedEntriesTrend()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。GlusterBrickEntity.getUnSyncedEntriesTrend()
方法的具体详情如下:
包路径:org.ovirt.engine.core.common.businessentities.gluster.GlusterBrickEntity
类名称:GlusterBrickEntity
方法名:getUnSyncedEntriesTrend
暂无
代码示例来源:origin: oVirt/ovirt-engine
private Double calculateSelfHealEta() {
if (this.getUnSyncedEntries() == null || this.getUnSyncedEntriesTrend() == null
|| this.getUnSyncedEntriesTrend().size() < 2) {
return 0D;
}
// Calculate Heal rate between each entries in the unsynced entries list and calculate the average heal rate.
List<Double> healRates = new ArrayList<>();
for (int index = 0; index < this.getUnSyncedEntriesTrend().size() - 1; index++) {
Integer entries = this.unSyncedEntriesTrend.get(index);
Integer entriesRemaining = this.unSyncedEntriesTrend.get(index + 1);
// -1 is added when fetching heal info fails. We can ignore them for heal rate calculation.
if (entries >= 0 && entriesRemaining >= 0) {
double healRate = ((double) entries - entriesRemaining)
/ (Config.<Integer> getValue(ConfigValues.GlusterRefreshRateHealInfo));
if (healRate > 0) {
healRates.add(healRate);
}
}
}
if (healRates.isEmpty()) {
return 0D;
}
Double healRateSum = 0D;
for (Double healRate : healRates) {
healRateSum += healRate;
}
Double healRateAvg = healRateSum / healRates.size();
return this.getUnSyncedEntries() / healRateAvg;
}
代码示例来源: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());
}
内容来源于网络,如有侵权,请联系作者删除!