- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,066 for Closed (0.38 sec)
-
guava/src/com/google/common/collect/BoundType.java
* ("open"). If a range is unbounded on a side, it is neither open nor closed on that side; the * bound simply does not exist. * * @since 10.0 */ @GwtCompatible @ElementTypesAreNonnullByDefault public enum BoundType { /** The endpoint value <i>is not</i> considered part of the set ("exclusive"). */ OPEN(false), CLOSED(true); final boolean inclusive;
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Mon Sep 20 15:57:47 GMT 2021 - 1.4K bytes - Viewed (0) -
internal/grid/muxclient.go
} } // send the message. msg.Seq and msg.MuxID will be set func (m *muxClient) send(msg message) error { m.respMu.Lock() defer m.respMu.Unlock() if m.closed { return errors.New("mux client closed") } return m.sendLocked(msg) } // sendLocked the message. msg.Seq and msg.MuxID will be set. // m.respMu must be held. func (m *muxClient) sendLocked(msg message) error {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SimpleTimeLimiterTest.java
Stopwatch stopwatch = Stopwatch.createStarted(); String result = proxy.sleepThenReturnInput("x"); assertThat(result).isEqualTo("x"); assertThat(stopwatch.elapsed(MILLISECONDS)).isIn(Range.closed(DELAY_MS, ENOUGH_MS)); assertThat(target.finished).isTrue(); } public void testNewProxy_goodMethodWithNotEnoughTime() throws Exception { SampleImpl target = new SampleImpl(9999);
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 9.5K bytes - Viewed (0) -
cni/pkg/nodeagent/fakes_test.go
return &fakeNs{closed: &atomic.Bool{}, fd: fd, inode: inode} } // Fd returns the file descriptor func (f *fakeNs) Fd() uintptr { return f.fd } func (f *fakeNs) Inode() uint64 { return f.inode } // Close simulates closing the file descriptor and returns nil for no error func (f *fakeNs) Close() error { f.closed.Store(true) return nil } func fakeFs() fs.FS {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 3.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SimpleTimeLimiterTest.java
Stopwatch stopwatch = Stopwatch.createStarted(); String result = proxy.sleepThenReturnInput("x"); assertThat(result).isEqualTo("x"); assertThat(stopwatch.elapsed(MILLISECONDS)).isIn(Range.closed(DELAY_MS, ENOUGH_MS)); assertThat(target.finished).isTrue(); } public void testNewProxy_goodMethodWithNotEnoughTime() throws Exception { SampleImpl target = new SampleImpl(9999);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 9.5K bytes - Viewed (0) -
src/archive/zip/writer.go
w.comment = comment return nil } // Close finishes writing the zip file by writing the central directory. // It does not close the underlying writer. func (w *Writer) Close() error { if w.last != nil && !w.last.closed { if err := w.last.close(); err != nil { return err } w.last = nil } if w.closed { return errors.New("zip: writer closed twice") } w.closed = true // write central directory
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Apr 04 14:28:57 GMT 2024 - 19.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
if (civilizedFileSystem) return fileSource lockingSourceCount++ return object : ForwardingSource(fileSource) { private var closed = false override fun close() { super.close() if (!closed) { closed = true synchronized(this@DiskLruCache) { lockingSourceCount-- if (lockingSourceCount == 0 && zombie) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 34.7K bytes - Viewed (0) -
src/main/java/jcifs/smb/DirFileEntryEnumIteratorBase.java
protected abstract FileEntry[] getResults (); /** * */ protected synchronized void doClose () throws CIFSException { // otherwise already closed if ( !this.closed ) { this.closed = true; try { doCloseInternal(); } finally { this.next = null; this.treeHandle.release();
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 5.8K bytes - Viewed (0) -
src/main/java/jcifs/context/AbstractCIFSContext.java
return false; } /** * {@inheritDoc} * * * @see jcifs.CIFSContext#close() */ @Override public boolean close () throws CIFSException { if ( !this.closed ) { Runtime.getRuntime().removeShutdownHook(this); } return false; } /** * {@inheritDoc} *
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Tue Jul 07 10:50:16 GMT 2020 - 3.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/TestStreamSupplier.java
* stream was closed. Intended for use in a test where only a single stream should be opened and * possibly closed. * * @author Colin Decker */ public interface TestStreamSupplier { /** Returns whether or not a new stream was opened. */ boolean wasStreamOpened(); /** Returns whether or not an open stream was closed. */ boolean wasStreamClosed();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 1.1K bytes - Viewed (0)