log.debug("Secure negotiation failure");
            throw new CIFSException("Mismatched attributes validating negotiate info");
        }

        log.debug("Secure negotiation OK");
    }

    /**
     * @param transport
     * @return
     * @throws SmbException
     */
    private int waitForState(final SmbTransportImpl transport) throws SmbException {
        int cs;

        if (method.getDeclaringClass().equals(TypeVariableImpl.class)) {
          try {
            method.setAccessible(true);
          } catch (AccessControlException e) {
            // OK: the method is accessible to us anyway. The setAccessible call is only for
            // unusual execution environments where that might not be true.
          }
          builder.put(method.getName(), method);
        }

      }
    }
    throw new IndexOutOfBoundsException("Index exceeds specified range");
  }

  /**
   * Helper method to grow the character buffer as needed, this only happens once in a while so it's
   * ok if it's in a method call. If the index passed in is 0 then no copying will be done.
   */
  private static char[] growBuffer(char[] dest, int index, int size) {

            Response
              .Builder()
              .request(chain!!.request())
              .protocol(Protocol.HTTP_1_1)
              .code(200)
              .message("OK")
              .body("a".toResponseBody(null))
              .build()
          },
        ).build()
    val call = client.newCallWithListener(Request.Builder().url(server.url("/")).build())

         * only way to get a TypeVariable instance for the resolved types is to create our own. The
         * created TypeVariable will not interoperate with any JDK TypeVariable. But this is OK: We
         * don't _want_ our new TypeVariable to be equal to the JDK TypeVariable because it has
         * _different bounds_ than the JDK TypeVariable. And it wouldn't make sense for our new

    protected static final String CRAWLER_CLIENTS = "crawlerClients";

    /** HTTP status code for Not Found */
    private static final int HTTP_STATUS_NOT_FOUND = 404;

    /** HTTP status code for OK */
    private static final int HTTP_STATUS_OK = 200;

    /**
     * Cache for client rules mapping client names to their corresponding URL patterns.

    ) {
      val url = "http://example.com/websocket"
      val response =
        Response
          .Builder()
          .code(101)
          .message("OK")
          .request(Request.Builder().url(url).build())
          .headers(responseHeaders!!)
          .protocol(Protocol.HTTP_1_1)
          .build()
      webSocket =
        RealWebSocket(

	bucketName := "bucket"
	objectName := "myobject"
	err = obj.MakeBucket(ctx, bucketName, MakeBucketOptions{
		VersioningEnabled: true,
	})
	if err != nil {
		t.Fatal(err)
	}

	z, ok := obj.(*erasureServerPools)
	if !ok {
		t.Fatal("unexpected object layer type")
	}

	versions := make([]string, 2)
	for i := range z.serverPools {
		objInfo, err := z.serverPools[i].PutObject(ctx, bucketName, objectName,

			entries = append(entries, ch)
		}
		out := make(chan metaCacheEntry, 1)
		err := mergeEntryChannels(t.Context(), entries, out, 1)
		if err != nil {
			t.Fatal(err)
		}
		got, ok := <-out
		if !ok {
			t.Fatal("Got no result")
		}

		xl, err := got.xlmeta()
		if err != nil {
			t.Fatal(err)
		}
		if len(xl.versions) != 3 {

   * GWT SortedMap implementation that we delegate to throws
   * NullPointerException if the comparator does. Since our construction
   * methods ensure that null is never present in the map, it's OK for the
   * comparator to look for it wherever it wants.
   *
   * Note that we do NOT touch the comparator returned by comparator(), which
   * should be identical to the one the user passed in. We touch only the