- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 1,266 for AFTER (0.01 sec)
-
src/test/java/jcifs/smb/SmbPipeHandleImplTest.java
assertFalse(target.isOpen()); assertTrue(target.isStale()); } @Test @DisplayName("getInput and getOutput throw after close") void testGetInputOutputAndClosed() throws CIFSException { // After closing the handle, further calls throw target.close(); CIFSException e1 = assertThrows(SmbException.class, target::getInput);
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 11.7K bytes - Viewed (0) -
guava/src/com/google/common/collect/RangeMap.java
* * <p>If {@code !range.contains(k)}, {@link #get(Comparable) get(k)} will return the same result * before and after a call to {@code remove(range)}. If {@code range.contains(k)}, then after a * call to {@code remove(range)}, {@code get(k)} will return {@code null}. */ void remove(Range<K> range); /**Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 7.6K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
} @Override protected void tearDown() throws Exception { // Make sure we have no waiting threads. latch.countDown(); } /** Constructs a listenable future with a value available after the latch has counted down. */ protected abstract <V> ListenableFuture<V> createListenableFuture( V value, @Nullable Exception except, CountDownLatch waitOn);
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 6.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
Executors.newSingleThreadScheduledExecutor(new ThreadFactoryImpl()); // Add a listener to shut down the executor after the service is stopped. This ensures that the // JVM shutdown will not be prevented from exiting after this service has stopped or failed. // Technically this listener is added after start() was called so it is a little gross, but it
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 27.8K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/CacheBuilder.java
* Cache} interfaces. The {@code asMap} view (and its collection views) have <i>weakly consistent * iterators</i>. This means that they are safe for concurrent use, but if other threads modify the * cache after the iterator is created, it is undefined which of these changes, if any, are * reflected in that iterator. These iterators never throw {@link ConcurrentModificationException}. *Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Wed Oct 08 18:55:33 UTC 2025 - 51.9K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/com/SmbComSeekResponse.java
import jcifs.internal.smb1.ServerMessageBlock; import jcifs.internal.util.SMBUtil; /** * SMB1 Seek command response implementation. * Handles server responses to file seek operations, returning the new file * position after a seek request in SMB1 protocol file operations. * * @author mbechler */ public class SmbComSeekResponse extends ServerMessageBlock { private long offset; /** * Constructs a seek response.Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 2.8K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops_gen_test.go
} left, err := v.UnmarshalMsg(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after UnmarshalMsg(): %q", len(left), left) } left, err = msgp.Skip(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsghealingTracker(b *testing.B) { v := healingTracker{}
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 2.3K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/rdma/RdmaBufferManagerTest.java
long allocatedBeforeCleanup = bufferManager.getTotalAllocated(); // Cleanup should not throw exception assertDoesNotThrow(() -> bufferManager.cleanup()); // After cleanup, all regions should be released (but the count may not match exactly // if some regions were pooled rather than immediately released)Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 7.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
* #collectValueFromNonCancelledFuture}. As this is called after the subclass is constructed, * we're guaranteed to have properly initialized the subclass. */ final void init() { /* * requireNonNull is safe because this is called from the constructor after `futures` is set but * before releaseResources could be called (because we have not yet set up any of the listeners
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 16K bytes - Viewed (0) -
src/test/java/jcifs/smb/SecurityBlobTest.java
// Act blob.set(null); // Assert assertNotNull(blob.get(), "get() should return non-null after set(null)"); assertEquals(0, blob.length(), "length() should be 0 after set(null)"); assertEquals("", blob.toString(), "toString() should be empty after set(null)"); } // Verifies constructor stores the exact array reference and exposes it via get() @TestRegistered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 9.4K bytes - Viewed (0)