void testForceCleanup() {
        TestResource resource1 = new TestResource("cleanup1");
        TestResource resource2 = new TestResource("cleanup2");

        resourceManager.registerResource(resource1);
        resourceManager.registerResource(resource2);

        assertFalse(resource1.isClosed());
        assertFalse(resource2.isClosed());

        int cleaned = resourceManager.forceCleanup();

    }

    /**
     * Create a managed resource wrapper
     *
     * @param <T> resource type
     * @param resource the resource to wrap
     * @return managed resource
     */
    public <T extends AutoCloseable> ManagedResource<T> manage(T resource) {
        String resourceId = registerResource(resource);
        return new ManagedResource<>(resource, resourceId, this);
    }

    /**

	}

	// No locks held on the all resources, so claim write
	// lock on all resources at once.
	now := UTCNow()
	for i, resource := range args.Resources {
		l.lockMap[resource] = []lockRequesterInfo{
			{
				Name:            resource,
				Writer:          true,
				Source:          args.Source,
				Owner:           args.Owner,
				UID:             args.UID,
				Timestamp:       now.UnixNano(),

        // Then
        assertNotNull(resource1, "First resource should be created");
        assertNotNull(resource2, "Second resource should be created");
        assertNotNull(pipe1, "First pipe should be created");
        assertNotNull(pipe2, "Second pipe should be created");

        assertNotSame(resource1, resource2, "Different resources should be different instances");

            assertTrue(resource.exists(), "Resource should exist");
            assertTrue(resource.isFile(), "Should be a file");
            assertTrue(resource.canWrite(), "Should be writable");

            // Should be able to perform file operations
            assertDoesNotThrow(() -> {
                resource.setReadOnly();
                resource.setReadWrite();
                resource.setAttributes(0x20);

		locksHeld[resource] = []lockRequesterInfo{lri}
	}

	// Add a few concurrent read locks to the mix
	for i := range 50 {
		resource := fmt.Sprintf("bucket/get-object-%d", i)
		lri := lockRequesterInfo{
			Name:   resource,
			UID:    mustGetUUID(),
			Owner:  owners[i%len(owners)],
			Quorum: 2,
		}
		lris = append(lris, lri)
		locksHeld[resource] = append(locksHeld[resource], lri)

        this.requestedResources = -1;
    }

    /**
     * Creates a resource exception with resource details
     *
     * @param message the error message
     * @param errorCode the SMB error code
     * @param resourceType the type of resource
     * @param available available resources
     * @param requested requested resources
     */

        assertTrue(iterator.hasNext());
        assertSame(resource, iterator.next());

        assertTrue(iterator.hasNext());
        assertSame(resource, iterator.next());

        assertTrue(iterator.hasNext());
        assertSame(resource, iterator.next());

        assertFalse(iterator.hasNext());
        assertNull(iterator.next());

        verify(resource, never()).close();
    }

    @Test

        } catch (final MissingResourceException ignore) {
            return null;
        }
    }

    /**
     * Returns the string for the specified key from the resource bundle.
     *
     * @param bundle the resource bundle (must not be {@literal null} or empty)
     * @param key the key
     * @return the string for the specified key (must not be {@literal null} or empty)

    /**
     * Get a resource
     *
     * @param url the URL of the SMB resource
     * @return the SMB resource at the specified location
     * @throws CIFSException if the resource cannot be accessed
     */
    SmbResource get(String url) throws CIFSException;

    /**
     * Get a pipe resource
     *
     * @param url the URL of the SMB pipe resource
     * @param pipeType