}
    }

    protected void mergeFileSet(FileSet target, FileSet source, boolean sourceDominant, Map<Object, Object> context) {
        mergePatternSet(target, source, sourceDominant, context);
        mergeFileSet_Directory(target, source, sourceDominant, context);
    }

    protected void mergeFileSet_Directory(
            FileSet target, FileSet source, boolean sourceDominant, Map<Object, Object> context) {

pkg debug/pe, const IMAGE_FILE_MACHINE_ARMNT ideal-int
pkg expvar, method (*Map) Delete(string)
pkg go/doc, const PreserveAST = 4
pkg go/doc, const PreserveAST Mode
pkg go/importer, func ForCompiler(*token.FileSet, string, Lookup) types.Importer
pkg go/token, method (*File) LineStart(int) Pos
pkg io, type StringWriter interface { WriteString }
pkg io, type StringWriter interface, WriteString(string) (int, error)

        return "Scm {connection=" + getConnection() + "}";
    }
            ]]>
          </code>
        </codeSegment>
      </codeSegments>
    </class>
    <class>
      <name>FileSet</name>
      <version>3.0.0+</version>
      <superClass>PatternSet</superClass>
      <description>A PatternSet for files.</description>
      <fields>
        <field>
          <name>directory</name>

# CL 135110044 go/token: implement PositionFor accessors, Robert Griesemer <******@****.***>
pkg go/token, method (*File) PositionFor(Pos, bool) Position
pkg go/token, method (*FileSet) PositionFor(Pos, bool) Position

# CL 109000049 image: add RGBAAt, Gray16At, etc., ChaiShushan <******@****.***>
pkg image, method (*Alpha) AlphaAt(int, int) color.Alpha

pkg go/token, method (*FileSet) AddFile(string, int, int) *File
pkg go/token, method (*FileSet) Base() int
pkg go/token, method (*FileSet) File(Pos) *File
pkg go/token, method (*FileSet) Iterate(func(*File) bool)
pkg go/token, method (*FileSet) Position(Pos) Position
pkg go/token, method (*FileSet) Read(func(interface{}) error) error
pkg go/token, method (*FileSet) Write(func(interface{}) error) error

	handler := &sftpDriver{
		endpoint:    fmt.Sprintf("127.0.0.1:%s", globalMinioPort),
		permissions: perms,
		remoteIP:    remoteIP,
	}
	return sftp.Handlers{
		FileGet:  handler,
		FilePut:  handler,
		FileCmd:  handler,
		FileList: handler,
	}
}

type forwardForTransport struct {
	tr  http.RoundTripper
	fwd string
}

var errLimitExceeded = errors.New("the maximum store limit reached")

// QueueStore - Filestore for persisting items.
type QueueStore[_ any] struct {
	sync.RWMutex
	entryLimit uint64
	directory  string
	fileExt    string

	entries map[string]int64 // key -> modtime as unix nano
}

// NewQueueStore - Creates an instance for QueueStore.
func NewQueueStore[I any](directory string, limit uint64, ext string) *QueueStore[I] {

            assertEquals("smb://server/share/path/", loc.getParent());
            assertEquals(url, loc.getPath());
            // canonicalisation simply removes '.' and '..'
            assertEquals("smb://server/share/path/filetxt", loc.getCanonicalURL());
            assertFalse(loc.isRoot());
        }
    }

    @Nested
    @DisplayName("Invalid inputs and edge cases")
    class Invalid {
        @Test

    manifest.getMainAttributes().put(Attributes.Name.CLASS_PATH, jarFile.getName());

    Closer closer = Closer.create();
    try {
      FileOutputStream fileOut = closer.register(new FileOutputStream(jarFile));
      JarOutputStream jarOut = closer.register(new JarOutputStream(fileOut, manifest));
      for (String entry : entries) {
        jarOut.putNextEntry(new ZipEntry(entry));

    manifest.getMainAttributes().put(Attributes.Name.CLASS_PATH, jarFile.getName());

    Closer closer = Closer.create();
    try {
      FileOutputStream fileOut = closer.register(new FileOutputStream(jarFile));
      JarOutputStream jarOut = closer.register(new JarOutputStream(fileOut, manifest));
      for (String entry : entries) {
        jarOut.putNextEntry(new ZipEntry(entry));