static final Logger logger = LogManager.getLogger(GenerateThumbnailJob.class);

    /** Number of threads to use for thumbnail generation. */
    protected int numOfThreads = 1;

    /** Flag indicating whether to perform cleanup operations. */
    protected boolean cleanup = false;

    /**
     * Default constructor for the GenerateThumbnailJob.
     */
    public GenerateThumbnailJob() {
        super();

    @DisplayName("Should handle various NTLM flags")
    void testVariousNTLMFlags(int flag) {
        // When
        Type1Message type1 = new Type1Message(mockContext, flag, null, null);

        // Then
        assertTrue((type1.getFlags() & flag) != 0);
    }

    @Test
    @DisplayName("Should include NTLMSSP signature")
    void testNTLMSSPSignature() throws IOException {

            for (int flag : fragmentFlags) {
                assertTrue(flag >= 0x00 && flag <= 0xFF,
                        String.format("Fragment flag 0x%02X should be in valid byte range 0x00-0xFF", flag));
            }
        }

        @Test
        @DisplayName("RPC packet flags should be within byte range")

                ACE.FLAGS_INHERITED })
        @DisplayName("Flag constants should be powers of 2")
        void shouldBeValidFlagPowersOfTwo(int flag) {
            assertTrue(flag > 0, "Flag should be positive");
            assertEquals(0, flag & (flag - 1), "Flag should be power of 2: " + Integer.toHexString(flag));
        }

        @Test
        @DisplayName("Should validate all constants are unique")

    public static final byte SMB2_SHARE_TYPE_PRINT = 0x3;

    /**
     * Share flag indicating manual caching of documents.
     */
    public static final int SMB2_SHAREFLAG_MANUAL_CACHING = 0x0;
    /**
     * Share flag indicating automatic caching of documents.
     */
    public static final int SMB2_SHAREFLAG_AUTO_CACHING = 0x10;
    /**
     * Share flag indicating automatic caching of programs and documents.
     */

	bucketToList string
)

func init() {
	flag.StringVar(&stsEndpoint, "sts-ep", "http://localhost:9000", "STS endpoint")
	flag.StringVar(&token, "t", "", "Token to use with AssumeRoleWithCustomToken STS API (required)")
	flag.StringVar(&roleArn, "r", "", "RoleARN to use with the request (required)")
	flag.BoolVar(&displayCreds, "d", false, "Only show generated credentials")

}

// OpenFile captures time taken to call os.OpenFile
func OpenFile(name string, flag int, perm os.FileMode) (f *os.File, err error) {
	switch flag & writeMode {
	case writeMode:
		defer updateOSMetrics(osMetricOpenFileW, name)(err)
	default:
		defer updateOSMetrics(osMetricOpenFileR, name)(err)
	}
	return os.OpenFile(name, flag, perm)
}

// Access captures time taken to call syscall.Access()

    /** Inheritance flag: child objects inherit this ACE */
    public static final int FLAGS_OBJECT_INHERIT = 0x01;
    /** Inheritance flag: child containers inherit this ACE */
    public static final int FLAGS_CONTAINER_INHERIT = 0x02;
    /** Inheritance flag: inheritance stops after one level */
    public static final int FLAGS_NO_PROPAGATE = 0x04;

    }

    @Nested
    @DisplayName("Flag Constants Tests")
    class FlagConstantsTests {

        @Test
        @DisplayName("Should have correct shared lock flag value")
        void testSharedLockFlag() {
            assertEquals(0x1, Smb2Lock.SMB2_LOCKFLAG_SHARED_LOCK);
        }

        @Test
        @DisplayName("Should have correct exclusive lock flag value")
        void testExclusiveLockFlag() {

     * Processes Google on/off comment directives in the node.
     *
     * @param node the node to process
     * @param flag the flag indicating whether content should be included
     * @return the processed node
     */
    protected Node processGoogleOffOn(final Node node, final ValueHolder<Boolean> flag) {
        final NodeList nodeList = node.getChildNodes();
        List<Node> removedNodeList = null;