- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for Fong (0.27 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/flowcontrol/WindowCounter.kt
) { /** The total number of bytes consumed. */ var total: Long = 0L private set /** The total number of bytes acknowledged by outgoing `WINDOW_UPDATE` frames. */ var acknowledged: Long = 0L private set val unacknowledged: Long @Synchronized get() = total - acknowledged @Synchronized fun update( total: Long = 0, acknowledged: Long = 0, ) { check(total >= 0)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 1.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ConnectionPool.kt
* Connections will still be closed if they idle beyond the keep-alive but will be replaced. */ @JvmField val minimumConcurrentCalls: Int = 0, /** How long to wait to retry pre-emptive connection attempts that fail. */ @JvmField val backoffDelayMillis: Long = 60 * 1000, /** How much jitter to introduce in connection retry backoff delays */ @JvmField val backoffJitterMillis: Int = 100, )
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Apr 03 20:39:41 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
nextOutFrame = outFramesIterator.next() } if (nextOutFrame != null && nextOutFrame.sequence == i) { val start = nextOutFrame.start var truncated: Boolean var end: Long if (outFramesIterator.hasNext()) { nextOutFrame = outFramesIterator.next() end = nextOutFrame.start truncated = false } else { end = outBytes.size.toLong()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-ResponseCommon.kt
internal class UnreadableResponseBody( private val mediaType: MediaType?, private val contentLength: Long, ) : ResponseBody(), Source { override fun contentType() = mediaType override fun contentLength() = contentLength override fun source() = buffer() override fun read( sink: Buffer, byteCount: Long, ): Long { throw IllegalStateException( """
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Apr 15 13:24:48 GMT 2024 - 5.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/NativeImageTestsAccessors.kt
import okhttp3.internal.connection.RealConnection import okio.FileSystem import okio.Path internal fun buildCache( file: Path, maxSize: Long, fileSystem: FileSystem, ): Cache { return Cache(fileSystem, file, maxSize) } internal var RealConnection.idleAtNsAccessor: Long get() = idleAtNs set(value) { idleAtNs = value } internal val Response.exchangeAccessor: Exchange? get() = this.exchange
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 1.3K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt
var uriHost: String = "example.com" var uriPort: Int = 1 fun newConnection( pool: RealConnectionPool, route: Route, idleAtNanos: Long = Long.MAX_VALUE, taskRunner: TaskRunner = this.taskRunner, ): RealConnection { val result = RealConnection.newTestConnection( taskRunner = taskRunner, connectionPool = pool,
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 7.7K bytes - Viewed (0) -
android/guava/src/com/google/common/base/Platform.java
* type. * * In practice, we are very unlikely to see `null`: The `WeakReference` to the enum constant * won't be cleared as long as the enum constant is referenced somewhere, and the enum constant * is referenced somewhere for as long as the enum class is loaded. *Maybe in theory* the enum * class could be unloaded after the above call to `getEnumConstants` but before we call
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 15 22:32:14 GMT 2024 - 3.8K bytes - Viewed (0) -
istioctl/pkg/authz/authz.go
) var configDumpFile string func checkCmd(ctx cli.Context) *cobra.Command { cmd := &cobra.Command{ Use: "check [<type>/]<name>[.<namespace>]", Short: "Check AuthorizationPolicy applied in the pod.", Long: `Check prints the AuthorizationPolicy applied to a pod by directly checking the Envoy configuration of the pod. The command is especially useful for inspecting
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 5K bytes - Viewed (0) -
maven-compat/src/test/java/org/apache/maven/artifact/resolver/TestFileWagon.java
if (testTransferListener != null) { testTransferListener.addTransfer(resourceName); } } public boolean getIfNewer(String resourceName, File destination, long timestamp) throws TransferFailedException, ResourceDoesNotExistException, AuthorizationException { if (!insideGet) { addTransfer("getIfNewer " + resourceName); }
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Thu Apr 25 05:46:50 GMT 2024 - 2.8K bytes - Viewed (0) -
cmd/storage-errors.go
// errTooManyOpenFiles - too many open files. var errTooManyOpenFiles = StorageErr("too many open files, please increase 'ulimit -n'") // errFileNameTooLong - given file name is too long than supported length. var errFileNameTooLong = StorageErr("file name too long") // errVolumeExists - cannot create same volume again. var errVolumeExists = StorageErr("volume already exists") // errIsNotRegular - not of regular file type.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.4K bytes - Viewed (0)