- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 20 for IsClosed (0.27 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
* resources are released and all following calls to [.newSource] return null. Guarded by this. */ var sourceCount = 0 val isClosed: Boolean get() = file == null @Throws(IOException::class) private fun writeHeader( prefix: ByteString, upstreamSize: Long, metadataSize: Long, ) { val header =
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
guava/src/com/google/common/base/FinalizableReferenceQueue.java
* Reference<?> reference = new FinalizablePhantomReference<MyServer>(myServer, frq) { * public void finalizeReferent() { * references.remove(this): * if (!serverSocket.isClosed()) { * ...log a message about how nobody called close()... * try { * serverSocket.close(); * } catch (IOException e) { * ... * } * }
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Wed Apr 26 20:07:17 GMT 2023 - 13.1K bytes - Viewed (0) -
android/guava/src/com/google/common/base/FinalizableReferenceQueue.java
* Reference<?> reference = new FinalizablePhantomReference<MyServer>(myServer, frq) { * public void finalizeReferent() { * references.remove(this): * if (!serverSocket.isClosed()) { * ...log a message about how nobody called close()... * try { * serverSocket.close(); * } catch (IOException e) { * ... * } * }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 26 20:07:17 GMT 2023 - 13.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
@ArgumentsSource(FileSystemParamProvider::class) fun isClosed_uninitializedCache(parameters: Pair<FileSystem, Boolean>) { setUp(parameters.first, parameters.second) // Create an uninitialized cache. cache = DiskLruCache(filesystem, cacheDir, appVersion, 2, Int.MAX_VALUE.toLong(), taskRunner).also { toClose.add(it) } assertThat(cache.isClosed()).isFalse() cache.close()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 14:55:09 GMT 2024 - 75.8K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportImpl.java
public boolean isDisconnected () { Socket s = this.socket; return super.isDisconnected() || s == null || s.isClosed(); } @Override public boolean isFailed () { Socket s = this.socket; return super.isFailed() || s == null || s.isClosed(); } @Override public boolean hasCapability ( int cap ) throws SmbException {
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Wed Jan 18 23:47:00 GMT 2023 - 67K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
@Synchronized @Throws(IOException::class) override fun flush() { if (!initialized) return checkNotClosed() trimToSize() journalWriter!!.flush() } @Synchronized fun isClosed(): Boolean = closed /** Closes this cache. Stored values will remain on the filesystem. */ @Synchronized @Throws(IOException::class) override fun close() { if (!initialized || closed) {
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) -
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
static void assertClosed(TestCloseable closeable1, TestCloseable... moreCloseables) throws IOException { for (TestCloseable closeable : asList(closeable1, moreCloseables)) { assertWithMessage("%s.isClosed()", closeable).that(closeable.awaitClosed()).isTrue(); } } private ClosingFuture<Object> failedClosingFuture() { return ClosingFuture.from(immediateFailedFuture(exception)); }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 75.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
static void assertClosed(TestCloseable closeable1, TestCloseable... moreCloseables) throws IOException { for (TestCloseable closeable : asList(closeable1, moreCloseables)) { assertWithMessage("%s.isClosed()", closeable).that(closeable.awaitClosed()).isTrue(); } } private ClosingFuture<Object> failedClosingFuture() { return ClosingFuture.from(immediateFailedFuture(exception)); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 74.7K bytes - Viewed (0) -
internal/grid/connection.go
case debugSetClientPingDuration: c.clientPingInterval = args[0].(time.Duration) case debugAddToDeadline: c.addDeadline = args[0].(time.Duration) case debugIsOutgoingClosed: // params: muxID uint64, isClosed func(bool) muxID := args[0].(uint64) resp := args[1].(func(b bool)) mid, ok := c.outgoing.Load(muxID) if !ok || mid == nil { resp(true) return } mid.respMu.Lock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
okhttp/api/okhttp.api
public final fun directoryPath ()Lokio/Path; public final fun evictAll ()V public fun flush ()V public final fun hitCount ()I public final fun initialize ()V public final fun isClosed ()Z public static final fun key (Lokhttp3/HttpUrl;)Ljava/lang/String; public final fun maxSize ()J public final fun networkCount ()I public final fun requestCount ()I public final fun size ()J
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:41:01 GMT 2024 - 70.2K bytes - Viewed (0)