本文整理了Java中net.spy.memcached.compat.log.Logger
类的一些代码示例,展示了Logger
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Logger
类的具体详情如下:
包路径:net.spy.memcached.compat.log.Logger
类名称:Logger
[英]Abstract mechanism for dealing with logs from various objects. Implementations are expected to have a constructor that takes a single String representing the name of the logging item, or an empty constructor.
[中]处理来自不同对象的日志的抽象机制。实现应该有一个构造函数,该构造函数接受表示日志项名称的单个字符串,或者是一个空构造函数。
代码示例来源:origin: apache/incubator-druid
@Override
protected byte[] compress(byte[] in)
{
if (in == null) {
throw new NullPointerException("Can't compress null");
}
LZ4Compressor compressor = lz4Factory.fastCompressor();
byte[] out = new byte[compressor.maxCompressedLength(in.length)];
int compressedLength = compressor.compress(in, 0, in.length, out, 0);
getLogger().debug("Compressed %d bytes to %d", in.length, compressedLength);
return ByteBuffer.allocate(Integer.BYTES + compressedLength)
.putInt(in.length)
.put(out, 0, compressedLength)
.array();
}
代码示例来源:origin: Netflix/EVCache
public void shutdown() {
removeMonitoring();
writeQ.clear();
readQ.clear();
inputQueue.clear();
try {
// Cleanup the ByteBuffers only if they are sun.nio.ch.DirectBuffer
// If we don't cleanup then we will leak 16K of memory
if (getRbuf() instanceof DirectBuffer) {
Cleaner cleaner = ((DirectBuffer) getRbuf()).cleaner();
if (cleaner != null) cleaner.clean();
cleaner = ((DirectBuffer) getWbuf()).cleaner();
if (cleaner != null) cleaner.clean();
}
} catch (Throwable t) {
getLogger().error("Exception cleaning ByteBuffer.", t);
}
}
代码示例来源:origin: apache/kylin
@Override
public MetricCollector getMetricCollector() {
String enableMetrics = metricsConfig.get("memcached.enabled");
if (enableMetrics().equals(MetricType.OFF) || enableMetrics == null
|| "false".equalsIgnoreCase(enableMetrics)) {
getLogger().debug("Memcached metrics collection disabled.");
return new NoopMetricCollector();
} else {
getLogger().info("Memcached metrics collection enabled (Profile " + enableMetrics() + ").");
return new MemcachedMetrics();
}
}
代码示例来源:origin: naver/arcus-java-client
public Element getElement(String key) {
Element element = cache.get(key);
if (logger.isDebugEnabled()) {
if (null != element) {
logger.debug("ArcusFrontCache: local cache hit for %s", key);
}
}
return element;
}
代码示例来源:origin: com.couchbase.client/couchbase-client
private void logRunException(Exception e) {
if (shutDown) {
// There are a couple types of errors that occur during the
// shutdown sequence that are considered OK. Log at debug.
getLogger().debug("Exception occurred during shutdown", e);
} else {
getLogger().warn("Problem handling Couchbase IO", e);
}
}
代码示例来源:origin: com.google.code.maven-play-plugin.spy/memcached
/**
* Close a closeable.
*/
public static void close(Closeable closeable) {
if (closeable != null) {
try {
closeable.close();
} catch (Exception e) {
logger.info("Unable to close %s", closeable, e);
}
}
}
代码示例来源:origin: com.couchbase.client/couchbase-client
@Override
public void run() {
try {
ioReactor.execute(ioEventDispatch);
} catch (InterruptedIOException ex) {
getLogger().error("I/O reactor Interrupted", ex);
} catch (IOException e) {
getLogger().error("I/O error: " + e.getMessage(), e);
}
getLogger().debug("I/O reactor terminated");
}
}, "Couchbase ClusterManager Thread");
代码示例来源:origin: com.couchbase.client/couchbase-client
@Override
public void cancelled() {
getLogger().warn("Cluster Response was cancelled.");
latch.countDown();
}
}
代码示例来源:origin: com.couchbase.client/couchbase-client
@Override
public void run() {
try {
ioReactor.execute(ioEventDispatch);
} catch (InterruptedIOException ex) {
getLogger().error("I/O reactor Interrupted", ex);
} catch (IOException e) {
getLogger().error("I/O error: " + e.getMessage(), e);
}
getLogger().info("I/O reactor terminated");
}
}, "Couchbase View Thread");
代码示例来源:origin: com.couchbase.client/couchbase-client
@Override
public boolean isDebugEnabled() {
return logger.isDebugEnabled();
}
代码示例来源:origin: com.couchbase.client/couchbase-client
@Override
public void log(Level level, Object o) {
logger.log(Level.DEBUG, o);
}
代码示例来源:origin: naver/arcus-java-client
/**
* Get the cache list asynchronously from the Arcus admin.
*/
void asyncGetCacheList() {
if (getLogger().isDebugEnabled()) {
getLogger().debug("Set a new watch on " + (cacheListZPath + serviceCode));
}
zk.getChildren(cacheListZPath + serviceCode, this, this, null);
}
代码示例来源:origin: com.google.code.simple-spring-memcached/spymemcached
private void logRunException(Exception e) {
if (shutDown) {
// There are a couple types of errors that occur during the
// shutdown sequence that are considered OK. Log at debug.
getLogger().debug("Exception occurred during shutdown", e);
} else {
getLogger().warn("Problem handling memcached IO", e);
}
}
}
代码示例来源:origin: com.google.code.maven-play-plugin.spy/spymemcached
/**
* Close a closeable.
*/
public static void close(Closeable closeable) {
if (closeable != null) {
try {
closeable.close();
} catch (Exception e) {
logger.info("Unable to close %s", closeable, e);
}
}
}
代码示例来源:origin: com.couchbase.client/couchbase-client
@Override
public void failed(Exception ex) {
getLogger().warn("Cluster Response failed with: ", ex);
latch.countDown();
}
代码示例来源:origin: com.couchbase.client/couchbase-client
@Override
public void log(Level level, Object o, Throwable throwable) {
logger.log(Level.DEBUG, o, throwable);
}
代码示例来源:origin: kr.pe.kwonnam.spymemcached-extra-transcoders/gzip-compress-transcoder
@Override
public byte[] compress(byte[] bytes) {
try (ByteArrayOutputStream baos = new ByteArrayOutputStream();
GZIPOutputStream gzos = new GZIPOutputStream(baos)) {
gzos.write(bytes);
gzos.flush();
gzos.close();
final byte[] compressedBytes = baos.toByteArray();
if (getLogger().isDebugEnabled()) {
getLogger().debug(String.format("gzip-compression original-size : %d compressed-size : %d", bytes.length, compressedBytes.length));
}
return compressedBytes;
} catch (IOException e) {
throw new IllegalStateException("Failed to compress with gzip.", e);
}
}
代码示例来源:origin: com.couchbase.client/couchbase-client
private void logRunException(Exception e) {
if (shutDown) {
// There are a couple types of errors that occur during the
// shutdown sequence that are considered OK. Log at debug.
getLogger().debug("Exception occurred during shutdown", e);
} else {
getLogger().warn("Problem handling Couchbase IO", e);
}
}
代码示例来源:origin: apache/kylin
for (long position : ketamaNodePositionsAtIteration(node, i)) {
newNodeMap.put(position, node);
getLogger().debug("Adding node %s with weight %s in position %d", node, thisWeight, position);
for (long position : ketamaNodePositionsAtIteration(node, i)) {
newNodeMap.put(position, node);
getLogger().debug("Adding node %s in position %d", node, position);
代码示例来源:origin: naver/arcus-java-client
/**
* Close a closeable.
*/
public static void close(Closeable closeable) {
if (closeable != null) {
try {
closeable.close();
} catch (Exception e) {
logger.info("Unable to close %s", closeable, e);
}
}
}
内容来源于网络,如有侵权,请联系作者删除!