defaultDomainField.setAccessible(true);
        defaultDomainField.set(explorer, null);
    }

    /**
     * Helper method to create a mocked NetworkExplorer instance
     */
    private NetworkExplorer createMockedNetworkExplorer(boolean enableBasic, String realm) {
        return new NetworkExplorer() {
            @Override

    protected ContentLengthHelper contentLengthHelper;

    /** The SMB authentication holder. */
    protected volatile SmbAuthenticationHolder smbAuthenticationHolder;

    /**
     * Creates a new SmbClient instance.
     */
    public SmbClient() {
        super();
    }

    @Override
    public synchronized void init() {
        if (smbAuthenticationHolder != null) {
            return;
        }

     *
     * Only use this method if you have prior knowledge that the receiving server supports
     * gzip-compressed requests.
     *
     * It is an error to call this multiple times on the same instance.
     *
     * @throws IllegalStateException if this request doesn't have a request body, or if it already
     *     has a 'Content-Encoding' header.
     */
    fun gzip() =
      apply {

    assertEquals(
        com.google.common.base.Optional.of("2"),
        generator.generateFresh(new TypeToken<com.google.common.base.Optional<String>>() {}));
    // Test that the first generated instance for different cgcb.Optional<T> is always absent().
    // Having generated cgcb.Optional<String> instances doesn't prevent absent() from being
    // generated for other cgcb.Optional types.
    assertEquals(

    assertEquals("[]", new AtomicDoubleArray(0).toString());
    assertEquals("[]", new AtomicDoubleArray(new double[0]).toString());
  }

  /** compareAndSet treats +0.0 and -0.0 as distinct values */
  public void testDistinctZeros() {
    AtomicDoubleArray aa = new AtomicDoubleArray(SIZE);
    for (int i : new int[] {0, SIZE - 1}) {
      assertFalse(aa.compareAndSet(i, -0.0, 7.0));

            SessionServicePacket.readPacketType(mockInputStream, buffer, 0);
        });

        assertEquals("unexpected EOF reading netbios session header", exception.getMessage());
    }

    // Tests for instance methods

    @Test
    @DisplayName("writeWireFormat should write header and trailer")
    void testWriteWireFormat() {
        packet.type = SessionServicePacket.SESSION_MESSAGE;

            byte[] buffer2 = createValidCopyChunkResponse(20, 8192, 163840);

            response1.decode(buffer1, 0, buffer1.length);
            response2.decode(buffer2, 0, buffer2.length);

            // Each instance should maintain its own state
            assertEquals(10, response1.getChunksWritten());
            assertEquals(4096, response1.getChunkBytesWritten());
            assertEquals(40960, response1.getTotalBytesWritten());

versioning unchanged." fi # At this point, the bucket should exist, skip checking for existence # Set policy on the bucket echo "Setting policy of bucket '$BUCKET' to '$POLICY'." ${MC} policy set $POLICY myminio/$BUCKET } # Try connecting to Minio instance {{- if .Values.tls.enabled }} scheme=https {{- else }} scheme=http {{- end }} connectToMinio $scheme {{ if .Values.buckets }} # Create the buckets {{- range .Values.buckets }} createBucket {{ .name }} {{ .policy }} {{ .purge }} {{ .versioning }}...

  @SuppressWarnings("GoodTime") // should be a java.time.Duration
  private final long totalLoadTime;

  private final long evictionCount;

  /**
   * Constructs a new {@code CacheStats} instance.
   *
   * <p>Five parameters of the same type in a row is a bad thing, but this class is not constructed
   * by end users and is too fine-grained for a builder.
   */

    return CollectCollectors.toImmutableRangeMap(keyFunction, valueFunction);
  }

  /**
   * Returns an empty immutable range map.
   *
   * <p><b>Performance note:</b> the instance returned is a singleton.
   */
  @SuppressWarnings("unchecked")
  public static <K extends Comparable<?>, V> ImmutableRangeMap<K, V> of() {
    return (ImmutableRangeMap<K, V>) EMPTY;
  }