private String nbName;
        private ASN1ObjectIdentifier[] supportedMechs;
        private int flags;
        private boolean integrity;
        private boolean disposed;

        DummySSPContext(byte[] signingKey, boolean established, String nbName, ASN1ObjectIdentifier[] supportedMechs, int flags,
                boolean integrity) {
            this.signingKey = signingKey;

  @Override
  protected abstract BlockingQueue<E> delegate();

  @CanIgnoreReturnValue
  @Override
  public int drainTo(Collection<? super E> c, int maxElements) {
    return delegate().drainTo(c, maxElements);
  }

  @CanIgnoreReturnValue
  @Override
  public int drainTo(Collection<? super E> c) {
    return delegate().drainTo(c);
  }

  @CanIgnoreReturnValue // TODO(kak): consider removing this

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

    /** Maximum number of retry attempts for failed operations */
    protected int maxRetryCount = 5;

    /** Default number of rows to process in a single batch */
    protected int defaultRowSize = 100;

    /**
     * Default constructor for indexing helper.
     * Creates a new instance with default values.
     */

    /**
     * Do not instantiate.
     */
    protected DateConversionUtil() {
    }

    /** Array of styles held by {@link DateFormat}. */
    protected static final int[] STYLES = new int[] { SHORT, MEDIUM, LONG, FULL };

    /**
     * Returns the pattern string for {@link DateFormat#SHORT} style in the default locale.
     *
     * @return the pattern string for {@link DateFormat#SHORT} style

    }

    /**
     * @param stackTrace
     * @return
     */
    private static StackTraceElement[] truncateTrace(final StackTraceElement[] stackTrace) {

        int s = 2;
        int e = stackTrace.length;

        for (int i = s; i < e; i++) {
            final StackTraceElement se = stackTrace[i];

        void testGetDefaultFlags_CIFSContext_Unicode() {
            // Given
            CIFSContext mockContext = createMockContext();

            // When
            int flags = Type2Message.getDefaultFlags(mockContext);

            // Then
            int expectedFlags =
                    Type2Message.NTLMSSP_NEGOTIATE_NTLM | Type2Message.NTLMSSP_NEGOTIATE_VERSION | Type2Message.NTLMSSP_NEGOTIATE_UNICODE;

    void testLeaseStateAccessors() {
        int newState = Smb2LeaseState.SMB2_LEASE_FULL;

        leaseContext.setLeaseState(newState);
        assertEquals(newState, leaseContext.getLeaseState());
    }

    @Test
    @DisplayName("Should set and get lease flags")
    void testLeaseFlagsAccessors() {
        int newFlags = 0x12345678;

        leaseContext.setLeaseFlags(newFlags);

        // Test with max value
        SMBUtil.writeInt8(0xFFFFFFFFFFFFFFFFL, dst, 8);
        for (int i = 8; i < 16; i++) {
            assertEquals((byte) 0xFF, dst[i]);
        }

        // Test with zero
        SMBUtil.writeInt8(0L, dst, 16);
        for (int i = 16; i < 24; i++) {
            assertEquals((byte) 0x00, dst[i]);
        }
    }

    @Test

    private final AtomicLong totalSuccesses = new AtomicLong(0);
    private final AtomicLong rejectedCalls = new AtomicLong(0);

    // Configuration
    private final int failureThreshold;
    private final int successThreshold;
    private final long timeoutMillis;

    /**
     * Creates a simple circuit breaker with default settings
     *
     * @param name the circuit breaker name
     */

		// a size of 16 is encoded as `10` while a size of 64 KB
		// is `10000`.
		switch {
		case b >= '0' && b <= '9':
			size = size<<4 | int(b-'0')
		case b >= 'a' && b <= 'f':
			size = size<<4 | int(b-('a'-10))
		case b >= 'A' && b <= 'F':
			size = size<<4 | int(b-('A'-10))
		default:
			if cr.debug {
				fmt.Printf("err size: %v\n", string(b))
			}
			cr.err = errMalformedEncoding
			return n, cr.err