return
	}

	// Ensure body content type is opaque to ensure that request body has not
	// been interpreted as form data.
	contentType := r.Header.Get("Content-Type")
	if contentType != "application/octet-stream" {
		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrBadRequest), r.URL)
		return
	}

	password := cred.SecretKey

	defer cancel()

	req, err := http.NewRequestWithContext(ctx, http.MethodGet, serverURL.String(), nil)
	if err != nil {
		return err
	}
	// Indicate that the liveness check for a peer call
	req.Header.Set(xhttp.MinIOPeerCall, "true")

	resp, err := httpClient.Do(req)
	if err != nil {
		return err
	}
	xhttp.DrainBody(resp.Body)

	return nil
}

	}
}

// getTransitionedObjectReader returns a reader from the transitioned tier.
func getTransitionedObjectReader(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, h http.Header, oi ObjectInfo, opts ObjectOptions) (gr *GetObjectReader, err error) {
	tgtClient, err := globalTierConfigMgr.getDriver(ctx, oi.TransitionedObject.Tier)
	if err != nil {

    @Test
    void readWireFormat_shouldDelegateToParent() {
        // Arrange
        nodeStatusRequest = new NodeStatusRequest(mockConfig, mockName);
        byte[] src = new byte[200];
        // Setup minimal valid header
        src[0] = 0x00;
        src[1] = 0x01; // Transaction ID
        src[2] = 0x00; // Flags
        src[3] = 0x00; // Flags
        src[4] = 0x00;
        src[5] = 0x01; // Question count

        assertTrue(s.contains("totalParameterCount="), "string representation contains totalParameterCount field");
    }

    /**
     * Verify that readParameterWordsWireFormat parses the SMB header
     * correctly and updates all relevant members.
     */
    @Test
    public void readParameterWordsWireFormat_parsesHeaderCorrectly() {
        DummyResponse d = new DummyResponse();

	return ((data >= parity) && (data > 0) && (parity >= 0))
}

//msgp:clearomitted

//go:generate msgp -file=$GOFILE -unexported

// A xlMetaV1Object represents `xl.meta` metadata header.
type xlMetaV1Object struct {
	Version string   `json:"version"` // Version of the current `xl.meta`.
	Format  string   `json:"format"`  // Format of the current `xl.meta`.

# Below should fail as compression and SSEC used at the same time
# DISABLED: We must check the response header to see if compression was actually applied
#RESULT=$({ ./mc put /tmp/data/mpartobj.txt minio1/test-bucket/mpartobj.txt --enc-c "minio1/test-bucket/mpartobj.txt=${TEST_MINIO_ENC_KEY}" --insecure; } 2>&1)

        logger.info("itemList: {}", itemList);
        return itemList;
    }

    protected static Response deleteMethod(final String path) {
        return given().contentType("application/json").header("Authorization", getTestToken()).delete(path);
    }

    protected static void deleteDocuments(final String queryString) {
        List<String> docIds = new ArrayList<>();

    call.eventListener.responseHeadersEnd(call, response)
  }

  @Throws(IOException::class)
  fun openResponseBody(response: Response): ResponseBody {
    try {
      val contentType = response.header("Content-Type")
      val contentLength = codec.reportedContentLength(response)
      val rawSource = codec.openResponseBodySource(response)
      val source =
        ResponseBodySource(
          delegate = rawSource,

        byte[] expectedBytes = unicodeFileName.getBytes(StandardCharsets.UTF_16LE);
        assertEquals(32 + expectedBytes.length, bytesWritten);

        // Verify filename length in header
        int fnLength = buffer[Smb2Constants.SMB2_HEADER_LENGTH + 26] | (buffer[Smb2Constants.SMB2_HEADER_LENGTH + 27] << 8);
        assertEquals(expectedBytes.length, fnLength);
    }

    @Test