/**
 * Return the {@link Compressor} to the pool.
 *
 * @param compressor
 *          the <code>Compressor</code> to be returned to the pool
 */
public static void returnCompressor(Compressor compressor) {
  if (compressor == null) {
    return;
  }
  // if the compressor can't be reused, don't pool it.
  if (compressor.getClass().isAnnotationPresent(DoNotPool.class)) {
    return;
  }
  compressor.reset();
  payback(COMPRESSOR_POOL, compressor);
}
 

/**
 * Return the {@link Decompressor} to the pool.
 *
 * @param decompressor
 *          the <code>Decompressor</code> to be returned to the pool
 */
public static void returnDecompressor(Decompressor decompressor) {
  if (decompressor == null) {
    return;
  }
  // if the decompressor can't be reused, don't pool it.
  if (decompressor.getClass().isAnnotationPresent(DoNotPool.class)) {
    return;
  }
  decompressor.reset();
  payback(DECOMPRESSOR_POOL, decompressor);
}
 

public void returnDecompressor(Decompressor decompressor) {
  if (decompressor != null) {
    if (LOG.isTraceEnabled()) LOG.trace("Returning decompressor " + decompressor + " to pool.");
    CodecPool.returnDecompressor(decompressor);
    if (decompressor.getClass().isAnnotationPresent(DoNotPool.class)) {
      if (LOG.isTraceEnabled()) LOG.trace("Ending decompressor " + decompressor);
      decompressor.end();
    }
  }
}
 

/**
 * Return the {@link Compressor} to the pool.
 *
 * @param compressor
 *          the <code>Compressor</code> to be returned to the pool
 */
public static void returnCompressor(Compressor compressor) {
  if (compressor == null) {
    return;
  }
  // if the compressor can't be reused, don't pool it.
  if (compressor.getClass().isAnnotationPresent(DoNotPool.class)) {
    return;
  }
  compressor.reset();
  payback(COMPRESSOR_POOL, compressor);
}
 

/**
 * Return the {@link Decompressor} to the pool.
 *
 * @param decompressor
 *          the <code>Decompressor</code> to be returned to the pool
 */
public static void returnDecompressor(Decompressor decompressor) {
  if (decompressor == null) {
    return;
  }
  // if the decompressor can't be reused, don't pool it.
  if (decompressor.getClass().isAnnotationPresent(DoNotPool.class)) {
    return;
  }
  decompressor.reset();
  payback(DECOMPRESSOR_POOL, decompressor);
}