private int dataMb;

    private BytesReference pagedBytes;

    private StreamInput streamInput;

    @Setup
    public void initResults() throws IOException {
        final BytesStreamOutput tmp = new BytesStreamOutput();
        final long bytes = new ByteSizeValue(dataMb, ByteSizeUnit.MB).getBytes();
        for (int i = 0; i < bytes / 8; i++) {
            tmp.writeLong(i);
        }
        pagedBytes = tmp.bytes();

/**
 * Simple base class to verify that we handle generics correctly.
 *
 * @author Kevin Bourrillion
 */
@GwtCompatible
public class BaseComparable implements Comparable<BaseComparable>, Serializable {
  private final String s;

  public BaseComparable(String s) {
    this.s = s;
  }

  @Override
  public int hashCode() { // delegate to 's'
    return s.hashCode();
  }

  @Override

    @Subscribe
    public abstract void overriddenInSubclass(Object o);
  }

  static class SubClass extends SuperClass {
    final List<Object> overriddenAndAnnotatedInSubclassEvents = new ArrayList<>();
    final List<Object> overriddenInSubclassEvents = new ArrayList<>();

    @Subscribe
    @Override
    public void overriddenAndAnnotatedInSubclass(Object o) {

import java.util.Date;

import org.codehaus.plexus.interpolation.AbstractValueSource;

/**
 *
 */
@Deprecated
public class BuildTimestampValueSource extends AbstractValueSource {

    private final Date startTime;

    private final String format;

    private String formattedDate;

    public BuildTimestampValueSource(Date startTime, String format) {
        super(false);
        this.startTime = startTime;

/**
 * Base class for requests.
 *
 * @since 4.0.0
 */
@Experimental
abstract class BaseRequest<S extends ProtoSession> implements Request<S> {

    private final S session;
    private final RequestTrace trace;

    protected BaseRequest(@Nonnull S session) {
        this(session, null);
    }

    protected BaseRequest(@Nonnull S session, RequestTrace trace) {

import org.apache.maven.project.artifact.ProjectArtifactsCache;

public class SetWithResolutionResult extends AbstractSet<Artifact>
        implements ProjectArtifactsCache.ArtifactsSetWithResult {
    final DependencyResolutionResult result;
    final Set<Artifact> artifacts;

    public SetWithResolutionResult(DependencyResolutionResult result, Set<Artifact> artifacts) {
        this.result = result;

 * @author Kyle Maddison
 * @author Geoff Pike
 */
final class FarmHashFingerprint64 extends AbstractNonStreamingHashFunction {
  static final HashFunction FARMHASH_FINGERPRINT_64 = new FarmHashFingerprint64();

  // Some primes between 2^63 and 2^64 for various uses.
  private static final long K0 = 0xc3a5c85c97cb3127L;
  private static final long K1 = 0xb492b66fbe98f273L;
  private static final long K2 = 0x9ae16a3b2f90404fL;

  @Override

    /**
     * Context name for directory lease request
     */
    public static final String NAME_DIRECTORY_REQUEST = "DLse";

    /**
     * Context name for directory lease response
     */
    public static final String NAME_DIRECTORY_RESPONSE = "DLse";

    private static final byte[] CONTEXT_NAME_BYTES = NAME_DIRECTORY_REQUEST.getBytes();

    /**
     * Directory lease flag for recursive caching

   * implementation type is an implementation detail.
   */
  @J2ktIncompatible // serialization
  private static final class SerializedForm<E> implements Serializable {
    final Comparator<? super E> comparator;
    final Object[] elements;

    SerializedForm(Comparator<? super E> comparator, Object[] elements) {
      this.comparator = comparator;
      this.elements = elements;

     * @return concatenated string of localized validation messages separated by spaces
     */
    protected String getMessage(final VaMessenger<FessMessages> validationMessagesLambda) {
        final FessMessages messages = new FessMessages();
        validationMessagesLambda.message(messages);