本文整理了Java中org.apache.log4j.Logger.isInfoEnabled()
方法的一些代码示例,展示了Logger.isInfoEnabled()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Logger.isInfoEnabled()
方法的具体详情如下:
包路径:org.apache.log4j.Logger
类名称:Logger
方法名:isInfoEnabled
暂无
代码示例来源:origin: voldemort/voldemort
public void updateFetchProgress(String storeName) {
int curFetches = fetches.incrementAndGet();
if(0 == curFetches % progressPeriodOps) {
if(logger.isInfoEnabled()) {
long durationS = TimeUnit.MILLISECONDS.toSeconds(System.currentTimeMillis()
- startTimeMs);
logger.info("Fetched " + curFetches + " in " + durationS + " seconds for store "
+ storeName);
}
}
}
代码示例来源:origin: alibaba/cobar
private static void logExplicitReplicaSet(Object frontConn, String sql, RouteResultset rrs) {
if (frontConn != null && LOGGER.isInfoEnabled()) {
StringBuilder s = new StringBuilder();
s.append(frontConn).append("Explicit data node replica set from, sql=[");
s.append(sql).append(']');
LOGGER.info(s.toString());
}
}
}
代码示例来源:origin: apache/ignite
/** {@inheritDoc} */
@Override public void info(String msg) {
if (!impl.isInfoEnabled())
warning("Logging at INFO level without checking if INFO level is enabled: " + msg);
impl.info(msg);
}
代码示例来源:origin: voldemort/voldemort
public void updateProgressBar() {
if(logger.isInfoEnabled()) {
String progressBar = getPrettyProgressBar();
logger.info(progressBar);
}
}
}
代码示例来源:origin: voldemort/voldemort
/**
* Simple info message for status
*
* @param tag Message to print out at start of info message
*/
protected void statusInfoMessage(final String tag) {
if(logger.isInfoEnabled()) {
logger.info(tag + " : [partition: " + currentPartition + ", partitionFetched: "
+ currentPartitionFetched
+ "] for store " + storageEngine.getName());
}
}
代码示例来源:origin: javamelody/javamelody
/** {@inheritDoc} */
@Override
public void logHttpRequest(HttpServletRequest httpRequest, String requestName, long duration,
boolean systemError, int responseSize, String loggerName) {
final org.apache.log4j.Logger logger = org.apache.log4j.Logger.getLogger(loggerName);
if (logger.isInfoEnabled()) {
logger.info(LOG.buildLogMessage(httpRequest, duration, systemError, responseSize));
}
}
}
代码示例来源:origin: voldemort/voldemort
/**
* Progress info message
*
* @param tag Message that precedes progress info. Indicate 'keys' or
* 'entries'.
*/
protected void progressInfoMessage(final String tag) {
if(logger.isInfoEnabled()) {
long totalTimeS = (System.currentTimeMillis() - startTimeMs) / Time.MS_PER_SECOND;
logger.info(tag + " : scanned " + scanned + " and fetched " + fetched + " for store '"
+ storageEngine.getName() + "' partitionIds:" + partitionIds + " in "
+ totalTimeS + " s");
}
}
代码示例来源:origin: alibaba/cobar
private void setTimeout(CobarDetector detector) {
status = TIMEOUT_STATUS;
try {
ALARM.error(alarmMessage("TIMEOUT"));
if (HEARTBEAT.isInfoEnabled()) {
HEARTBEAT.info(requestMessage(TIMEOUT_STATUS, null));
}
} finally {
detector.quit();
isChecking.set(false);
}
}
代码示例来源:origin: alibaba/cobar
public void heartbeat() {
if (isAuthenticated) {
HeartbeatPacket hp = new HeartbeatPacket();
hp.packetId = 0;
hp.command = MySQLPacket.COM_HEARTBEAT;
hp.id = heartbeat.detectCount.incrementAndGet();
hp.write(this);
if (HEARTBEAT.isInfoEnabled()) {
HEARTBEAT.info(heartbeat.requestMessage(CobarHeartbeat.SEND, String.valueOf(hp.id).getBytes()));
}
} else {
authenticate();
}
}
代码示例来源:origin: voldemort/voldemort
public void run() {
if(logger.isInfoEnabled())
logger.info("Server now listening for connections on port " + port);
if(logger.isInfoEnabled())
logger.info("Acceptor thread interrupted");
if(logger.isInfoEnabled())
logger.info("Server has stopped listening for connections on port " + port);
代码示例来源:origin: voldemort/voldemort
/**
* Starting the testing environment and wait until all Voldemort server
* instances are online
*
* @throws InterruptedException
*/
public void start() throws InterruptedException {
if(logger.isInfoEnabled()) {
logger.info("Starting up and wait");
}
thread.start();
startFinishLatch.await();
if(logger.isInfoEnabled()) {
logger.info("Finished Waiting for start up");
}
}
代码示例来源:origin: alibaba/cobar
protected void success(AuthPacket auth) {
source.setAuthenticated(true);
source.setUser(auth.user);
source.setSchema(auth.database);
source.setCharsetIndex(auth.charsetIndex);
source.setHandler(new FrontendCommandHandler(source));
if (LOGGER.isInfoEnabled()) {
StringBuilder s = new StringBuilder();
s.append(source).append('\'').append(auth.user).append("' login success");
byte[] extra = auth.extra;
if (extra != null && extra.length > 0) {
s.append(",extra:").append(new String(extra));
}
LOGGER.info(s.toString());
}
ByteBuffer buffer = source.allocate();
source.write(source.writeToBuffer(AUTH_OK, buffer));
}
代码示例来源:origin: voldemort/voldemort
/**
* Stop a server
*
* @param nodeId The node of server to stop
*/
public void stopServer(int nodeId) {
if(logger.isInfoEnabled())
logger.info("Stopping server of node [" + nodeId + "]");
VoldemortServer server = voldemortServers.get(nodeId);
server.stop();
}
代码示例来源:origin: apache/ignite
/** {@inheritDoc} */
@Override public void info(String msg) {
if (!impl.isInfoEnabled())
warning("Logging at INFO level without checking if INFO level is enabled: " + msg);
impl.info(msg);
}
代码示例来源: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: 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
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: alibaba/cobar
case OK_STATUS:
setOk(detector);
if (HEARTBEAT.isInfoEnabled()) {
HEARTBEAT.info(requestMessage(OK_STATUS, message));
if (HEARTBEAT.isInfoEnabled()) {
HEARTBEAT.info(requestMessage(OFF_STATUS, message));
if (HEARTBEAT.isInfoEnabled()) {
HEARTBEAT.info(requestMessage(ERROR_STATUS, message));
代码示例来源:origin: voldemort/voldemort
int outputBatchSize,
boolean details) {
if(logger.isInfoEnabled()) {
logger.info("Connecting to bootstrap server: " + url);
代码示例来源:origin: voldemort/voldemort
int keysPerSecondLimit,
int progressPeriodOps) {
if(logger.isInfoEnabled()) {
logger.info("Connecting to bootstrap server: " + url);
内容来源于网络,如有侵权,请联系作者删除!