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

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

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

  1. /**
  2.  * Add an event to the queue. It will be processed in the order received.
  3.  * 
  4.  * @param event Event
  5.  */
  6. public void addEvent(Event event) {
  7.   if(event == null)
  8.     throw new IllegalStateException("event must be non-null");
  9.   if(logger.isTraceEnabled())
  10.     logger.trace("Adding event " + event);
  11.   eventQueue.add(event);
  12. }

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

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

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

  1. @Override
  2.   public void execute(Pipeline pipeline) {
  3.     for(Map.Entry<Node, Slop> slopToBeSent: slopsToBeSent.entrySet()) {
  4.       Slop slop = slopToBeSent.getValue();
  5.       Node failedNode = slopToBeSent.getKey();
  6.       if(logger.isTraceEnabled())
  7.         logger.trace("Performing hinted handoff for node " + failedNode + ", store "
  8.                + pipelineData.getStoreName() + "key " + key + ", version" + version);
  10.       hintedHandoff.sendHintParallel(failedNode, version, slop);
  11.     }
  12.     pipeline.addEvent(completeEvent);
  13.   }
  14. }

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

  1. for(SelectionKey sk: selector.keys()) {
  2.   try {
  3.     if(logger.isTraceEnabled())
  4.       logger.trace("Closing SelectionKey's channel");
  5.     if(logger.isTraceEnabled())
  6.       logger.trace("Cancelling SelectionKey");

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

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

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

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

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

  1. @Override
  2. public Map<ByteArray, List<Versioned<byte[]>>> getAll(Iterable<ByteArray> keys,
  3.                            Map<ByteArray, byte[]> transforms)
  4.     throws VoldemortException {
  5.   StoreUtils.assertValidKeys(keys);
  6.   Map<ByteArray, List<Versioned<byte[]>>> results = null;
  7.   long startTimeNs = -1;
  8.   if(logger.isTraceEnabled())
  9.     startTimeNs = System.nanoTime();
  10.   try {
  11.     results = StoreUtils.getAll(this, keys, transforms);
  12.   } catch(PersistenceFailureException pfe) {
  13.     throw pfe;
  14.   } finally {
  15.     if(logger.isTraceEnabled()) {
  16.       String keyStr = "";
  17.       for(ByteArray key: keys)
  18.         keyStr += key + " ";
  19.       logger.trace("Completed GETALL (" + getName() + ") from keys " + keyStr + " in "
  20.              + (System.nanoTime() - startTimeNs) + " ns at "
  21.              + System.currentTimeMillis());
  22.     }
  23.   }
  24.   return results;
  25. }

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

  1. /**
  2.  * Method to service public recording APIs
  3.  *
  4.  * @param op Operation being tracked
  5.  * @param timeNS Duration of operation
  6.  * @param numEmptyResponses Number of empty responses being sent back,
  7.  *                          i.e.: requested keys for which there were no values (GET and GET_ALL only)
  8.  * @param valueSize Size in bytes of the value
  9.  * @param keySize Size in bytes of the key
  10.  * @param getAllAggregateRequests Total of amount of keys requested in the operation (GET_ALL only)
  11.  */
  12. private void recordTime(Tracked op,
  13.             long timeNS,
  14.             long numEmptyResponses,
  15.             long valueSize,
  16.             long keySize,
  17.             long getAllAggregateRequests) {
  18.   counters.get(op).addRequest(timeNS,
  19.                 numEmptyResponses,
  20.                 valueSize,
  21.                 keySize,
  22.                 getAllAggregateRequests);
  23.   if (logger.isTraceEnabled() && !storeName.contains("aggregate") && !storeName.contains("voldsys$"))
  24.     logger.trace("Store '" + storeName + "' logged a " + op.toString() + " request taking " +
  25.         ((double) timeNS / voldemort.utils.Time.NS_PER_MS) + " ms");
  26. }

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

  1. public void requestComplete(Object result, long requestTime) {
  2.     if(logger.isTraceEnabled())
  3.       logger.trace(pipeline.getOperation().getSimpleName()
  4.              + " response received (" + requestTime + " ms.) from node "
  5.              + node.getId());
  6.     Response<ByteArray, Object> response = new Response<ByteArray, Object>(node,
  7.                                         key,
  8.                                         result,
  9.                                         requestTime);
  10.     if(logger.isTraceEnabled()) {
  11.       logger.trace(attemptsLatch.getCount() + " attempts remaining. Will block "
  12.              + " for " + blocksLatch.getCount() + " more ");
  13.     }
  14.     responses.put(node.getId(), response);
  15.     if(response.getValue() instanceof Exception && isOperationCompleted.get()) {
  16.       handleException(response, pipeline);
  17.     }
  18.     attemptsLatch.countDown();
  19.     blocksLatch.countDown();
  20.   }
  21. };

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

  1. @Override
  2. public Map<ByteArray, List<Versioned<byte[]>>> getAll(Iterable<ByteArray> keys,
  3.                            Map<ByteArray, byte[]> transforms)
  4.     throws VoldemortException {
  5.   // TODO Does RocksDB multiget supports atomicity ?
  6.   StoreUtils.assertValidKeys(keys);
  7.   long startTimeNs = -1;
  8.   if(logger.isTraceEnabled())
  9.     startTimeNs = System.nanoTime();
  10.   Map<ByteArray, List<Versioned<byte[]>>> results = null;
  11.   try {
  12.     results = StoreUtils.getAll(this, keys, transforms);
  13.   } catch(PersistenceFailureException e) {
  14.     logger.error(e);
  15.     throw new PersistenceFailureException(e);
  16.   } finally {
  17.     if(logger.isTraceEnabled()) {
  18.       String keyStr = "";
  19.       for(ByteArray key: keys)
  20.         keyStr += key + " ";
  21.       logger.trace("Completed GETALL (" + getName() + ") from keys " + keyStr + " in "
  22.              + (System.nanoTime() - startTimeNs) + " ns at "
  23.              + System.currentTimeMillis());
  24.     }
  25.   }
  26.   return results;
  27. }

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

  1. @Override
  2. protected void write(SelectionKey selectionKey) throws IOException {
  3.   if(!checkTimeout())
  4.     return;
  5.   if(outputStream.getBuffer().hasRemaining()) {
  6.     // If we have data, write what we can now...
  7.     int count = socketChannel.write(outputStream.getBuffer());
  8.     if(logger.isTraceEnabled())
  9.       logger.trace("Wrote " + count + " bytes, remaining: "
  10.              + outputStream.getBuffer().remaining() + " for "
  11.              + socketChannel.socket());
  12.   } else {
  13.     if(logger.isTraceEnabled())
  14.       logger.trace("Wrote no bytes for " + socketChannel.socket());
  15.   }
  16.   // If there's more to write but we didn't write it, we'll take that to
  17.   // mean that we're done here. We don't clear or reset anything. We leave
  18.   // our buffer state where it is and try our luck next time.
  19.   if(outputStream.getBuffer().hasRemaining())
  20.     return;
  21.   resetStreams();
  22.   // If we're not streaming writes, signal the Selector that we're
  23.   // ready to read the next request.
  24.   selectionKey.interestOps(SelectionKey.OP_READ);
  25. }

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

  1. private List<Versioned<byte[]>> getValueForKey(ByteArray key, byte[] transforms)
  2.     throws PersistenceFailureException {
  3.   long startTimeNs = -1;
  4.   if(logger.isTraceEnabled())
  5.     startTimeNs = System.nanoTime();
  6.   List<Versioned<byte[]>> value = null;
  7.   try {
  8.     byte[] result = getRocksDB().get(storeHandle, key.get());
  9.     if(result != null) {
  10.       value = StoreBinaryFormat.fromByteArray(result);
  11.     } else {
  12.       return Collections.emptyList();
  13.     }
  14.   } catch(RocksDBException e) {
  15.     logger.error(e);
  16.     throw new PersistenceFailureException(e);
  17.   } finally {
  18.     if(logger.isTraceEnabled()) {
  19.       logger.trace("Completed GET (" + getName() + ") from key " + key + " (keyRef: "
  20.              + System.identityHashCode(key) + ") in "
  21.              + (System.nanoTime() - startTimeNs) + " ns at "
  22.              + System.currentTimeMillis());
  23.     }
  24.   }
  25.   return value;
  26. }

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

  1. /**
  2.  * Null out current clientRequest before calling complete. timeOut and
  3.  * complete must *not* be within a synchronized block since both eventually
  4.  * check in the client request executor. Such a check in can trigger
  5.  * additional synchronized methods deeper in the stack.
  6.  */
  7. private ClientRequest<?> completeClientRequest() {
  8.   ClientRequest<?> local = atomicNullOutClientRequest();
  9.   if(local == null) {
  10.     return null;
  11.   }
  12.   if(isExpired) {
  13.     local.timeOut();
  14.   }
  15.   else {
  16.     local.complete();
  17.   }
  18.   if(logger.isTraceEnabled())
  19.     logger.trace("Marked client associated with " + socketChannel.socket() + " as complete");
  20.   return local;
  21. }

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

  1. protected void setAvailable(Node node) {
  2.   NodeStatus nodeStatus = getNodeStatus(node);
  3.   if(logger.isTraceEnabled())
  4.     logger.trace("Node " + node.getId() + " set as available");
  5.   // We need to distinguish the case where we're newly available and the
  6.   // case where we're getting redundant availability notices. So let's
  7.   // check the node status before we update it.
  8.   boolean previouslyAvailable = setAvailable(nodeStatus, true);
  9.   // If we were not previously available, we've just switched state,
  10.   // so notify any listeners.
  11.   if(!previouslyAvailable) {
  12.     if(logger.isInfoEnabled())
  13.       logger.info("Node " + node.getId() + " now available");
  14.     synchronized(nodeStatus) {
  15.       nodeStatus.resetNumConsecutiveCatastrophicErrors();
  16.       if(logger.isTraceEnabled()) {
  17.         logger.trace("Resetting # consecutive connect errors for node : " + node);
  18.       }
  19.       nodeStatus.notifyAll();
  20.     }
  21.     for(FailureDetectorListener fdl: listeners.keySet()) {
  22.       try {
  23.         fdl.nodeAvailable(node);
  24.       } catch(Exception e) {
  25.         if(logger.isEnabledFor(Level.WARN))
  26.           logger.warn(e, e);
  27.       }
  28.     }
  29.   }
  30. }

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

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

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

  1. int count = socketChannel.write(outputStream.getBuffer());
  2.   if(logger.isTraceEnabled())
  3.     logger.trace("Wrote " + count + " bytes, remaining: "
  4.            + outputStream.getBuffer().remaining() + " for "
  5.            + socketChannel.socket());
  6. if(logger.isTraceEnabled())
  7.   logger.trace("Wrote no bytes for " + socketChannel.socket());
  8. if(logger.isTraceEnabled())
  9.   logger.trace("Request is streaming for " + socketChannel.socket());

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

  1. /**
  2.  * Detailed request to track additional data about PUT, GET and GET_ALL
  3.  *
  4.  * @param timeNS The time in nanoseconds that the operation took to complete
  5.  * @param numEmptyResponses For GET and GET_ALL, how many keys were no values found
  6.  * @param valueBytes Total number of bytes across all versions of values' bytes
  7.  * @param keyBytes Total number of bytes in the keys
  8.  * @param getAllAggregatedCount Total number of keys returned for getAll calls
  9.  */
  10. public void addRequest(long timeNS,
  11.             long numEmptyResponses,
  12.             long valueBytes,
  13.             long keyBytes,
  14.             long getAllAggregatedCount) {
  15.   // timing instrumentation (trace only)
  16.   long startTimeNs = 0;
  17.   if(logger.isTraceEnabled()) {
  18.     startTimeNs = System.nanoTime();
  19.   }
  20.   long currentTime = time.milliseconds();
  21.   timeSensor.record((double) timeNS / voldemort.utils.Time.NS_PER_MS, currentTime);
  22.   emptyResponseKeysSensor.record(numEmptyResponses, currentTime);
  23.   valueBytesSensor.record(valueBytes, currentTime);
  24.   keyBytesSensor.record(keyBytes, currentTime);
  25.   getAllKeysCountSensor.record(getAllAggregatedCount, currentTime);
  26.   // timing instrumentation (trace only)
  27.   if(logger.isTraceEnabled()) {
  28.     logger.trace("addRequest took " + (System.nanoTime() - startTimeNs) + " ns.");
  29.   }
  30. }

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

  1. @Override
  2. public synchronized List<Versioned<V>> multiVersionPut(K key, final List<Versioned<V>> values) {
  3.   Boolean result = assertionMap.remove(key);
  4.   if(result == null) {
  5.     if(logger.isTraceEnabled()) {
  6.       logger.trace("PUT key: " + key + " (never asserted) assertionMap size: "
  7.              + assertionMap.size());
  8.     }
  9.   } else {
  10.     if(logger.isDebugEnabled()) {
  11.       logger.debug("PUT key: " + key
  12.              + " (found and fulfills put assertion) assertionMap size: "
  13.              + assertionMap.size());
  14.     }
  15.   }
  16.   List<Versioned<V>> obsoleteVals = super.multiVersionPut(key, values);
  17.   return obsoleteVals;
  18. }

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

  1. if(logger.isTraceEnabled())
  2.     logger.trace(operation.getSimpleName()
  3.            + " request, events complete due to error");
  4.   if(logger.isTraceEnabled())
  5.     logger.trace(operation.getSimpleName() + " request, events complete");
  6.   throw new IllegalStateException("action was null for event " + event);
  7. if(logger.isTraceEnabled())
  8.   logger.trace(operation.getSimpleName() + " request, action "
  9.          + action.getClass().getSimpleName() + " to handle " + event
  10.          + " event");

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

  1. public synchronized void assertPut(K key) throws VoldemortException {
  2.   StoreUtils.assertValidKey(key);
  3.   // delete if exist
  4.   List<Versioned<V>> result = map.remove(key);
  5.   if(result == null || result.size() == 0) {
  6.     // if non-exist, record as assertion
  7.     assertionMap.put(key, true); // use synchronized to avoid race
  8.                    // condition here
  9.     if(logger.isDebugEnabled()) {
  10.       logger.debug("PUT Assertion added (not yet fulfilled) for key: " + key
  11.              + " assertionMap size: " + assertionMap.size());
  12.     }
  13.   } else {
  14.     if(logger.isTraceEnabled()) {
  15.       logger.trace("PUT Assertion added (immediately fulfilled) for key: " + key
  16.              + " assertionMap size: " + assertionMap.size());
  17.     }
  18.   }
  19. }

内容来源于网络，如有侵权，请联系作者删除！

Logger

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com