net.spy.memcached.compat.log.Logger类的使用及代码示例

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

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

  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: Netflix/EVCache

  1. public void shutdown() {
  2.   removeMonitoring();
  3.   writeQ.clear();
  4.   readQ.clear();
  5.   inputQueue.clear();
  6.   try {
  7.     // Cleanup the ByteBuffers only if they are sun.nio.ch.DirectBuffer
  8.     // If we don't cleanup then we will leak 16K of memory
  9.     if (getRbuf() instanceof DirectBuffer) {
  10.       Cleaner cleaner = ((DirectBuffer) getRbuf()).cleaner();
  11.       if (cleaner != null) cleaner.clean();
  12.       cleaner = ((DirectBuffer) getWbuf()).cleaner();
  13.       if (cleaner != null) cleaner.clean();
  14.     }
  15.   } catch (Throwable t) {
  16.     getLogger().error("Exception cleaning ByteBuffer.", t);
  17.   }
  18. }

代码示例来源：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: naver/arcus-java-client

  1. public Element getElement(String key) {
  2.  Element element = cache.get(key);
  3.  if (logger.isDebugEnabled()) {
  4.   if (null != element) {
  5.    logger.debug("ArcusFrontCache: local cache hit for %s", key);
  6.   }
  7.  }
  8.  return element;
  9. }

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

  1. private void logRunException(Exception e) {
  2.  if (shutDown) {
  3.   // There are a couple types of errors that occur during the
  4.   // shutdown sequence that are considered OK. Log at debug.
  5.   getLogger().debug("Exception occurred during shutdown", e);
  6.  } else {
  7.   getLogger().warn("Problem handling Couchbase IO", e);
  8.  }
  9. }

代码示例来源：origin: com.google.code.maven-play-plugin.spy/memcached

  1. /**
  2.  * Close a closeable.
  3.  */
  4. public static void close(Closeable closeable) {
  5.   if (closeable != null) {
  6.     try {
  7.       closeable.close();
  8.     } catch (Exception e) {
  9.       logger.info("Unable to close %s", closeable, e);
  10.     }
  11.   }
  12. }

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

  1. @Override
  2.  public void run() {
  3.   try {
  4.    ioReactor.execute(ioEventDispatch);
  5.   } catch (InterruptedIOException ex) {
  6.    getLogger().error("I/O reactor Interrupted", ex);
  7.   } catch (IOException e) {
  8.    getLogger().error("I/O error: " + e.getMessage(), e);
  9.   }
  10.   getLogger().debug("I/O reactor terminated");
  11.  }
  12. }, "Couchbase ClusterManager Thread");

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

  1. @Override
  2.  public void cancelled() {
  3.   getLogger().warn("Cluster Response was cancelled.");
  4.   latch.countDown();
  5.  }
  6. }

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

  1. @Override
  2.  public void run() {
  3.   try {
  4.    ioReactor.execute(ioEventDispatch);
  5.   } catch (InterruptedIOException ex) {
  6.    getLogger().error("I/O reactor Interrupted", ex);
  7.   } catch (IOException e) {
  8.    getLogger().error("I/O error: " + e.getMessage(), e);
  9.   }
  10.   getLogger().info("I/O reactor terminated");
  11.  }
  12. }, "Couchbase View Thread");

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

  1. @Override
  2. public boolean isDebugEnabled() {
  3.  return logger.isDebugEnabled();
  4. }

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

  1. @Override
  2. public void log(Level level, Object o) {
  3.  logger.log(Level.DEBUG, o);
  4. }

代码示例来源：origin: naver/arcus-java-client

  1. /**
  2.  * Get the cache list asynchronously from the Arcus admin.
  3.  */
  4. void asyncGetCacheList() {
  5.  if (getLogger().isDebugEnabled()) {
  6.   getLogger().debug("Set a new watch on " + (cacheListZPath + serviceCode));
  7.  }
  8.  zk.getChildren(cacheListZPath + serviceCode, this, this, null);
  9. }

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

  1. private void logRunException(Exception e) {
  2.   if (shutDown) {
  3.    // There are a couple types of errors that occur during the
  4.    // shutdown sequence that are considered OK. Log at debug.
  5.    getLogger().debug("Exception occurred during shutdown", e);
  6.   } else {
  7.    getLogger().warn("Problem handling memcached IO", e);
  8.   }
  9.  }
  10. }

代码示例来源：origin: com.google.code.maven-play-plugin.spy/spymemcached

  1. /**
  2.  * Close a closeable.
  3.  */
  4. public static void close(Closeable closeable) {
  5.   if (closeable != null) {
  6.     try {
  7.       closeable.close();
  8.     } catch (Exception e) {
  9.       logger.info("Unable to close %s", closeable, e);
  10.     }
  11.   }
  12. }

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

  1. @Override
  2. public void failed(Exception ex) {
  3.  getLogger().warn("Cluster Response failed with: ", ex);
  4.  latch.countDown();
  5. }

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

  1. @Override
  2. public void log(Level level, Object o, Throwable throwable) {
  3.  logger.log(Level.DEBUG, o, throwable);
  4. }

代码示例来源：origin: kr.pe.kwonnam.spymemcached-extra-transcoders/gzip-compress-transcoder

  1. @Override
  2. public byte[] compress(byte[] bytes) {
  3.   try (ByteArrayOutputStream baos = new ByteArrayOutputStream();
  4.      GZIPOutputStream gzos = new GZIPOutputStream(baos)) {
  5.     gzos.write(bytes);
  6.     gzos.flush();
  7.     gzos.close();
  8.     final byte[] compressedBytes = baos.toByteArray();
  9.     if (getLogger().isDebugEnabled()) {
  10.       getLogger().debug(String.format("gzip-compression original-size : %d compressed-size : %d", bytes.length, compressedBytes.length));
  11.     }
  12.     return compressedBytes;
  13.   } catch (IOException e) {
  14.     throw new IllegalStateException("Failed to compress with gzip.", e);
  15.   }
  16. }

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

  1. private void logRunException(Exception e) {
  2.  if (shutDown) {
  3.   // There are a couple types of errors that occur during the
  4.   // shutdown sequence that are considered OK. Log at debug.
  5.   getLogger().debug("Exception occurred during shutdown", e);
  6.  } else {
  7.   getLogger().warn("Problem handling Couchbase IO", e);
  8.  }
  9. }

代码示例来源：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: naver/arcus-java-client

  1. /**
  2.  * Close a closeable.
  3.  */
  4. public static void close(Closeable closeable) {
  5.  if (closeable != null) {
  6.   try {
  7.    closeable.close();
  8.   } catch (Exception e) {
  9.    logger.info("Unable to close %s", closeable, e);
  10.   }
  11.  }
  12. }

内容来源于网络，如有侵权，请联系作者删除！

Logger

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com