org.apache.log4j.Logger.isTraceEnabled()方法的使用及代码示例

x33g5p2x  于2022-01-23 转载在 其他  
字(12.1k)|赞(0)|评价(0)|浏览(208)

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

Logger.isTraceEnabled介绍

[英]Check whether this category is enabled for the TRACE Level.
[中]检查是否为跟踪级别启用了此类别。

代码示例

代码示例来源:origin: voldemort/voldemort

/**
 * Add an event to the queue. It will be processed in the order received.
 * 
 * @param event Event
 */
public void addEvent(Event event) {
  if(event == null)
    throw new IllegalStateException("event must be non-null");
  if(logger.isTraceEnabled())
    logger.trace("Adding event " + event);
  eventQueue.add(event);
}

代码示例来源:origin: apache/ignite

/** {@inheritDoc} */
@Override public void trace(String msg) {
  if (!impl.isTraceEnabled())
    warning("Logging at TRACE level without checking if TRACE level is enabled: " + msg);
  impl.trace(msg);
}

代码示例来源:origin: voldemort/voldemort

@Override
  public void execute(Pipeline pipeline) {
    for(Map.Entry<Node, Slop> slopToBeSent: slopsToBeSent.entrySet()) {
      Slop slop = slopToBeSent.getValue();
      Node failedNode = slopToBeSent.getKey();
      if(logger.isTraceEnabled())
        logger.trace("Performing hinted handoff for node " + failedNode + ", store "
               + pipelineData.getStoreName() + "key " + key + ", version" + version);

      hintedHandoff.sendHintParallel(failedNode, version, slop);
    }
    pipeline.addEvent(completeEvent);
  }
}

代码示例来源:origin: voldemort/voldemort

for(SelectionKey sk: selector.keys()) {
  try {
    if(logger.isTraceEnabled())
      logger.trace("Closing SelectionKey's channel");
    if(logger.isTraceEnabled())
      logger.trace("Cancelling SelectionKey");

代码示例来源:origin: voldemort/voldemort

if(logger.isTraceEnabled())
  logger.trace("Shut down SelectorManager thread pool acceptor, waiting "
         + SHUTDOWN_TIMEOUT_MS + " ms for termination");

代码示例来源:origin: voldemort/voldemort

int dataSize = inputStream.readInt();
if(logger.isTraceEnabled())
  logger.trace("In isCompleteRequest, dataSize: " + dataSize + ", buffer position: "
         + buffer.position());
if(logger.isTraceEnabled())
  logger.trace("In isCompleteRequest, probable partial read occurred: " + e);

代码示例来源:origin: voldemort/voldemort

@Override
public Map<ByteArray, List<Versioned<byte[]>>> getAll(Iterable<ByteArray> keys,
                           Map<ByteArray, byte[]> transforms)
    throws VoldemortException {
  StoreUtils.assertValidKeys(keys);
  Map<ByteArray, List<Versioned<byte[]>>> results = null;
  long startTimeNs = -1;
  if(logger.isTraceEnabled())
    startTimeNs = System.nanoTime();
  try {
    results = StoreUtils.getAll(this, keys, transforms);
  } catch(PersistenceFailureException pfe) {
    throw pfe;
  } finally {
    if(logger.isTraceEnabled()) {
      String keyStr = "";
      for(ByteArray key: keys)
        keyStr += key + " ";
      logger.trace("Completed GETALL (" + getName() + ") from keys " + keyStr + " in "
             + (System.nanoTime() - startTimeNs) + " ns at "
             + System.currentTimeMillis());
    }
  }
  return results;
}

代码示例来源:origin: voldemort/voldemort

/**
 * Method to service public recording APIs
 *
 * @param op Operation being tracked
 * @param timeNS Duration of operation
 * @param numEmptyResponses Number of empty responses being sent back,
 *                          i.e.: requested keys for which there were no values (GET and GET_ALL only)
 * @param valueSize Size in bytes of the value
 * @param keySize Size in bytes of the key
 * @param getAllAggregateRequests Total of amount of keys requested in the operation (GET_ALL only)
 */
private void recordTime(Tracked op,
            long timeNS,
            long numEmptyResponses,
            long valueSize,
            long keySize,
            long getAllAggregateRequests) {
  counters.get(op).addRequest(timeNS,
                numEmptyResponses,
                valueSize,
                keySize,
                getAllAggregateRequests);
  if (logger.isTraceEnabled() && !storeName.contains("aggregate") && !storeName.contains("voldsys$"))
    logger.trace("Store '" + storeName + "' logged a " + op.toString() + " request taking " +
        ((double) timeNS / voldemort.utils.Time.NS_PER_MS) + " ms");
}

代码示例来源:origin: voldemort/voldemort

public void requestComplete(Object result, long requestTime) {
    if(logger.isTraceEnabled())
      logger.trace(pipeline.getOperation().getSimpleName()
             + " response received (" + requestTime + " ms.) from node "
             + node.getId());
    Response<ByteArray, Object> response = new Response<ByteArray, Object>(node,
                                        key,
                                        result,
                                        requestTime);
    if(logger.isTraceEnabled()) {
      logger.trace(attemptsLatch.getCount() + " attempts remaining. Will block "
             + " for " + blocksLatch.getCount() + " more ");
    }
    responses.put(node.getId(), response);
    if(response.getValue() instanceof Exception && isOperationCompleted.get()) {
      handleException(response, pipeline);
    }
    attemptsLatch.countDown();
    blocksLatch.countDown();
  }
};

代码示例来源:origin: voldemort/voldemort

@Override
public Map<ByteArray, List<Versioned<byte[]>>> getAll(Iterable<ByteArray> keys,
                           Map<ByteArray, byte[]> transforms)
    throws VoldemortException {
  // TODO Does RocksDB multiget supports atomicity ?
  StoreUtils.assertValidKeys(keys);
  long startTimeNs = -1;
  if(logger.isTraceEnabled())
    startTimeNs = System.nanoTime();
  Map<ByteArray, List<Versioned<byte[]>>> results = null;
  try {
    results = StoreUtils.getAll(this, keys, transforms);
  } catch(PersistenceFailureException e) {
    logger.error(e);
    throw new PersistenceFailureException(e);
  } finally {
    if(logger.isTraceEnabled()) {
      String keyStr = "";
      for(ByteArray key: keys)
        keyStr += key + " ";
      logger.trace("Completed GETALL (" + getName() + ") from keys " + keyStr + " in "
             + (System.nanoTime() - startTimeNs) + " ns at "
             + System.currentTimeMillis());
    }
  }
  return results;
}

代码示例来源:origin: voldemort/voldemort

@Override
protected void write(SelectionKey selectionKey) throws IOException {
  if(!checkTimeout())
    return;
  if(outputStream.getBuffer().hasRemaining()) {
    // If we have data, write what we can now...
    int count = socketChannel.write(outputStream.getBuffer());
    if(logger.isTraceEnabled())
      logger.trace("Wrote " + count + " bytes, remaining: "
             + outputStream.getBuffer().remaining() + " for "
             + socketChannel.socket());
  } else {
    if(logger.isTraceEnabled())
      logger.trace("Wrote no bytes for " + socketChannel.socket());
  }
  // If there's more to write but we didn't write it, we'll take that to
  // mean that we're done here. We don't clear or reset anything. We leave
  // our buffer state where it is and try our luck next time.
  if(outputStream.getBuffer().hasRemaining())
    return;
  resetStreams();
  // If we're not streaming writes, signal the Selector that we're
  // ready to read the next request.
  selectionKey.interestOps(SelectionKey.OP_READ);
}

代码示例来源:origin: voldemort/voldemort

private List<Versioned<byte[]>> getValueForKey(ByteArray key, byte[] transforms)
    throws PersistenceFailureException {
  long startTimeNs = -1;
  if(logger.isTraceEnabled())
    startTimeNs = System.nanoTime();
  List<Versioned<byte[]>> value = null;
  try {
    byte[] result = getRocksDB().get(storeHandle, key.get());
    if(result != null) {
      value = StoreBinaryFormat.fromByteArray(result);
    } else {
      return Collections.emptyList();
    }
  } catch(RocksDBException e) {
    logger.error(e);
    throw new PersistenceFailureException(e);
  } finally {
    if(logger.isTraceEnabled()) {
      logger.trace("Completed GET (" + getName() + ") from key " + key + " (keyRef: "
             + System.identityHashCode(key) + ") in "
             + (System.nanoTime() - startTimeNs) + " ns at "
             + System.currentTimeMillis());
    }
  }
  return value;
}

代码示例来源:origin: voldemort/voldemort

/**
 * Null out current clientRequest before calling complete. timeOut and
 * complete must *not* be within a synchronized block since both eventually
 * check in the client request executor. Such a check in can trigger
 * additional synchronized methods deeper in the stack.
 */
private ClientRequest<?> completeClientRequest() {
  ClientRequest<?> local = atomicNullOutClientRequest();
  if(local == null) {
    return null;
  }
  if(isExpired) {
    local.timeOut();
  }
  else {
    local.complete();
  }
  if(logger.isTraceEnabled())
    logger.trace("Marked client associated with " + socketChannel.socket() + " as complete");
  return local;
}

代码示例来源:origin: voldemort/voldemort

protected void setAvailable(Node node) {
  NodeStatus nodeStatus = getNodeStatus(node);
  if(logger.isTraceEnabled())
    logger.trace("Node " + node.getId() + " set as available");
  // We need to distinguish the case where we're newly available and the
  // case where we're getting redundant availability notices. So let's
  // check the node status before we update it.
  boolean previouslyAvailable = setAvailable(nodeStatus, true);
  // If we were not previously available, we've just switched state,
  // so notify any listeners.
  if(!previouslyAvailable) {
    if(logger.isInfoEnabled())
      logger.info("Node " + node.getId() + " now available");
    synchronized(nodeStatus) {
      nodeStatus.resetNumConsecutiveCatastrophicErrors();
      if(logger.isTraceEnabled()) {
        logger.trace("Resetting # consecutive connect errors for node : " + node);
      }
      nodeStatus.notifyAll();
    }
    for(FailureDetectorListener fdl: listeners.keySet()) {
      try {
        fdl.nodeAvailable(node);
      } catch(Exception e) {
        if(logger.isEnabledFor(Level.WARN))
          logger.warn(e, e);
      }
    }
  }
}

代码示例来源:origin: apache/ignite

/** {@inheritDoc} */
@Override public void trace(String msg) {
  if (!impl.isTraceEnabled())
    warning("Logging at TRACE level without checking if TRACE level is enabled: " + msg);
  impl.trace(msg);
}

代码示例来源:origin: voldemort/voldemort

int count = socketChannel.write(outputStream.getBuffer());
  if(logger.isTraceEnabled())
    logger.trace("Wrote " + count + " bytes, remaining: "
           + outputStream.getBuffer().remaining() + " for "
           + socketChannel.socket());
if(logger.isTraceEnabled())
  logger.trace("Wrote no bytes for " + socketChannel.socket());
if(logger.isTraceEnabled())
  logger.trace("Request is streaming for " + socketChannel.socket());

代码示例来源:origin: voldemort/voldemort

/**
 * Detailed request to track additional data about PUT, GET and GET_ALL
 *
 * @param timeNS The time in nanoseconds that the operation took to complete
 * @param numEmptyResponses For GET and GET_ALL, how many keys were no values found
 * @param valueBytes Total number of bytes across all versions of values' bytes
 * @param keyBytes Total number of bytes in the keys
 * @param getAllAggregatedCount Total number of keys returned for getAll calls
 */
public void addRequest(long timeNS,
            long numEmptyResponses,
            long valueBytes,
            long keyBytes,
            long getAllAggregatedCount) {
  // timing instrumentation (trace only)
  long startTimeNs = 0;
  if(logger.isTraceEnabled()) {
    startTimeNs = System.nanoTime();
  }
  long currentTime = time.milliseconds();
  timeSensor.record((double) timeNS / voldemort.utils.Time.NS_PER_MS, currentTime);
  emptyResponseKeysSensor.record(numEmptyResponses, currentTime);
  valueBytesSensor.record(valueBytes, currentTime);
  keyBytesSensor.record(keyBytes, currentTime);
  getAllKeysCountSensor.record(getAllAggregatedCount, currentTime);
  // timing instrumentation (trace only)
  if(logger.isTraceEnabled()) {
    logger.trace("addRequest took " + (System.nanoTime() - startTimeNs) + " ns.");
  }
}

代码示例来源:origin: voldemort/voldemort

@Override
public synchronized List<Versioned<V>> multiVersionPut(K key, final List<Versioned<V>> values) {
  Boolean result = assertionMap.remove(key);
  if(result == null) {
    if(logger.isTraceEnabled()) {
      logger.trace("PUT key: " + key + " (never asserted) assertionMap size: "
             + assertionMap.size());
    }
  } else {
    if(logger.isDebugEnabled()) {
      logger.debug("PUT key: " + key
             + " (found and fulfills put assertion) assertionMap size: "
             + assertionMap.size());
    }
  }
  List<Versioned<V>> obsoleteVals = super.multiVersionPut(key, values);
  return obsoleteVals;
}

代码示例来源:origin: voldemort/voldemort

if(logger.isTraceEnabled())
    logger.trace(operation.getSimpleName()
           + " request, events complete due to error");
  if(logger.isTraceEnabled())
    logger.trace(operation.getSimpleName() + " request, events complete");
  throw new IllegalStateException("action was null for event " + event);
if(logger.isTraceEnabled())
  logger.trace(operation.getSimpleName() + " request, action "
         + action.getClass().getSimpleName() + " to handle " + event
         + " event");

代码示例来源:origin: voldemort/voldemort

public synchronized void assertPut(K key) throws VoldemortException {
  StoreUtils.assertValidKey(key);
  // delete if exist
  List<Versioned<V>> result = map.remove(key);
  if(result == null || result.size() == 0) {
    // if non-exist, record as assertion
    assertionMap.put(key, true); // use synchronized to avoid race
                   // condition here
    if(logger.isDebugEnabled()) {
      logger.debug("PUT Assertion added (not yet fulfilled) for key: " + key
             + " assertionMap size: " + assertionMap.size());
    }
  } else {
    if(logger.isTraceEnabled()) {
      logger.trace("PUT Assertion added (immediately fulfilled) for key: " + key
             + " assertionMap size: " + assertionMap.size());
    }
  }
}

相关文章