// Cleanup persistent handle manager
                if (persistentHandleManager != null) {
                    try {
                        persistentHandleManager.shutdown();
                        log.debug("Persistent handle manager shutdown on session logoff");
                    } catch (Exception e) {
                        log.warn("Error shutting down persistent handle manager during logoff", e);

                    // Expected to catch exception silently
                }
            }
        };

        FwAssistantDirector assistantDirector = createMockAssistantDirector();

        // Should handle ClassNotFoundException gracefully
        customHook.hook(assistantDirector);

        // Verify no exception is thrown to the caller
        assertTrue(true);
    }

        leaseManager.updateLease(key, grantedState);

        LeaseEntry entry = leaseManager.getLease(key);
        assertEquals(grantedState, entry.getLeaseState());
    }

    @Test
    @DisplayName("Should handle lease break")
    void testHandleLeaseBreak() {
        String path = "/share/file.txt";
        int initialState = Smb2LeaseState.SMB2_LEASE_FULL;
        int newState = Smb2LeaseState.SMB2_LEASE_READ_CACHING;

            // Should use caller available units, not actual free units
            assertEquals(500L * 8 * 512, fileFsFullSizeInfo.getFree());
        }

        @Test
        @DisplayName("Should handle negative values in buffer")
        void shouldHandleNegativeValuesInBuffer() throws SMBProtocolDecodingException {
            // Given - negative values (treated as unsigned in protocol)

        CIFSException expectedException = new CIFSException("Failed to close handle");
        doThrow(expectedException).when(watchHandle).close();

        // Execute and verify
        CIFSException thrown = assertThrows(CIFSException.class, () -> {
            watchHandle.close();
        });

        assertEquals("Failed to close handle", thrown.getMessage());
        verify(watchHandle, times(1)).close();
    }

            assertEquals(2048, response.getEndOfFile());
            assertEquals(0x10, response.getFileAttributes());
        }

        @Test
        @DisplayName("Should handle all zero values correctly")
        void testReadBytesWireFormatWithZeroValues() throws SMBProtocolDecodingException {
            // Given
            byte[] buffer = new byte[60];

import jcifs.smb1.util.Encdec;

/**
 * DCERPC handle implementation using SMB named pipes for transport
 */
public class DcerpcPipeHandle extends DcerpcHandle {

    SmbNamedPipe pipe;
    SmbFileInputStream in = null;
    SmbFileOutputStream out = null;
    boolean isStart = true;

    /**
     * Creates a DCERPC pipe handle with the specified URL and authentication

# OpenAPI

There are several utilities to handle OpenAPI.

	// Register distributed namespace lock routers.
	registerLockRESTHandlers(lockGrid)

	// Add lock grid to router
	router.Handle(grid.RouteLockPath, adminMiddleware(lockGrid.Handler(storageServerRequestValidate), noGZFlag, noObjLayerFlag))

	// Add grid to router
	router.Handle(grid.RoutePath, adminMiddleware(commonGrid.Handler(storageServerRequestValidate), noGZFlag, noObjLayerFlag))
}

            } else {
                throw new IOException("Simulated reconnection failure");
            }
        }

        public void testCreateReconnectionRequest(HandleInfo handle) {
            createReconnectionRequest(handle);
        }
    }