assertTrue(type1Token.length > 0);

        // Decode the token to verify its properties
        Type1Message type1Message = new Type1Message(type1Token);
        // Type1Message ORs default flags with provided flags; ensure expected bits are present
        assertTrue((type1Message.getFlags() & context.ntlmsspFlags) == context.ntlmsspFlags);
        assertEquals(domain, type1Message.getSuppliedDomain());
    }

    @Test

    }

    /**
     * Sets additional information flags for the query
     *
     * @param additionalInformation
     *            the additionalInformation to set
     */
    public final void setAdditionalInformation(final int additionalInformation) {
        this.additionalInformation = additionalInformation;
    }

    /**
     * Sets the query flags for the information request
     *
     * @param queryFlags

 VersionID [16]byte  // Version UUID, raw.
 ModTime   int64     // Unix nanoseconds.
 Signature [4]byte   // Signature of metadata.
 Type      uint8     // Type if the version
 Flags     uint8
}
```

The following flags are defined:

```
const (
 FreeVersion = 1 << 0
 UsesDataDir = 1 << 1
 InlineData  = 1 << 2
)
```

        assertEquals(250, SmbConstants.DEFAULT_SSN_LIMIT);
        assertEquals(35000, SmbConstants.DEFAULT_CONN_TIMEOUT);
    }

    @Test
    @DisplayName("Should define SMB flags constants")
    void testSmbFlags() {
        assertEquals(0x00, SmbConstants.FLAGS_NONE);
        assertEquals(0x01, SmbConstants.FLAGS_LOCK_AND_READ_WRITE_AND_UNLOCK);

# "contrib".
if "__all__" in vars():
  vars()["__all__"].append("contrib")

from tensorflow.python.platform import flags
# The "app" module will be imported as part of the placeholder section above.
_current_module.app.flags = flags  # pylint: disable=undefined-variable
setattr(_current_module, "flags", flags)

_major_api_version = 1

# Add module aliases from Keras to TF.
# Some tf endpoints actually lives under Keras.

        }

        @Test
        @DisplayName("Should handle all flags set")
        void testAllFlagsSet() {
            int allFlags = 0xFFFFFFFF;
            testMessage.addFlags(allFlags);
            assertEquals(allFlags, testMessage.getFlags());

            // Should still be able to clear specific flags
            testMessage.clearFlags(ServerMessageBlock2.SMB2_FLAGS_SIGNED);

                // need fragementation
                msg.flags &= ~DCERPC_LAST_FRAG;
                fragSize = this.max_xmit - 24;
            } else {
                msg.flags |= DCERPC_LAST_FRAG;
                msg.alloc_hint = fragSize;
            }

            msg.length = 24 + fragSize;

            if (off > 0) {
                msg.flags &= ~DCERPC_FIRST_FRAG;
            }

     * @param off the start offset in the data
     * @param len the number of bytes to write
     * @param flags write operation flags
     * @throws IOException if an I/O error occurs
     */
    public void writeDirect(final byte[] b, int off, int len, final int flags) throws IOException {
        if (len <= 0) {
            return;
        }

        if (tmp == null) {

     *
     * @return descriptive text for the ACE scope
     */
    String getApplyToText();

    /**
     * Returns the flags for this ACE. The <code>isInherited()</code>
     * method checks the <code>FLAGS_INHERITED</code> bit in these flags.
     *
     * @return the ACE flags
     */
    int getFlags();

    /**
     * Returns true if this ACE is an inherited ACE and false if it is a direct ACE.

        // Command at +12
        SMBUtil.writeInt2(command, buf, start + 12);
        // Flags at +16: server-to-redirector
        SMBUtil.writeInt4(0x00000001, buf, start + 16);
        // SessionId at +40 (sync header)
        SMBUtil.writeInt8(sessionId, buf, start + 40);
    }

    /**
     * Build a SESSION_SETUP response body with specified flags and security blob.
     * securityBufferOffset is set relative to header start.
     */