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

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

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

Logger.isDebugEnabled介绍

暂无

代码示例

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

  1. private Socket applySettings(Socket s) throws IOException {
  2.   if(logger.isDebugEnabled())
  3.     logger.debug("Attempting to set socket receive buffer of "
  4.            + this.socketReceiveBufferSize + " bytes");
  5.   s.setReceiveBufferSize(socketReceiveBufferSize);
  6.   s.setSoTimeout(socketTimeout);
  7.   if(logger.isDebugEnabled())
  8.     logger.info("Actually set socket receive buffer to " + s.getReceiveBufferSize()
  9.           + " bytes");
  10.   return s;
  11. }

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

  1. public SelectorManagerWorker(Selector selector,
  2.                SocketChannel socketChannel,
  3.                int socketBufferSize) {
  4.   this.selector = selector;
  5.   this.socketChannel = socketChannel;
  6.   this.socketBufferSize = socketBufferSize;
  7.   this.resizeThreshold = socketBufferSize * 2; // This is arbitrary...
  8.   this.createTimestamp = System.nanoTime();
  9.   this.isClosed = new AtomicBoolean(false);
  10.   if(logger.isDebugEnabled())
  11.     logger.debug("Accepting remote connection from " + socketChannel.socket());
  12. }

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

  1. protected void closeInternal() {
  2.   if(logger.isDebugEnabled())
  3.     logger.debug("Closing remote connection from " + socketChannel.socket());
  4.   try {
  5.     socketChannel.socket().close();
  6.   } catch(IOException e) {
  7.     if(logger.isEnabledFor(Level.WARN))
  8.       logger.warn(e.getMessage(), e);
  9.   }
  10.   try {
  11.     socketChannel.close();
  12.   } catch(IOException e) {
  13.     if(logger.isEnabledFor(Level.WARN))
  14.       logger.warn(e.getMessage(), e);
  15.   }
  16.   SelectionKey selectionKey = socketChannel.keyFor(selector);
  17.   if(selectionKey != null) {
  18.     try {
  19.       selectionKey.attach(null);
  20.       selectionKey.cancel();
  21.     } catch(Exception e) {
  22.       if(logger.isEnabledFor(Level.WARN))
  23.         logger.warn(e.getMessage(), e);
  24.     }
  25.   }
  26.   // close the streams, so we account for comm buffer frees
  27.   IOUtils.closeQuietly(inputStream);
  28.   IOUtils.closeQuietly(outputStream);
  29. }

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

  1. @Override
  2. public List<Node> routeRequest(byte[] key) {
  3.   List<Integer> partitionList = getPartitionList(key);
  4.   if(partitionList.size() == 0)
  5.     return new ArrayList<Node>(0);
  6.   // pull out the nodes corresponding to the target partitions
  7.   List<Node> preferenceList = new ArrayList<Node>(partitionList.size());
  8.   for(int partition: partitionList) {
  9.     preferenceList.add(partitionToNode[partition]);
  10.   }
  11.   if(logger.isDebugEnabled()) {
  12.     List<Integer> nodeIdList = new ArrayList<Integer>();
  13.     for(int partition: partitionList) {
  14.       nodeIdList.add(partitionToNode[partition].getId());
  15.     }
  16.     logger.debug("Key " + ByteUtils.toHexString(key) + " mapped to Nodes " + nodeIdList
  17.            + " Partitions " + partitionList);
  18.   }
  19.   return preferenceList;
  20. }

代码示例来源：origin: alibaba/cobar

  1. @Override
  2. public void error(int errCode, Throwable t) {
  3.   // 根据异常类型和信息，选择日志输出级别。
  4.   if (t instanceof EOFException) {
  5.     if (LOGGER.isDebugEnabled()) {
  6.       LOGGER.debug(toString(), t);
  7.     }
  8.   } else if (isConnectionReset(t)) {
  9.     if (LOGGER.isInfoEnabled()) {
  10.       LOGGER.info(toString(), t);
  11.     }
  12.   } else {
  13.     LOGGER.warn(toString(), t);
  14.   }
  15.   // 异常返回码处理
  16.   switch (errCode) {
  17.   case ErrorCode.ERR_HANDLE_DATA:
  18.     String msg = t.getMessage();
  19.     writeErrMessage(ErrorCode.ER_YES, msg == null ? t.getClass().getSimpleName() : msg);
  20.     break;
  21.   default:
  22.     close();
  23.   }
  24. }

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

  1. /**
  2.  * Persists the current set of versions buffered for the current key into
  3.  * storage, using the multiVersionPut api
  4.  * 
  5.  * NOTE: Now, it could be that the stream broke off and has more pending
  6.  * versions. For now, we simply commit what we have to disk. A better design
  7.  * would rely on in-stream markers to do the flushing to storage.
  8.  */
  9. private void writeBufferedValsToStorage() {
  10.   List<Versioned<byte[]>> obsoleteVals = storageEngine.multiVersionPut(currBufferedKey,
  11.                                      currBufferedVals);
  12.   // log Obsolete versions in debug mode
  13.   if(logger.isDebugEnabled() && obsoleteVals.size() > 0) {
  14.     logger.debug("updateEntries (Streaming multi-version-put) rejected these versions as obsolete : "
  15.            + StoreUtils.getVersions(obsoleteVals) + " for key " + currBufferedKey);
  16.   }
  17.   currBufferedVals = new ArrayList<Versioned<byte[]>>(VALS_BUFFER_EXPECTED_SIZE);
  18. }

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

  1. @Override
  2. public void requestComplete(Object result, long requestTime) {
  3.   Slop slop = null;
  4.   boolean loggerDebugEnabled = logger.isDebugEnabled();
  5.   if(loggerDebugEnabled) {
  6.     slop = slopSerializer.toObject(slopVersioned.getValue());
  7.     && !(response.getValue() instanceof ObsoleteVersionException)) {
  8.     if(!failedNodes.contains(node))
  9.       failedNodes.add(node);
  10.     if(response.getValue() instanceof UnreachableStoreException) {
  11.       UnreachableStoreException use = (UnreachableStoreException) response.getValue();
  12.         logger.debug("Write of key " + slop.getKey() + " for "
  13.                + slop.getNodeId() + " to node " + node
  14.                + " failed due to unreachable: " + use.getMessage());
  15.     logger.debug("Slop write of key " + slop.getKey() + " for node "
  16.            + slop.getNodeId() + " to node " + node + " succeeded in "
  17.            + (System.nanoTime() - startNs) + " ns");

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

  1. if(parseAndValidateRequest()) {
  2.   if(this.isGetVersionRequest) {
  3.     if(logger.isDebugEnabled()) {
  4.       debugLog("GET_VERSION", System.currentTimeMillis());
  5.                                             this.parsedRoutingType);
  6.   } else if(this.parsedKeys.size() > 1) {
  7.     if(logger.isDebugEnabled()) {
  8.       debugLog("GET_ALL", System.currentTimeMillis());
  9.                                           this.parsedRoutingType);
  10.   } else {
  11.     if(logger.isDebugEnabled()) {
  12.       debugLog("GET", System.currentTimeMillis());

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

  1. || this.parsedVectorClock.getEntries().size() == 0) {
  2.   if(logger.isDebugEnabled()) {
  3.     debugLog("PUT", System.currentTimeMillis());
  4.                                     this.parsedRoutingType);
  5. } else {
  6.   if(logger.isDebugEnabled()) {
  7.     debugLog("PUT_VERSION", System.currentTimeMillis());
  8. logger.error("Error when parsing value. Value cannot be null.");
  9. RestErrorHandler.writeErrorResponse(messageEvent,
  10.                   HttpResponseStatus.BAD_REQUEST,

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

  1. nodeIdList = this.storeInstance.getReplicationNodeList(masterPartitionId);
  2. } catch(Exception exception) {
  3.   logger.info("Aborting fixKey due to bad init.");
  4.   if(logger.isDebugEnabled()) {
  5.     exception.printStackTrace();
  6.   if(toReadRepair.size() == 0) {
  7.     logger.trace("Nothing to repair");

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

  1. if(logger.isDebugEnabled()) {
  2.   logger.debug("Incoming get request");
  3.                             null);
  4.   if(versionedValues.size() > 0) {
  5.     GetResponseSender responseConstructor = new GetResponseSender(messageEvent,
  6.                                    requestObject.getKey(),
  7.     logger.error("Error when doing get. Key does not exist");
  8.     RestErrorHandler.writeErrorResponse(messageEvent,
  9.                       NOT_FOUND,
  10. if(logger.isDebugEnabled()) {
  11.   logger.debug("Incoming get all request");
  12.     if(values.size() > 0) {
  13.       hasAtleastOneValidKey = true;
  14.       break;
  15. if(logger.isDebugEnabled()) {
  16.   logger.debug("Incoming put request");
  17. if(logger.isDebugEnabled()) {
  18. if(logger.isDebugEnabled()) {

代码示例来源：origin: brianfrankcooper/YCSB

  1. @Override
  2. public Status delete(String table, String key) {
  3.  if (LOGGER.isDebugEnabled()) {
  4.   LOGGER.debug("deletekey: " + key + " from table: " + table);
  5.  }
  6.  DeleteItemRequest req = new DeleteItemRequest(table, createPrimaryKey(key));
  7.  try {
  8.   dynamoDB.deleteItem(req);
  9.  } catch (AmazonServiceException ex) {
  10.   LOGGER.error(ex);
  11.   return Status.ERROR;
  12.  } catch (AmazonClientException ex) {
  13.   LOGGER.error(ex);
  14.   return CLIENT_ERROR;
  15.  }
  16.  return Status.OK;
  17. }

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

  1. badKeyWriterService = Executors.newSingleThreadExecutor();
  2. badKeyWriterService.submit(new BadKeyWriter(badKeyFileOut, badKeyQOut));
  3. logger.info("Created badKeyWriter.");
  4.                         blockingQ,
  5.                         rejectedExecutionHandler);
  6. logger.info("Created ConsistencyFixWorker pool.");
  7. logger.info("Created badKeyReader.");
  8.   logger.info("Bad key writer service has shutdown.");
  9. } catch(InterruptedException e) {
  10.   logger.error("InterruptedException caught.");
  11.   if(logger.isDebugEnabled()) {
  12.     e.printStackTrace();

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

  1. long startTimeInMs = System.currentTimeMillis();
  2. String keyHexString = "";
  3. if(logger.isDebugEnabled()) {
  4.   ByteArray key = (ByteArray) requestWrapper.getKey();
  5.   keyHexString = RestUtils.getKeyHexString(key);
  6. if(logger.isDebugEnabled()) {
  7.   int vcEntrySize = 0;
  8.   for(Versioned<V> vc: items) {
  9. logger.info("Received invalid metadata exception during get [  " + e.getMessage()
  10.       + " ] on store '" + storeName + "'. Rebootstrapping");
  11. bootStrap();

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

  1. @Override
  2. protected List<Node> getNodes(ByteArray key) {
  3.   List<Node> originalNodes = null;
  4.   List<Node> nodes = new ArrayList<Node>();
  5.   try {
  6.     originalNodes = super.getNodes(key);
  7.   } catch(VoldemortException e) {
  8.     pipelineData.setFatalError(e);
  9.     return null;
  10.   }
  11.   for(Node node: originalNodes) {
  12.     if(node.getZoneId() == clientZone.getId()) {
  13.       nodes.add(node);
  14.     }
  15.   }
  16.   if(logger.isDebugEnabled())
  17.     logger.debug("Adding " + nodes.size() + " node(s) to preference list");
  18.   return nodes;
  19. }

代码示例来源：origin: alibaba/cobar

  1. @Override
  2. public void error(int errCode, Throwable t) {
  3.   // 根据异常类型和信息，选择日志输出级别。
  4.   if (t instanceof EOFException) {
  5.     if (LOGGER.isDebugEnabled()) {
  6.       LOGGER.debug(toString(), t);
  7.     }
  8.   } else if (isConnectionReset(t)) {
  9.     if (LOGGER.isInfoEnabled()) {
  10.       LOGGER.info(toString(), t);
  11.     }
  12.   } else {
  13.     LOGGER.warn(toString(), t);
  14.   }
  15.   // 异常返回码处理
  16.   switch (errCode) {
  17.   case ErrorCode.ERR_HANDLE_DATA:
  18.     String msg = t.getMessage();
  19.     writeErrMessage(ErrorCode.ER_YES, msg == null ? t.getClass().getSimpleName() : msg);
  20.     break;
  21.   default:
  22.     close();
  23.   }
  24. }

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

  1. public Versioned<V> getSysStore(K key) {
  2.   logger.debug("Invoking Get for key : " + key + " on store name : " + this.storeName);
  3.   Versioned<V> versioned = null;
  4.   try {
  5.     List<Versioned<V>> items = this.sysStore.get(key, null);
  6.     if(items.size() == 1)
  7.       versioned = items.get(0);
  8.     else if(items.size() > 1)
  9.       throw new InconsistentDataException("Unresolved versions returned from get(" + key
  10.                         + ") = " + items, items);
  11.     if(versioned != null)
  12.       logger.debug("Value for key : " + key + " = " + versioned.getValue()
  13.              + " on store name : " + this.storeName);
  14.     else
  15.       logger.debug("Got null value");
  16.   } catch(InvalidMetadataException e) {
  17.     throw e;
  18.   } catch(Exception e) {
  19.     if(logger.isDebugEnabled()) {
  20.       logger.debug("Exception caught during getSysStore: " + e);
  21.     }
  22.   }
  23.   return versioned;
  24. }

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

  1. ByteArray key = new ByteArray(RestUtils.decodeVoldemortKey(base64Key));
  2. if(logger.isDebugEnabled()) {
  3.   logger.debug("Content-Location : " + contentLocation);
  4.   logger.debug("Base 64 key : " + base64Key);
  5.   int contentLength = Integer.parseInt(valuePart.getHeader(RestMessageHeaders.CONTENT_LENGTH)[0]);
  6.   if(logger.isDebugEnabled()) {
  7.     logger.debug("Received serialized Vector Clock : " + serializedVC);
  8.   valueResultList.add(new Versioned<byte[]>(bodyPartBytes, clock));

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

  1. if(isClosed.get()) {
  2.   if(logger.isInfoEnabled())
  3.     logger.debug("Closed, exiting for " + endpoint);
  4.   if(logger.isDebugEnabled())
  5.     logger.debug("Registering connection from "
  6.            + socketChannel.socket().getPort());
  7.     if(logger.isDebugEnabled())
  8.       logger.debug("Requested socket receive buffer size was "
  9.              + this.socketBufferSize + " bytes but actual size is "
  10.              + socketChannel.socket().getReceiveBufferSize()
  11.     if(logger.isDebugEnabled())
  12.       logger.debug("Requested socket send buffer size was "
  13.              + this.socketBufferSize + " bytes but actual size is "
  14.   if(logger.isDebugEnabled())
  15.     logger.debug("Selector is closed, exiting");
  16. } catch(Exception e) {
  17.   if(logger.isEnabledFor(Level.ERROR))
  18.     logger.error(e.getMessage(), e);
  19. logger.error(e.getMessage(), e);

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

  1. private void invokeCallback(Object o, long requestTime) {
  2.   if(callback != null) {
  3.     try {
  4.       if(logger.isDebugEnabled()) {
  5.         logger.debug("Async request end; requestRef: "
  6.                + System.identityHashCode(clientRequest)
  7.                + " time: "
  8.                + System.currentTimeMillis()
  9.                + " server: "
  10.                + clientRequestExecutor.getSocketChannel()
  11.                           .socket()
  12.                           .getRemoteSocketAddress()
  13.                + " local socket: "
  14.                + clientRequestExecutor.getSocketChannel()
  15.                           .socket()
  16.                           .getLocalAddress() + ":"
  17.                + clientRequestExecutor.getSocketChannel().socket().getLocalPort()
  18.                + " result: " + o);
  19.       }
  20.       callback.requestComplete(o, requestTime);
  21.     } catch(Exception e) {
  22.       if(logger.isEnabledFor(Level.WARN))
  23.         logger.warn(e, e);
  24.     }
  25.   }
  26. }

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

Logger

相关文章

    查看更多

    热门标签

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

    最新文章

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