}

    /**
     * Initialize the output stream with the tree handle configuration.
     *
     * @param th the tree handle to use for configuration
     * @throws CIFSException if an error occurs during initialization
     */
    protected final void init(final SmbTreeHandleImpl th) throws CIFSException {
        final int sendBufferSize = th.getSendBufferSize();
        if (this.smb2) {

		w.Header()[xhttp.ETag] = []string{`"` + objInfo.ETag + `"`}
	}

	// Set the relevant version ID as part of the response header.
	if objInfo.VersionID != "" && objInfo.VersionID != nullVersionID {
		w.Header()[xhttp.AmzVersionID] = []string{objInfo.VersionID}
		// If version is a deleted marker, set this header as well
		if objInfo.DeleteMarker && del { // only returned during delete object

        SmbTreeConnection freshConnection = mock(SmbTreeConnection.class);
        when(freshConnection.acquire()).thenReturn(freshConnection);

        // Should not throw NPE during construction
        SmbTreeHandleImpl handleWithNullLoc = new SmbTreeHandleImpl(null, freshConnection);
        assertNotNull(handleWithNullLoc);

        // But operations that use resourceLoc might fail

        // CIFS context returns same config to build responses during initResponse
        lenient().when(cifsContext.getConfig()).thenReturn(config);
    }

    @AfterEach
    void teardown() {
        // No global state to reset beyond mocks
    }

    static Stream<String> wildcardProvider() {
        return Stream.of(null, "", "*");
    }

    @ParameterizedTest

 * for that key. The subclass should not call {@link #createCollection()} directly, and a new
 * instance should be created every time the method is called.
 *
 * <p>For example, the subclass could pass a {@link java.util.TreeMap} during construction, and
 * {@link #createCollection()} could return a {@link java.util.TreeSet}, in which case the
 * multimap's iterators would propagate through the keys and values in sorted order.
 *

       *   rowEntry at least once.
       *
       * - The only case in which rowEntry is cleared (during remove() below) happens only if the
       *   caller removed every element from columnIterator. During that process, we would have had
       *   to iterate it to exhaustion. Then we can apply the logic above about an empty

     *
     * @return the application type string "FES"
     */
    @Override
    protected String myAppType() { // for framework
        return APP_TYPE;
    }

    /**
     * Returns the user type identifier for this application.
     *
     * @return an optional containing the user type string "A" for Admin
     */
    @Override
    protected OptionalThing<String> myUserType() { // for framework

		Bucket             string
		KeyMarker          string
		UploadIDMarker     string `xml:"UploadIdMarker"`
		NextKeyMarker      string
		NextUploadIDMarker string `xml:"NextUploadIdMarker"`
		EncodingType       string
		MaxUploads         int
		IsTruncated        bool
		// All the in progress multipart uploads.
		Uploads []struct {
			Key          string
			UploadID     string `xml:"UploadId"`

// the 'writeQuorum' this function returns '0' if quorum cannot
// be achieved and disks have too many inconsistent versions.
func reduceCommonDataDir(dataDirs []string, writeQuorum int) (dataDir string) {
	dataDirsCount := make(map[string]int)
	for _, ddir := range dataDirs {
		dataDirsCount[ddir]++
	}

	maxCnt := 0
	for ddir, count := range dataDirsCount {
		if maxCnt < count {
			maxCnt = count

            thread.start();
        }
    }

    void tryClose() {
        synchronized (LOCK) {

            /* Yes, there is the potential to drop packets
             * because we might close the socket during a
             * request. However the chances are slim and the
             * retry code should ensure the overall request
             * is serviced. The alternative complicates things