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

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

本文整理了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

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());
}

相关文章