- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for Krause (0.16 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
} } return null } private fun <E : IOException?> timeoutExit(cause: E): E { if (timeoutEarlyExit) return cause if (!timeout.exit()) return cause val e = InterruptedIOException("timeout") if (cause != null) e.initCause(cause) @Suppress("UNCHECKED_CAST") // E is either IOException or IOException? return e as E } /**
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
*/ override fun close() { close(ErrorCode.NO_ERROR, ErrorCode.CANCEL, null) } internal fun close( connectionCode: ErrorCode, streamCode: ErrorCode, cause: IOException?, ) { this.assertThreadDoesntHoldLock() ignoreIoExceptions { shutdown(connectionCode) } var streamsToClose: Array<Http2Stream>? = null this.withLock {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
closeLater(ErrorCode.CANCEL) connection.sendDegradedPingLater() } override fun newTimeoutException(cause: IOException?): IOException { return SocketTimeoutException("timeout").apply { if (cause != null) { initCause(cause) } } } @Throws(IOException::class) fun exitAndThrowIfTimedOut() {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
connectionUser.releaseConnectionNoEvents() } else -> null } } // If the call's connection wasn't released, reuse it. We don't call connectionAcquired() here // because we already acquired it. if (connectionUser.candidateConnection() != null) { check(toClose == null) return ReusePlan(candidate) }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 12K bytes - Viewed (0) -
cmd/endpoint.go
return ep, fmt.Errorf("empty or root path is not supported in URL endpoint") } // On windows having a preceding SlashSeparator will cause problems, if the // command line already has C:/<export-folder/ in it. Final resulting // path on windows might become C:/C:/ this will cause problems // of starting minio server properly in distributed mode on windows. // As a special case make sure to trim the separator.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 34.1K bytes - Viewed (0) -
cmd/server-main.go
} return nil } if configRetriableErrors(err) { logger.Info("Waiting for all MinIO sub-systems to be initialized.. possible cause (%v)", err) time.Sleep(time.Duration(r.Float64() * float64(5*time.Second))) continue } // Any other unhandled return right here. return fmt.Errorf("Unable to initialize sub-systems: %w", err) }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 32.7K bytes - Viewed (1) -
android/guava/src/com/google/common/collect/Iterables.java
* Queue#isEmpty} and {@link Queue#remove()}, since {@link Queue}'s iteration order is undefined. * Calling {@link Iterator#hasNext()} on a generated iterator from the returned iterable may cause * an item to be immediately dequeued for return on a subsequent call to {@link Iterator#next()}. * * <p>Whether the input {@code iterable} is a {@link Queue} or not, the returned {@code Iterable}
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 24 19:38:27 GMT 2024 - 42.8K bytes - Viewed (0)