assertThat(stats.loadSuccessCount()).isEqualTo(computeCount.get());
    assertThat(stats.loadExceptionCount()).isEqualTo(exceptionCount.get() + computeNullCount.get());
    // each computed value is still in the cache, or was passed to the removal listener
    assertThat(cache.size() + removalListener.size()).isEqualTo(computeCount.get());
  }

  @J2ktIncompatible
  @GwtIncompatible // NullPointerTester

    assertThat(stats.loadSuccessCount()).isEqualTo(computeCount.get());
    assertThat(stats.loadExceptionCount()).isEqualTo(exceptionCount.get() + computeNullCount.get());
    // each computed value is still in the cache, or was passed to the removal listener
    assertThat(cache.size() + removalListener.size()).isEqualTo(computeCount.get());
  }

  @J2ktIncompatible
  @GwtIncompatible // NullPointerTester

                    if (!thumbnailManager.offer(doc)) {
                        if (logger.isDebugEnabled()) {
                            logger.debug("Removing {}={} from doc[{}]", thumbnailField, doc.get(thumbnailField),
                                    doc.get(fessConfig.getIndexFieldUrl()));
                        }
                        doc.remove(thumbnailField);
                    }
                });
            }

  end
  extra_with_lintian = <<-SHELL
    #{extra}
    install lintian
  SHELL
  linux_common(
    config,
    name,
    update_command: 'apt-get update',
    update_tracking_file: '/var/cache/apt/archives/last_update',
    install_command: 'apt-get install -y --force-yes',
    extra: extra_with_lintian
  )
end

def ubuntu_docker(config)

        } finally {
            super.finalize();
        }
    }

    /**
     * Gets the current usage count for this transport.
     *
     * @return the number of known usages
     */
    protected long getUsageCount() {
        return this.usageCount.get();
    }

    /**
     * Generate a unique key for the given request
     *

  @Override
  public @Nullable V get(@Nullable Object key) {
    if (key == null) {
      return null;
    }
    int hash = hash(key);
    return segmentFor(hash).get(key, hash);
  }

  @CanIgnoreReturnValue // TODO(b/27479612): consider removing this
  V get(K key, CacheLoader<? super K, V> loader) throws ExecutionException {

            kryo.register(clazz);
        } catch (final Exception e) {
            logger.warn("Failed to register class for Kryo serialization: {}", clazz.getName(), e);
        }
    }

    /**
     * Gets the configured serializer type from the Fess configuration.
     *
     * @return the serializer type (either "kryo" or "javabin")
     */
    protected String getSerializerType() {

            } catch (final Exception e) {
                logger.error("Could not destroy a process correctly.", e);
            }
        }
        return -1;
    }

    /**
     * Gets the set of session IDs for all currently running processes.
     *
     * @return set of session IDs for running processes
     */
    public Set<String> getRunningSessionIdSet() {

   * It is set by a client who only wants to make a request if it can be fully satisfied by the
   * cache. Cached responses that would require validation (ie. conditional gets) are not permitted
   * if this header is set.
   */
  @get:JvmName("onlyIfCached") val onlyIfCached: Boolean,
  @get:JvmName("noTransform") val noTransform: Boolean,
  @get:JvmName("immutable") val immutable: Boolean,

  @Override
  public @Nullable V get(@Nullable Object key) {
    if (key == null) {
      return null;
    }
    int hash = hash(key);
    return segmentFor(hash).get(key, hash);
  }

  @CanIgnoreReturnValue // TODO(b/27479612): consider removing this
  V get(K key, CacheLoader<? super K, V> loader) throws ExecutionException {