Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 284 for immediately (0.05 sec)

  1. src/test/java/jcifs/internal/smb2/lock/Smb2LockTest.java

            void testUnlockFlag() {
                assertEquals(0x4, Smb2Lock.SMB2_LOCKFLAG_UNLOCK);
            }
    
            @Test
            @DisplayName("Should have correct fail immediately flag value")
            void testFailImmediatelyFlag() {
                assertEquals(0x10, Smb2Lock.SMB2_LOCKFLAG_FAIL_IMMEDIATELY);
            }
    
            @Test
            @DisplayName("Should allow flag combinations")
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 10.9K bytes
    - Viewed (0)
  2. guava/src/com/google/common/collect/Multiset.java

      // Views
    
      /**
       * Returns the set of distinct elements contained in this multiset. The element set is backed by
       * the same data as the multiset, so any change to either is immediately reflected in the other.
       * The order of the elements in the element set is unspecified.
       *
       * <p>If the element set supports any removal operations, these necessarily cause <b>all</b>
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Jul 08 18:32:10 UTC 2025
    - 20.9K bytes
    - Viewed (0)
  3. internal/lock/lock_windows.go

    	if flag == syscall.O_RDONLY {
    		// https://docs.microsoft.com/en-us/windows/desktop/api/fileapi/nf-fileapi-lockfileex
    		//lint:ignore SA4016 Reasons
    		lockType = lockFileFailImmediately // Set this to enable shared lock and fail immediately.
    	}
    	return lockedOpenFile(path, flag, perm, lockType)
    }
    
    // LockedOpenFile - initializes a new lock and protects
    // the file from concurrent access.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  4. src/test/java/jcifs/internal/smb2/lease/DirectoryLeaseManagerTest.java

            // Make the cache entry expired
            DirectoryCacheEntry entry = directoryLeaseManager.getCacheEntry(directoryPath);
            entry.setMaxAge(1); // 1ms to expire immediately
            try {
                Thread.sleep(10);
            } catch (InterruptedException e) {
                // Ignore
            }
    
            // When lease is lost, cache entry should be removed
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 01:47:47 UTC 2025
    - 15.9K bytes
    - Viewed (0)
  5. src/test/java/jcifs/smb/DirFileEntryEnumIteratorBaseTest.java

            assertSame(parent, it.getParent());
            verify(tree, times(1)).acquire();
        }
    
        @Test
        @DisplayName("Constructor with open() returning null closes immediately and hasNext=false")
        void constructorOpenNullCloses() throws Exception {
            // Arrange
            stubAcquireReturnsSelf();
            List<FileEntry[]> pages = List.of(new FileEntry[][] { new FileEntry[] {} });
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 14.5K bytes
    - Viewed (0)
  6. guava/src/com/google/common/cache/CacheBuilder.java

       * For example, the cache may evict an entry because it hasn't been used recently or very often.
       *
       * <p>If {@code maximumSize} is zero, elements will be evicted immediately after being loaded into
       * cache. This can be useful in testing, or to disable caching temporarily.
       *
       * <p>This feature cannot be used in conjunction with {@link #maximumWeight}.
       *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Oct 08 18:55:33 UTC 2025
    - 51.6K bytes
    - Viewed (0)
  7. src/test/java/jcifs/smb/SmbTreeConnectionTest.java

            // Verify disconnect was called on retry
            verify(c, atLeastOnce()).disconnect(eq(true));
        }
    
        @Test
        @DisplayName("send honors NO_RETRY and propagates error immediately")
        void send_noRetry_param() throws Exception {
            SmbTreeConnection c = newConn();
            SmbTreeImpl tree = mock(SmbTreeImpl.class);
            when(tree.acquire(false)).thenReturn(tree);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 13K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/cache/CacheEvictionTest.java

        // Should we pepper more of these calls throughout the above? Where?
        CacheTesting.checkValidState(cache);
      }
    
      /**
       * Tests that when a single entry exceeds the segment's max weight, the new entry is immediately
       * evicted and nothing else.
       */
      public void testEviction_maxWeight_entryTooBig() {
        CountingRemovalListener<Integer, Integer> removalListener = countingRemovalListener();
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 18:19:59 UTC 2025
    - 15.1K bytes
    - Viewed (0)
  9. src/test/java/jcifs/smb/SmbTreeHandleImplTest.java

        }
    
        @Test
        @DisplayName("Null resourceLoc is accepted but may cause issues later")
        void constructorNullResourceLoc() {
            // Null resourceLoc doesn't throw NPE immediately - it's stored and may cause issues when used
            // This test documents the current behavior
            SmbTreeConnection freshConnection = mock(SmbTreeConnection.class);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 14.4K bytes
    - Viewed (0)
  10. internal/logger/target/kafka/kafka.go

    		// return error only for context timedout.
    		if errors.Is(ctx.Err(), context.DeadlineExceeded) {
    			return ctx.Err()
    		}
    		return nil
    	default:
    		// log channel is full, do not wait and return
    		// an error immediately to the caller
    		atomic.AddInt64(&h.totalMessages, 1)
    		atomic.AddInt64(&h.failedMessages, 1)
    		return errors.New("log buffer full")
    	}
    	return nil
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 10.2K bytes
    - Viewed (0)
Back to top