}
    }

    @Nested
    @DisplayName("Concurrency Tests")
    class ConcurrencyTests {

        @Test
        @DisplayName("Should handle concurrent received notifications")
        void testConcurrentReceived() throws InterruptedException {
            int threadCount = 10;
            CountDownLatch startLatch = new CountDownLatch(1);

      QueuingRemovalListener<K, V> listener, K key, V value, RemovalCause cause) {
    RemovalNotification<K, V> notification = listener.remove();
    assertSame(key, notification.getKey());
    assertSame(value, notification.getValue());
    assertSame(cause, notification.getCause());
  }

  // Segment core tests

  public void testNewEntry() {

    Object key = new Object();
    assertSame(computed, cache.getUnchecked(key));
    RemovalNotification<Object, Object> notification = listener.remove();
    assertSame(key, notification.getKey());
    assertSame(computed, notification.getValue());
    assertSame(RemovalCause.SIZE, notification.getCause());
    assertTrue(listener.isEmpty());
    checkEmpty(cache);
  }

  public void testGet_expireAfterWrite() {

    Object key = new Object();
    assertSame(computed, cache.getUnchecked(key));
    RemovalNotification<Object, Object> notification = listener.remove();
    assertSame(key, notification.getKey());
    assertSame(computed, notification.getValue());
    assertSame(RemovalCause.SIZE, notification.getCause());
    assertTrue(listener.isEmpty());
    checkEmpty(cache);
  }

  public void testGet_expireAfterWrite() {

    private Smb2OplockBreakNotification notification;

    @BeforeEach
    void setUp() {
        mockConfig = mock(Configuration.class);
        notification = new Smb2OplockBreakNotification(mockConfig);
    }

    @Nested
    @DisplayName("Constructor Tests")
    class ConstructorTests {

        @Test
        @DisplayName("Should create notification with configuration")

        assertNotNull(verifyCacheEntry);
        assertTrue(verifyCacheEntry.isComplete());
        assertEquals(2, verifyCacheEntry.getChildren().size());

        // Step 8: Test change notifications
        // Simulate file addition
        directoryLeaseManager.handleDirectoryChange(directoryPath, "newfile.txt", DirectoryChangeNotifier.DirectoryChangeType.FILE_ADDED);

        // Cache should be invalidated

 */
package jcifs;

/**
 * File notification information
 *
 *
 * @author mbechler
 *
 */
public interface FileNotifyInformation {

    // filter flags

    /**
     * Any file name change in the watched directory or subtree causes a change notification wait operation to return.
     * Changes include renaming, creating, or deleting a file.
     */

        notification.addNewIPAddress(ipv4);
        notification.addNewIPAddress(ipv6);
        notification.addOldIPAddress(ipv4);

        List<WitnessNotification.WitnessIPAddress> newAddresses = notification.getNewIPAddresses();
        List<WitnessNotification.WitnessIPAddress> oldAddresses = notification.getOldIPAddresses();

        assertEquals(2, newAddresses.size());
        assertEquals(1, oldAddresses.size());

  static class QueuingRemovalListener<K, V> extends ConcurrentLinkedQueue<RemovalNotification<K, V>>
      implements RemovalListener<K, V> {

    @Override
    public void onRemoval(RemovalNotification<K, V> notification) {
      add(notification);
    }
  }

  /**
   * {@link RemovalListener} that counts each {@link RemovalNotification} it receives, and provides
   * access to the most-recently received one.
   */

    /**
     * Creates a new empty witness notification.
     */
    public WitnessNotification() {
        this.timestamp = System.currentTimeMillis();
        this.newIPAddresses = new ArrayList<>();
        this.oldIPAddresses = new ArrayList<>();
        this.flags = WITNESS_RESOURCE_STATE_UNKNOWN;
    }

    /**
     * Creates a new witness notification.
     *
     * @param eventType the type of event