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

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

本文整理了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

  1. @Override
  2. protected byte[] compress(byte[] in)
  3. {
  4. if (in == null) {
  5. throw new NullPointerException("Can't compress null");
  6. }
  7. LZ4Compressor compressor = lz4Factory.fastCompressor();
  8. byte[] out = new byte[compressor.maxCompressedLength(in.length)];
  9. int compressedLength = compressor.compress(in, 0, in.length, out, 0);
  10. getLogger().debug("Compressed %d bytes to %d", in.length, compressedLength);
  11. return ByteBuffer.allocate(Integer.BYTES + compressedLength)
  12. .putInt(in.length)
  13. .put(out, 0, compressedLength)
  14. .array();
  15. }

代码示例来源:origin: apache/kylin

  1. for (long position : ketamaNodePositionsAtIteration(node, i)) {
  2. newNodeMap.put(position, node);
  3. getLogger().debug("Adding node %s with weight %s in position %d", node, thisWeight, position);
  4. for (long position : ketamaNodePositionsAtIteration(node, i)) {
  5. newNodeMap.put(position, node);
  6. getLogger().debug("Adding node %s in position %d", node, position);

代码示例来源:origin: apache/kylin

  1. @Override
  2. public MetricCollector getMetricCollector() {
  3. String enableMetrics = metricsConfig.get("memcached.enabled");
  4. if (enableMetrics().equals(MetricType.OFF) || enableMetrics == null
  5. || "false".equalsIgnoreCase(enableMetrics)) {
  6. getLogger().debug("Memcached metrics collection disabled.");
  7. return new NoopMetricCollector();
  8. } else {
  9. getLogger().info("Memcached metrics collection enabled (Profile " + enableMetrics() + ").");
  10. return new MemcachedMetrics();
  11. }
  12. }

代码示例来源:origin: Netflix/EVCache

  1. getLogger().debug("Mutation returned " + rv);
  2. return rv.get();

代码示例来源:origin: net.spy/spymemcached

  1. /**
  2. * Optionally handle retry (NOT_MY_VBUKET) responses.
  3. *
  4. * This method can be overridden in subclasses to handle the content
  5. * of the retry message appropriately.
  6. *
  7. * @param retryMessage the body of the retry message.
  8. */
  9. protected void handleRetryInformation(final byte[] retryMessage) {
  10. getLogger().debug("Got RETRY message: " + new String(retryMessage)
  11. + ", but not handled.");
  12. }

代码示例来源:origin: net.spy/spymemcached

  1. public final int writeSome() throws IOException {
  2. int wrote = channel.write(wbuf);
  3. assert wrote >= 0 : "Wrote negative bytes?";
  4. toWrite -= wrote;
  5. assert toWrite >= 0 : "toWrite went negative after writing " + wrote
  6. + " bytes for " + this;
  7. getLogger().debug("Wrote %d bytes", wrote);
  8. return wrote;
  9. }

代码示例来源:origin: net.spy/spymemcached

  1. /**
  2. * This is called on each subclass whenever an operation was cancelled.
  3. */
  4. protected void wasCancelled() {
  5. getLogger().debug("was cancelled.");
  6. }

代码示例来源:origin: com.google.code.simple-spring-memcached/spymemcached

  1. /**
  2. * This is called on each subclass whenever an operation was cancelled.
  3. */
  4. protected void wasCancelled() {
  5. getLogger().debug("was cancelled.");
  6. }

代码示例来源:origin: net.spy/spymemcached

  1. public final void fixupOps() {
  2. // As the selection key can be changed at any point due to node
  3. // failure, we'll grab the current volatile value and configure it.
  4. SelectionKey s = sk;
  5. if (s != null && s.isValid()) {
  6. int iops = getSelectionOps();
  7. getLogger().debug("Setting interested opts to %d", iops);
  8. s.interestOps(iops);
  9. } else {
  10. getLogger().debug("Selection key is not valid.");
  11. }
  12. }

代码示例来源:origin: net.spy/spymemcached

  1. public final void transitionWriteItem() {
  2. Operation op = removeCurrentWriteOp();
  3. assert op != null : "There is no write item to transition";
  4. getLogger().debug("Finished writing %s", op);
  5. }

代码示例来源:origin: com.amazonaws/elasticache-java-cluster-client

  1. public final void transitionWriteItem() {
  2. Operation op = removeCurrentWriteOp();
  3. assert op != null : "There is no write item to transition";
  4. getLogger().debug("Finished writing %s", op);
  5. }

代码示例来源:origin: com.google.code.simple-spring-memcached/spymemcached

  1. public void insertOperation(final MemcachedNode node, final Operation o) {
  2. o.setHandlingNode(node);
  3. o.initialize();
  4. node.insertOp(o);
  5. addedQueue.offer(node);
  6. Selector s = selector.wakeup();
  7. assert s == selector : "Wakeup returned the wrong selector.";
  8. getLogger().debug("Added %s to %s", o, node);
  9. }

代码示例来源:origin: net.spy/spymemcached

  1. @Override
  2. public void receivedStatus(OperationStatus status) {
  3. if(status.isSuccess()) {
  4. supportedMechs.set(status.getMessage());
  5. getLogger().debug("Received SASL supported mechs: "
  6. + status.getMessage());
  7. } else {
  8. getLogger().warn("Received non-success response for SASL mechs: "
  9. + status);
  10. }
  11. }

代码示例来源:origin: com.couchbase.client/couchbase-client

  1. @Override
  2. public void connectionLost(SocketAddress sa) {
  3. getLogger().debug("Connection lost for node: " + sa);
  4. cbConnFactory.configurationProvider.reloadConfig();
  5. super.connectionLost(sa);
  6. }

代码示例来源:origin: net.spy/spymemcached

  1. @Override
  2. public void handleLine(String line) {
  3. getLogger().debug("Result: %s", line);
  4. OperationStatus found = null;
  5. if (line.equals("NOT_FOUND")) {
  6. found = NOT_FOUND;
  7. } else {
  8. found = new OperationStatus(true, line, StatusCode.SUCCESS);
  9. }
  10. getCallback().receivedStatus(found);
  11. transitionState(OperationState.COMPLETE);
  12. }

代码示例来源:origin: net.spy/spymemcached

  1. @Override
  2. public void handleLine(String line) {
  3. getLogger().debug("Touch completed successfully");
  4. getCallback().receivedStatus(matchStatus(line, OK));
  5. transitionState(OperationState.COMPLETE);
  6. }

代码示例来源:origin: net.spy/spymemcached

  1. @Override
  2. public void handleLine(String line) {
  3. getLogger().debug("Unlock of %s returned %s", key, line);
  4. getCallback().receivedStatus(matchStatus(line, UNLOCKED, NOT_FOUND));
  5. transitionState(OperationState.COMPLETE);
  6. }

代码示例来源:origin: net.spy/spymemcached

  1. @Override
  2. public void handleLine(String line) {
  3. getLogger().debug("Delete of %s returned %s", key, line);
  4. getCallback().receivedStatus(matchStatus(line, DELETED, NOT_FOUND));
  5. transitionState(OperationState.COMPLETE);
  6. }

代码示例来源:origin: net.spy/spymemcached

  1. @Override
  2. public void handleLine(String line) {
  3. getLogger().debug("Flush completed successfully");
  4. getCallback().receivedStatus(matchStatus(line, OK));
  5. transitionState(OperationState.COMPLETE);
  6. }

代码示例来源:origin: com.google.code.simple-spring-memcached/spymemcached

  1. @Override
  2. public void handleLine(String line) {
  3. getLogger().debug("Unlock of %s returned %s", key, line);
  4. getCallback().receivedStatus(matchStatus(line, UNLOCKED, NOT_FOUND));
  5. transitionState(OperationState.COMPLETE);
  6. }

相关文章