resp.flushBuffer();
                return;
            }
        }

        try ( SmbFile file = openFile(pathInfo, server) ) {
            if ( file.isDirectory() ) {
                doDirectory(req, resp, file);
            }
            else {
                doFile(req, resp, file);
            }
        }
        catch ( SmbAuthException sae ) {
            if ( ssn != null ) {

    }

    @Deprecated
    @Override
    public File getPomFile() {
        return pomPath != null ? pomPath.toFile() : null;
    }

    @Override
    public Path getPomPath() {
        return pomPath;
    }

    @Deprecated
    @Override
    public DefaultModelBuildingRequest setPomFile(File pomFile) {

        }

        try {
            SmbFile file;

            if( ntlm != null ) {
                file = new SmbFile( "smb1:/" + pathInfo , ntlm );
            } else if( server == null ) {
                file = new SmbFile( "smb1://" );
            } else {
                file = new SmbFile( "smb1:/" + pathInfo );
            }

            if( file.isDirectory() ) {

}

// Open captures time taken to call os.Open
func Open(name string) (f *os.File, err error) {
	defer updateOSMetrics(osMetricOpen, name)(err)
	return os.Open(name)
}

// OpenFileDirectIO captures time taken to call disk.OpenFileDirectIO
func OpenFileDirectIO(name string, flag int, perm os.FileMode) (f *os.File, err error) {
	defer updateOSMetrics(osMetricOpenFileDirectIO, name)(err)

     */
    protected static File getBaseDir(final URL url, final String baseName) {
        assertArgumentNotNull("url", url);

        File file = URLUtil.toFile(url);
        final String[] paths = StringUtil.split(baseName, "/");
        for (final String path : paths) {
            file = file.getParentFile();
        }
        return file;
    }

    /**

/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *

    /** The key of the message: Synonym File */
    public static final String LABELS_SYNONYM_FILE = "{labels.synonymFile}";

    /** The key of the message: Stopwords File */
    public static final String LABELS_STOPWORDS_FILE = "{labels.stopwordsFile}";

    /** The key of the message: Stemmer Override File */

   *
   * <p><b>Warning:</b> If {@code to} represents an existing file, that file will be overwritten
   * with the contents of {@code from}. If {@code to} and {@code from} refer to the <i>same</i>
   * file, the contents of that file will be deleted.
   *
   * <p><b>{@link java.nio.file.Path} equivalent:</b> {@link
   * java.nio.file.Files#copy(java.nio.file.Path, java.nio.file.Path, java.nio.file.CopyOption...)}.

import (
	"context"
	"io"
	"sort"
	"strings"

	"github.com/minio/minio/internal/grid"
	xioutil "github.com/minio/minio/internal/ioutil"
	"github.com/valyala/bytebufferpool"
)

//go:generate msgp -file $GOFILE

// WalkDirOptions provides options for WalkDir operations.
type WalkDirOptions struct {
	// Bucket to scanner
	Bucket string

	// Directory inside the bucket.
	BaseDir string

//
// You should have received a copy of the GNU Affero General Public License
// along with this program.  If not, see <http://www.gnu.org/licenses/>.

//go:generate msgp -file=$GOFILE

package cmd

import (
	"context"
	"encoding/binary"
	"errors"
	"fmt"
	"io"
	"sync"
	"sync/atomic"
	"time"

	"github.com/google/uuid"
	"github.com/minio/madmin-go/v3"