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

Logger.isDebugEnabled介绍

暂无

代码示例

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

private Socket applySettings(Socket s) throws IOException {
  if(logger.isDebugEnabled())
    logger.debug("Attempting to set socket receive buffer of "
           + this.socketReceiveBufferSize + " bytes");
  s.setReceiveBufferSize(socketReceiveBufferSize);
  s.setSoTimeout(socketTimeout);
  if(logger.isDebugEnabled())
    logger.info("Actually set socket receive buffer to " + s.getReceiveBufferSize()
          + " bytes");
  return s;
}

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

public SelectorManagerWorker(Selector selector,
               SocketChannel socketChannel,
               int socketBufferSize) {
  this.selector = selector;
  this.socketChannel = socketChannel;
  this.socketBufferSize = socketBufferSize;
  this.resizeThreshold = socketBufferSize * 2; // This is arbitrary...
  this.createTimestamp = System.nanoTime();
  this.isClosed = new AtomicBoolean(false);
  if(logger.isDebugEnabled())
    logger.debug("Accepting remote connection from " + socketChannel.socket());
}

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

protected void closeInternal() {
  if(logger.isDebugEnabled())
    logger.debug("Closing remote connection from " + socketChannel.socket());
  try {
    socketChannel.socket().close();
  } catch(IOException e) {
    if(logger.isEnabledFor(Level.WARN))
      logger.warn(e.getMessage(), e);
  }
  try {
    socketChannel.close();
  } catch(IOException e) {
    if(logger.isEnabledFor(Level.WARN))
      logger.warn(e.getMessage(), e);
  }
  SelectionKey selectionKey = socketChannel.keyFor(selector);
  if(selectionKey != null) {
    try {
      selectionKey.attach(null);
      selectionKey.cancel();
    } catch(Exception e) {
      if(logger.isEnabledFor(Level.WARN))
        logger.warn(e.getMessage(), e);
    }
  }
  // close the streams, so we account for comm buffer frees
  IOUtils.closeQuietly(inputStream);
  IOUtils.closeQuietly(outputStream);
}

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

@Override
public List<Node> routeRequest(byte[] key) {
  List<Integer> partitionList = getPartitionList(key);
  if(partitionList.size() == 0)
    return new ArrayList<Node>(0);
  // pull out the nodes corresponding to the target partitions
  List<Node> preferenceList = new ArrayList<Node>(partitionList.size());
  for(int partition: partitionList) {
    preferenceList.add(partitionToNode[partition]);
  }
  if(logger.isDebugEnabled()) {
    List<Integer> nodeIdList = new ArrayList<Integer>();
    for(int partition: partitionList) {
      nodeIdList.add(partitionToNode[partition].getId());
    }
    logger.debug("Key " + ByteUtils.toHexString(key) + " mapped to Nodes " + nodeIdList
           + " Partitions " + partitionList);
  }
  return preferenceList;
}

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

@Override
public void error(int errCode, Throwable t) {
  // 根据异常类型和信息，选择日志输出级别。
  if (t instanceof EOFException) {
    if (LOGGER.isDebugEnabled()) {
      LOGGER.debug(toString(), t);
    }
  } else if (isConnectionReset(t)) {
    if (LOGGER.isInfoEnabled()) {
      LOGGER.info(toString(), t);
    }
  } else {
    LOGGER.warn(toString(), t);
  }
  // 异常返回码处理
  switch (errCode) {
  case ErrorCode.ERR_HANDLE_DATA:
    String msg = t.getMessage();
    writeErrMessage(ErrorCode.ER_YES, msg == null ? t.getClass().getSimpleName() : msg);
    break;
  default:
    close();
  }
}

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

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

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

@Override
public void requestComplete(Object result, long requestTime) {
  Slop slop = null;
  boolean loggerDebugEnabled = logger.isDebugEnabled();
  if(loggerDebugEnabled) {
    slop = slopSerializer.toObject(slopVersioned.getValue());
    && !(response.getValue() instanceof ObsoleteVersionException)) {
    if(!failedNodes.contains(node))
      failedNodes.add(node);
    if(response.getValue() instanceof UnreachableStoreException) {
      UnreachableStoreException use = (UnreachableStoreException) response.getValue();
        logger.debug("Write of key " + slop.getKey() + " for "
               + slop.getNodeId() + " to node " + node
               + " failed due to unreachable: " + use.getMessage());
    logger.debug("Slop write of key " + slop.getKey() + " for node "
           + slop.getNodeId() + " to node " + node + " succeeded in "
           + (System.nanoTime() - startNs) + " ns");

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

if(parseAndValidateRequest()) {
  if(this.isGetVersionRequest) {
    if(logger.isDebugEnabled()) {
      debugLog("GET_VERSION", System.currentTimeMillis());
                                            this.parsedRoutingType);
  } else if(this.parsedKeys.size() > 1) {
    if(logger.isDebugEnabled()) {
      debugLog("GET_ALL", System.currentTimeMillis());
                                          this.parsedRoutingType);
  } else {
    if(logger.isDebugEnabled()) {
      debugLog("GET", System.currentTimeMillis());

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

|| this.parsedVectorClock.getEntries().size() == 0) {
  if(logger.isDebugEnabled()) {
    debugLog("PUT", System.currentTimeMillis());
                                    this.parsedRoutingType);
} else {
  if(logger.isDebugEnabled()) {
    debugLog("PUT_VERSION", System.currentTimeMillis());
logger.error("Error when parsing value. Value cannot be null.");
RestErrorHandler.writeErrorResponse(messageEvent,
                  HttpResponseStatus.BAD_REQUEST,

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

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

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

if(logger.isDebugEnabled()) {
  logger.debug("Incoming get request");
                            null);
  if(versionedValues.size() > 0) {
    GetResponseSender responseConstructor = new GetResponseSender(messageEvent,
                                   requestObject.getKey(),
    logger.error("Error when doing get. Key does not exist");
    RestErrorHandler.writeErrorResponse(messageEvent,
                      NOT_FOUND,
if(logger.isDebugEnabled()) {
  logger.debug("Incoming get all request");
    if(values.size() > 0) {
      hasAtleastOneValidKey = true;
      break;
if(logger.isDebugEnabled()) {
  logger.debug("Incoming put request");
if(logger.isDebugEnabled()) {
if(logger.isDebugEnabled()) {

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

@Override
public Status delete(String table, String key) {
 if (LOGGER.isDebugEnabled()) {
  LOGGER.debug("deletekey: " + key + " from table: " + table);
 }
 DeleteItemRequest req = new DeleteItemRequest(table, createPrimaryKey(key));
 try {
  dynamoDB.deleteItem(req);
 } catch (AmazonServiceException ex) {
  LOGGER.error(ex);
  return Status.ERROR;
 } catch (AmazonClientException ex) {
  LOGGER.error(ex);
  return CLIENT_ERROR;
 }
 return Status.OK;
}

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

badKeyWriterService = Executors.newSingleThreadExecutor();
badKeyWriterService.submit(new BadKeyWriter(badKeyFileOut, badKeyQOut));
logger.info("Created badKeyWriter.");
                        blockingQ,
                        rejectedExecutionHandler);
logger.info("Created ConsistencyFixWorker pool.");
logger.info("Created badKeyReader.");
  logger.info("Bad key writer service has shutdown.");
} catch(InterruptedException e) {
  logger.error("InterruptedException caught.");
  if(logger.isDebugEnabled()) {
    e.printStackTrace();

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

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

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

@Override
protected List<Node> getNodes(ByteArray key) {
  List<Node> originalNodes = null;
  List<Node> nodes = new ArrayList<Node>();
  try {
    originalNodes = super.getNodes(key);
  } catch(VoldemortException e) {
    pipelineData.setFatalError(e);
    return null;
  }
  for(Node node: originalNodes) {
    if(node.getZoneId() == clientZone.getId()) {
      nodes.add(node);
    }
  }
  if(logger.isDebugEnabled())
    logger.debug("Adding " + nodes.size() + " node(s) to preference list");
  return nodes;
}

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

@Override
public void error(int errCode, Throwable t) {
  // 根据异常类型和信息，选择日志输出级别。
  if (t instanceof EOFException) {
    if (LOGGER.isDebugEnabled()) {
      LOGGER.debug(toString(), t);
    }
  } else if (isConnectionReset(t)) {
    if (LOGGER.isInfoEnabled()) {
      LOGGER.info(toString(), t);
    }
  } else {
    LOGGER.warn(toString(), t);
  }
  // 异常返回码处理
  switch (errCode) {
  case ErrorCode.ERR_HANDLE_DATA:
    String msg = t.getMessage();
    writeErrMessage(ErrorCode.ER_YES, msg == null ? t.getClass().getSimpleName() : msg);
    break;
  default:
    close();
  }
}

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

public Versioned<V> getSysStore(K key) {
  logger.debug("Invoking Get for key : " + key + " on store name : " + this.storeName);
  Versioned<V> versioned = null;
  try {
    List<Versioned<V>> items = this.sysStore.get(key, null);
    if(items.size() == 1)
      versioned = items.get(0);
    else if(items.size() > 1)
      throw new InconsistentDataException("Unresolved versions returned from get(" + key
                        + ") = " + items, items);
    if(versioned != null)
      logger.debug("Value for key : " + key + " = " + versioned.getValue()
             + " on store name : " + this.storeName);
    else
      logger.debug("Got null value");
  } catch(InvalidMetadataException e) {
    throw e;
  } catch(Exception e) {
    if(logger.isDebugEnabled()) {
      logger.debug("Exception caught during getSysStore: " + e);
    }
  }
  return versioned;
}

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

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

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

if(isClosed.get()) {
  if(logger.isInfoEnabled())
    logger.debug("Closed, exiting for " + endpoint);
  if(logger.isDebugEnabled())
    logger.debug("Registering connection from "
           + socketChannel.socket().getPort());
    if(logger.isDebugEnabled())
      logger.debug("Requested socket receive buffer size was "
             + this.socketBufferSize + " bytes but actual size is "
             + socketChannel.socket().getReceiveBufferSize()
    if(logger.isDebugEnabled())
      logger.debug("Requested socket send buffer size was "
             + this.socketBufferSize + " bytes but actual size is "
  if(logger.isDebugEnabled())
    logger.debug("Selector is closed, exiting");
} catch(Exception e) {
  if(logger.isEnabledFor(Level.ERROR))
    logger.error(e.getMessage(), e);
logger.error(e.getMessage(), e);

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

private void invokeCallback(Object o, long requestTime) {
  if(callback != null) {
    try {
      if(logger.isDebugEnabled()) {
        logger.debug("Async request end; requestRef: "
               + System.identityHashCode(clientRequest)
               + " time: "
               + System.currentTimeMillis()
               + " server: "
               + clientRequestExecutor.getSocketChannel()
                          .socket()
                          .getRemoteSocketAddress()
               + " local socket: "
               + clientRequestExecutor.getSocketChannel()
                          .socket()
                          .getLocalAddress() + ":"
               + clientRequestExecutor.getSocketChannel().socket().getLocalPort()
               + " result: " + o);
      }
      callback.requestComplete(o, requestTime);
    } catch(Exception e) {
      if(logger.isEnabledFor(Level.WARN))
        logger.warn(e, e);
    }
  }
}