本文整理了Java中net.spy.memcached.compat.log.Logger.debug()
方法的一些代码示例,展示了Logger.debug()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Logger.debug()
方法的具体详情如下:
包路径:net.spy.memcached.compat.log.Logger
类名称:Logger
方法名:debug
[英]Log a message at debug level.
[中]在调试级别记录消息。
代码示例来源: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: 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: 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: Netflix/EVCache
getLogger().debug("Mutation returned " + rv);
return rv.get();
代码示例来源:origin: net.spy/spymemcached
/**
* Optionally handle retry (NOT_MY_VBUKET) responses.
*
* This method can be overridden in subclasses to handle the content
* of the retry message appropriately.
*
* @param retryMessage the body of the retry message.
*/
protected void handleRetryInformation(final byte[] retryMessage) {
getLogger().debug("Got RETRY message: " + new String(retryMessage)
+ ", but not handled.");
}
代码示例来源:origin: net.spy/spymemcached
public final int writeSome() throws IOException {
int wrote = channel.write(wbuf);
assert wrote >= 0 : "Wrote negative bytes?";
toWrite -= wrote;
assert toWrite >= 0 : "toWrite went negative after writing " + wrote
+ " bytes for " + this;
getLogger().debug("Wrote %d bytes", wrote);
return wrote;
}
代码示例来源:origin: net.spy/spymemcached
/**
* This is called on each subclass whenever an operation was cancelled.
*/
protected void wasCancelled() {
getLogger().debug("was cancelled.");
}
代码示例来源:origin: com.google.code.simple-spring-memcached/spymemcached
/**
* This is called on each subclass whenever an operation was cancelled.
*/
protected void wasCancelled() {
getLogger().debug("was cancelled.");
}
代码示例来源:origin: net.spy/spymemcached
public final void fixupOps() {
// As the selection key can be changed at any point due to node
// failure, we'll grab the current volatile value and configure it.
SelectionKey s = sk;
if (s != null && s.isValid()) {
int iops = getSelectionOps();
getLogger().debug("Setting interested opts to %d", iops);
s.interestOps(iops);
} else {
getLogger().debug("Selection key is not valid.");
}
}
代码示例来源:origin: net.spy/spymemcached
public final void transitionWriteItem() {
Operation op = removeCurrentWriteOp();
assert op != null : "There is no write item to transition";
getLogger().debug("Finished writing %s", op);
}
代码示例来源:origin: com.amazonaws/elasticache-java-cluster-client
public final void transitionWriteItem() {
Operation op = removeCurrentWriteOp();
assert op != null : "There is no write item to transition";
getLogger().debug("Finished writing %s", op);
}
代码示例来源:origin: com.google.code.simple-spring-memcached/spymemcached
public void insertOperation(final MemcachedNode node, final Operation o) {
o.setHandlingNode(node);
o.initialize();
node.insertOp(o);
addedQueue.offer(node);
Selector s = selector.wakeup();
assert s == selector : "Wakeup returned the wrong selector.";
getLogger().debug("Added %s to %s", o, node);
}
代码示例来源:origin: net.spy/spymemcached
@Override
public void receivedStatus(OperationStatus status) {
if(status.isSuccess()) {
supportedMechs.set(status.getMessage());
getLogger().debug("Received SASL supported mechs: "
+ status.getMessage());
} else {
getLogger().warn("Received non-success response for SASL mechs: "
+ status);
}
}
代码示例来源:origin: com.couchbase.client/couchbase-client
@Override
public void connectionLost(SocketAddress sa) {
getLogger().debug("Connection lost for node: " + sa);
cbConnFactory.configurationProvider.reloadConfig();
super.connectionLost(sa);
}
代码示例来源:origin: net.spy/spymemcached
@Override
public void handleLine(String line) {
getLogger().debug("Result: %s", line);
OperationStatus found = null;
if (line.equals("NOT_FOUND")) {
found = NOT_FOUND;
} else {
found = new OperationStatus(true, line, StatusCode.SUCCESS);
}
getCallback().receivedStatus(found);
transitionState(OperationState.COMPLETE);
}
代码示例来源:origin: net.spy/spymemcached
@Override
public void handleLine(String line) {
getLogger().debug("Touch completed successfully");
getCallback().receivedStatus(matchStatus(line, OK));
transitionState(OperationState.COMPLETE);
}
代码示例来源:origin: net.spy/spymemcached
@Override
public void handleLine(String line) {
getLogger().debug("Unlock of %s returned %s", key, line);
getCallback().receivedStatus(matchStatus(line, UNLOCKED, NOT_FOUND));
transitionState(OperationState.COMPLETE);
}
代码示例来源:origin: net.spy/spymemcached
@Override
public void handleLine(String line) {
getLogger().debug("Delete of %s returned %s", key, line);
getCallback().receivedStatus(matchStatus(line, DELETED, NOT_FOUND));
transitionState(OperationState.COMPLETE);
}
代码示例来源:origin: net.spy/spymemcached
@Override
public void handleLine(String line) {
getLogger().debug("Flush completed successfully");
getCallback().receivedStatus(matchStatus(line, OK));
transitionState(OperationState.COMPLETE);
}
代码示例来源:origin: com.google.code.simple-spring-memcached/spymemcached
@Override
public void handleLine(String line) {
getLogger().debug("Unlock of %s returned %s", key, line);
getCallback().receivedStatus(matchStatus(line, UNLOCKED, NOT_FOUND));
transitionState(OperationState.COMPLETE);
}
内容来源于网络,如有侵权,请联系作者删除!