}
    
    public int getLeaseTimeout() {
        return getIntProperty(LEASE_TIMEOUT, 30000);  // 30 seconds default
    }
    
    public int getMaxLeases() {
        return getIntProperty(MAX_LEASES, 1000);  // Max concurrent leases
    }
    
    public int getLeaseVersion() {
        return getIntProperty(LEASE_VERSION, 2);  // Default to V2 if supported
    }
}
```

## 8. Testing Strategy

            assertEquals(2048, SMBUtil.readInt4(buffer, 4));

            // Test at position 100
            Arrays.fill(buffer, (byte) 0);
            bytesWritten = request.writeBytesWireFormat(buffer, 100);
            assertEquals(49, bytesWritten);
            assertEquals(2048, SMBUtil.readInt4(buffer, 104));
            assertEquals(4096L, SMBUtil.readInt8(buffer, 108));
        }

        @Test

		}
	}

	testCasesFailure := []struct {
		totalSize int64
		partSize  int64
		partIndex int
		err       error
	}{
		// partSize is 0, returns error.
		{10, 0, 1, errPartSizeZero},
		// partIndex is 0, returns error.
		{10, 1, 0, errPartSizeIndex},
		// Total size is -1, returns error.
		{-2, 10, 1, errInvalidArgument},
	}

                                               value="${f:h(crawlingThreadCount)}" class="form-control"
                                               min="1" max="1000">
                                    </div>
                                </div>
                                <div class="form-group row">

	"github.com/minio/minio/internal/logger"
	"github.com/minio/pkg/v3/policy"
	xxml "github.com/minio/xxml"
)

const (
	maxObjectList  = 1000  // Limit number of objects in a listObjectsResponse/listObjectsVersionsResponse.
	maxDeleteList  = 1000  // Limit number of objects deleted in a delete call.
	maxUploadsList = 10000 // Limit number of uploads in a listUploadsResponse.

        private final String output;

        public TestInputStreamThread(String output) {
            super(new java.io.ByteArrayInputStream(new byte[0]), java.nio.charset.StandardCharsets.UTF_8, 1000, null);
            this.output = output;
        }

        @Override
        public void start() {
            // Override start to do nothing in test - simulate immediate completion
        }

            verify(mockNdrBuffer, times(5)).enc_ndr_small((byte) 0);
            verify(mockNdrBuffer).enc_ndr_small((byte) 5);

            // Verify sub_authority values
            verify(mockNdrBuffer).enc_ndr_long(1000);
            verify(mockNdrBuffer).enc_ndr_long(2000);
        }

        @Test
        @DisplayName("Should decode SID correctly")
        void testSidTDecode() throws NdrException {

        // Test at different offsets
        int[] offsets = { 0, 10, 50, 100, 200 };

        for (int offset : offsets) {
            // Given
            byte[] buffer = new byte[1024];
            Smb2SessionSetupRequest req =
                    new Smb2SessionSetupRequest(mockContext, TEST_SECURITY_MODE, TEST_CAPABILITIES, TEST_PREVIOUS_SESSION_ID, TEST_TOKEN);

            // When

            .build(loader);

    // Increment 100 times
    for (int i = 0; i < 100; ++i) {
      cache.getUnchecked(10).incrementAndGet();
      ticker.advance(1, MILLISECONDS);
    }

    assertThat(applyCount.get()).isEqualTo(evictionCount.get() + 1);
    int remaining = cache.getUnchecked(10).get();
    assertThat(totalSum.get() + remaining).isEqualTo(100);
  }

  static final Integer N1 = 1;
  static final Integer N2 = 2;
  static final Integer N3 = 3;
  static final Integer N4 = 4;
  static final Integer N5 = 5;
  static final Integer NODE_NOT_IN_GRAPH = 1000;

  // TODO(user): Consider separating Strings that we've defined here to capture
  // identifiable substrings of expected error messages, from Strings that we've defined
  // here to provide error messages.