net.spy.memcached.compat.log.Logger.debug()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(6.2k)|赞(0)|评价(0)|浏览(163)

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

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);
}

相关文章