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

TimeValue.nsecToMSec介绍

暂无

代码示例

代码示例来源：origin: org.elasticsearch/elasticsearch

/**
 * Resets and returns elapsed time in milliseconds.
 */
public long reset() {
  long nowNS = System.nanoTime();
  try {
    return TimeValue.nsecToMSec(nowNS - startNS);
  } finally {
    startNS = nowNS;
  }
}

代码示例来源：origin: org.elasticsearch/elasticsearch

public ChannelStats() {
  lastAccessedTime = TimeValue.nsecToMSec(System.nanoTime());
}

代码示例来源：origin: org.elasticsearch/elasticsearch

/** Returns elapsed time in millis, or 0 if timer was not started */
public synchronized long time() {
  if (startNanoTime == 0) {
    return 0;
  }
  if (time >= 0) {
    return time;
  }
  return Math.max(0, TimeValue.nsecToMSec(System.nanoTime() - startNanoTime));
}

代码示例来源：origin: org.elasticsearch/elasticsearch

public synchronized void stop() {
  assert stopTime == 0 : "already stopped";
  stopTime = Math.max(System.currentTimeMillis(), startTime);
  time = TimeValue.nsecToMSec(System.nanoTime() - startNanoTime);
  assert time >= 0;
}

代码示例来源：origin: org.elasticsearch/elasticsearch

@Override
public void run() {
  while (running) {
    relativeMillis = TimeValue.nsecToMSec(System.nanoTime());
    absoluteMillis = System.currentTimeMillis();
    try {
      Thread.sleep(interval);
    } catch (InterruptedException e) {
      running = false;
      return;
    }
  }
}

代码示例来源：origin: org.elasticsearch/elasticsearch

/** Deactivate throttling, which switches the lock to be an always-acquirable NoOpLock */
public void deactivate() {
  assert lock != NOOP_LOCK : "throttling deactivated but not active";
  lock = NOOP_LOCK;
  assert startOfThrottleNS > 0 : "Bad state of startOfThrottleNS";
  long throttleTimeNS = System.nanoTime() - startOfThrottleNS;
  if (throttleTimeNS >= 0) {
    // Paranoia (System.nanoTime() is supposed to be monotonic): time slip may have occurred but never want
    // to add a negative number
    throttleTimeMillisMetric.inc(TimeValue.nsecToMSec(throttleTimeNS));
  }
}

代码示例来源：origin: org.elasticsearch/elasticsearch

@Override
public void clusterStateProcessed(String source, ClusterState oldState, ClusterState newState) {
  final long timeoutInMillis = Math.max(0, endTimeMS - TimeValue.nsecToMSec(System.nanoTime()));
  final TimeValue newTimeout = TimeValue.timeValueMillis(timeoutInMillis);
  request.timeout(newTimeout);
  executeHealth(request, listener);
}

代码示例来源：origin: org.elasticsearch/elasticsearch

@Override
public void clusterStateProcessed(String source, ClusterState oldState, ClusterState newState) {
  final long timeoutInMillis = Math.max(0, endTimeMS - TimeValue.nsecToMSec(System.nanoTime()));
  final TimeValue newTimeout = TimeValue.timeValueMillis(timeoutInMillis);
  request.timeout(newTimeout);
  executeHealth(request, listener);
}

代码示例来源：origin: org.elasticsearch/elasticsearch

CachedTimeThread(String name, long interval) {
  super(name);
  this.interval = interval;
  this.relativeMillis = TimeValue.nsecToMSec(System.nanoTime());
  this.absoluteMillis = System.currentTimeMillis();
  this.counter = new TimeCounter();
  setDaemon(true);
}

代码示例来源：origin: org.elasticsearch/elasticsearch

/**
 * Stop the current task. The results are undefined if timing
 * methods are called without invoking at least one pair
 * {@link #start()} / {@link #stop()} methods.
 *
 * @see #start()
 */
public StopWatch stop() throws IllegalStateException {
  if (!this.running) {
    throw new IllegalStateException("Can't stop StopWatch: it's not running");
  }
  long lastTimeNS = System.nanoTime() - this.startTimeNS;
  this.totalTimeNS += lastTimeNS;
  this.lastTaskInfo = new TaskInfo(this.currentTaskName, TimeValue.nsecToMSec(lastTimeNS));
  if (this.keepTaskList) {
    this.taskList.add(lastTaskInfo);
  }
  ++this.taskCount;
  this.running = false;
  this.currentTaskName = null;
  return this;
}

代码示例来源：origin: org.elasticsearch/elasticsearch

long getThrottleTimeInMillis() {
  long currentThrottleNS = 0;
  if (isThrottled() && startOfThrottleNS != 0) {
    currentThrottleNS +=  System.nanoTime() - startOfThrottleNS;
    if (currentThrottleNS < 0) {
      // Paranoia (System.nanoTime() is supposed to be monotonic): time slip must have happened, have to ignore this value
      currentThrottleNS = 0;
    }
  }
  return throttleTimeMillisMetric.count() + TimeValue.nsecToMSec(currentThrottleNS);
}

代码示例来源：origin: org.elasticsearch/elasticsearch

@Override
  public void onTimeout(TimeValue timeout) {
    ObservingContext context = observingContext.getAndSet(null);
    if (context != null) {
      clusterApplierService.removeTimeoutListener(this);
      long timeSinceStartMS = TimeValue.nsecToMSec(System.nanoTime() - startTimeNS);
      logger.trace("observer: timeout notification from cluster service. timeout setting [{}], time since start [{}]",
        timeOutValue, new TimeValue(timeSinceStartMS));
      // update to latest, in case people want to retry
      lastObservedState.set(new StoredState(clusterApplierService.state()));
      timedOut = true;
      context.listener.onTimeout(timeOutValue);
    }
  }
}

代码示例来源：origin: org.elasticsearch/elasticsearch

try {
  for (int i = 0; i < numShards; i++) {
    long timeoutLeftMS = Math.max(0, lockTimeoutMS - TimeValue.nsecToMSec((System.nanoTime() - startTimeNS)));
    allLocks.add(shardLock(new ShardId(index, i), timeoutLeftMS));

代码示例来源：origin: org.elasticsearch/elasticsearch

@Override
public void run() {
  long startTimeNS = System.nanoTime();
  if (logger.isTraceEnabled()) {
    logger.trace("running periodic field data cache cleanup");
  }
  try {
    this.cache.getCache().refresh();
  } catch (Exception e) {
    logger.warn("Exception during periodic field data cache cleanup:", e);
  }
  if (logger.isTraceEnabled()) {
    logger.trace("periodic field data cache cleanup finished in {} milliseconds",
      TimeValue.nsecToMSec(System.nanoTime() - startTimeNS));
  }
  try {
    this.requestCache.cleanCache();
  } catch (Exception e) {
    logger.warn("Exception during periodic request cache cleanup:", e);
  }
  // Reschedule itself to run again if not closed
  if (closed.get() == false) {
    threadPool.schedule(interval, ThreadPool.Names.SAME, this);
  }
}

代码示例来源：origin: org.elasticsearch/elasticsearch

recoveryState.getVerifyIndex().checkIndexTime(Math.max(0, TimeValue.nsecToMSec(System.nanoTime() - timeNS)));

代码示例来源：origin: org.elasticsearch/elasticsearch

TimeValue executionTime = TimeValue.timeValueMillis(Math.max(0, TimeValue.nsecToMSec(currentTimeInNanos() - startTimeNS)));
if (logger.isTraceEnabled()) {
  logger.trace(

代码示例来源：origin: org.elasticsearch/elasticsearch

timeOutValue = this.timeOutValue;
if (timeOutValue != null) {
  long timeSinceStartMS = TimeValue.nsecToMSec(System.nanoTime() - startTimeNS);
  timeoutTimeLeftMS = timeOutValue.millis() - timeSinceStartMS;
  if (timeoutTimeLeftMS <= 0L) {

代码示例来源：origin: org.elasticsearch/elasticsearch

super.doMerge(writer, merge);
} finally {
  long tookMS = TimeValue.nsecToMSec(System.nanoTime() - timeNS);
  totalMergesSizeInBytes.inc(totalSizeInBytes);
  totalMerges.inc(tookMS);
  long stoppedMS = TimeValue.nsecToMSec(
    merge.getMergeProgress().getPauseTimes().get(MergePolicy.OneMergeProgress.PauseReason.STOPPED)
  );
  long throttledMS = TimeValue.nsecToMSec(
    merge.getMergeProgress().getPauseTimes().get(MergePolicy.OneMergeProgress.PauseReason.PAUSED)
  );

代码示例来源：origin: org.elasticsearch/elasticsearch

logger.debug("took {} to load state", TimeValue.timeValueMillis(TimeValue.nsecToMSec(System.nanoTime() - startNS)));
} catch (Exception e) {
  logger.error("failed to read local state, exiting...", e);

代码示例来源：origin: org.elasticsearch/elasticsearch

final ActionListener<ClusterHealthResponse> listener) {
if (request.waitForEvents() != null) {
  final long endTimeMS = TimeValue.nsecToMSec(System.nanoTime()) + request.timeout().millis();
  if (request.local()) {
    clusterService.submitStateUpdateTask("cluster_health (wait_for_events [" + request.waitForEvents() + "])",