System.arraycopy(fileId, 0, buffer, 8, 16);
            return buffer;
        }
    }

    @Nested
    @DisplayName("Oplock Level Constants Tests")
    class OplockLevelTests {

        @ParameterizedTest
        @DisplayName("Should handle standard oplock levels")
        @MethodSource("provideOplockLevels")
        void testStandardOplockLevels(byte oplockLevel, String description) throws Exception {

    /**
     * No oplock
     */
    public static final byte SMB2_OPLOCK_LEVEL_NONE = 0x0;
    /**
     * Level II oplock
     */
    public static final byte SMB2_OPLOCK_LEVEL_II = 0x1;
    /**
     * Exclusive oplock
     */
    public static final byte SMB2_OPLOCK_LEVEL_EXCLUSIVE = 0x8;
    /**
     * Batch oplock
     */

        }
    }
    
    public void releaseLease(Smb2LeaseKey key) {
        lock.writeLock().lock();
        try {
            LeaseEntry entry = leases.remove(key);
            if (entry != null) {
                pathToLease.remove(entry.path);
            }
        } finally {
            lock.writeLock().unlock();
        }
    }
    
    private void flushCachedWrites(String path) {

        byte[] buffer = new byte[1024];
        request.writeBytesWireFormat(buffer, 0);
        assertEquals((byte) 0x01, buffer[2]);
    }

    @Test
    @DisplayName("Test oplock level setter")
    void testSetRequestedOplockLevel() {
        request = new Smb2CreateRequest(mockConfig, "test.txt");

        request.setRequestedOplockLevel(Smb2CreateRequest.SMB2_OPLOCK_LEVEL_BATCH);

    private static byte[] buildCreateBodyNoContexts(byte oplock, byte openFlags, int createAction, long ctime, long atime, long mtime,
            long chtime, long allocSize, long eof, int attrs, byte[] fileId) {
        byte[] body = new byte[2 + 2 + 4 + 8 + 8 + 8 + 8 + 8 + 8 + 4 + 4 + 16 + 4 + 4];
        int i = 0;
        SMBUtil.writeInt2(89, body, i); // StructureSize
        body[i + 2] = oplock;
        body[i + 3] = openFlags;
        i += 4;

    int FLAGS_NONE = 0x00;
    /** Lock and read write and unlock flag */
    int FLAGS_LOCK_AND_READ_WRITE_AND_UNLOCK = 0x01;
    /** Receive buffer posted flag */
    int FLAGS_RECEIVE_BUFFER_POSTED = 0x02;
    /** Path names are caseless flag */
    int FLAGS_PATH_NAMES_CASELESS = 0x08;
    /** Path names canonicalized flag */
    int FLAGS_PATH_NAMES_CANONICALIZED = 0x10;
    /** Oplock requested or granted flag */

        if (isReceived() && next instanceof RequestWithFileId) {
            ((RequestWithFileId) next).setFileId(this.fileId);
        }
        super.prepare(next);
    }

    /**
     * Get the oplock level granted by the server
     * @return the oplockLevel
     */
    public final byte getOplockLevel() {
        return this.oplockLevel;
    }

    /**
     * Get the open flags returned by the server

## Implementation Phases

### Phase 1: SMB3 Lease Implementation (Foundation)
**Priority: HIGH** | **Estimated Effort: 3-4 weeks**

SMB3 leases replace the traditional oplock mechanism and are foundational for other features.

#### 1.1 Core Lease Infrastructure
```
Package: jcifs.internal.smb2.lease
├── Smb2LeaseBreak.java          - Lease break notification handling

		globalHTTPStats.incS3RequestsIncoming()

		if r.Header.Get(globalObjectPerfUserMetadata) == "" {
			if val := globalServiceFreeze.Load(); val != nil {
				if unlock, ok := val.(chan struct{}); ok && unlock != nil {
					// Wait until unfrozen.
					select {
					case <-unlock:
					case <-r.Context().Done():
						// if client canceled we don't need to wait here forever.
						return
					}
				}
			}
		}

    Lock myLock = CycleDetectingLockFactory.newInstance(Policies.THROW).newReentrantLock("MyLock");
    lock03.lock();
    myLock.lock();
    lock03.unlock();

    PotentialDeadlockException expected =
        assertThrows(PotentialDeadlockException.class, () -> lock01.lock());
    checkMessage(
        expected,
        "MyLock -> OtherOrder.FIRST",
        "OtherOrder.THIRD -> MyLock",