- Sort Score
- Result 10 results
- Languages All
Results 201 - 210 of 1,029 for Var (0.01 sec)
-
mockwebserver/src/test/java/mockwebserver3/internal/http2/Http2Server.kt
sslSocket.startHandshake() return sslSocket } override fun onStream(stream: Http2Stream) { try { val requestHeaders = stream.takeHeaders() var path: String? = null var i = 0 val size = requestHeaders.size while (i < size) { if (requestHeaders.name(i) == Header.TARGET_PATH_UTF8) { path = requestHeaders.value(i) break }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 6.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-HeadersCommon.kt
internal fun Headers.commonValue(index: Int): String = namesAndValues.getOrNull(index * 2 + 1) ?: throw IndexOutOfBoundsException("value[$index]") internal fun Headers.commonValues(name: String): List<String> { var result: MutableList<String>? = null for (i in 0 until size) { if (name.equals(name(i), ignoreCase = true)) { if (result == null) result = ArrayList(2) result.add(value(i)) } }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon May 05 16:01:00 UTC 2025 - 5.8K bytes - Viewed (0) -
cmd/config.go
// MinIO configuration file. minioConfigFile = "config.json" ) func listServerConfigHistory(ctx context.Context, objAPI ObjectLayer, withData bool, count int) ( []madmin.ConfigHistoryEntry, error, ) { var configHistory []madmin.ConfigHistoryEntry // List all kvs marker := "" for { res, err := objAPI.ListObjects(ctx, minioMetaBucket, minioConfigHistoryPrefix, marker, "", maxObjectList) if err != nil {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5.9K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/SocketFailureTest.kt
val clientTestRule = OkHttpClientTestRule() @StartStop private val server = MockWebServer() private var client = clientTestRule .newClientBuilder() .eventListener(listener) .build() class SocketClosingEventListener : EventListener() { var shouldClose: Boolean = false var lastSocket: Socket? = null override fun connectionAcquired( call: Call, connection: Connection,
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jul 29 21:11:09 UTC 2025 - 3K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/WebPlatformUrlTestData.kt
* ``` */ class WebPlatformUrlTestData { var input: String? = null var base: String? = null var scheme = "" var username = "" var password: String? = null var host = "" var port = "" var path = "" var query = "" var fragment = "" fun expectParseFailure() = scheme.isEmpty() private operator fun set( name: String,
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 3.7K bytes - Viewed (0) -
cmd/perf-tests.go
objAPI := newObjectLayerFn() if objAPI == nil { return SpeedTestResult{}, errServerNotInitialized } var wg sync.WaitGroup var errOnce sync.Once var retError string var totalBytesWritten uint64 var totalBytesRead uint64 objCountPerThread := make([]uint64, opts.concurrency) uploadsCtx, uploadsCancel := context.WithTimeout(ctx, opts.duration)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 11.7K bytes - Viewed (0) -
cmd/common-main.go
return } if currentReleaseTime.IsZero() { return } _, lrTime, err := getLatestReleaseTime(u, 2*time.Second, mode) if err != nil { return } var older time.Duration var downloadURL string if lrTime.After(currentReleaseTime) { older = lrTime.Sub(currentReleaseTime) downloadURL = getDownloadURL(releaseTimeToReleaseTag(lrTime)) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 32.5K bytes - Viewed (3) -
src/cmd/asm/internal/arch/loong64.go
} var loong64LasxArngExtMap = map[string]int16{ "B32": loong64.ARNG_32B, "H16": loong64.ARNG_16H, "W8": loong64.ARNG_8W, "V4": loong64.ARNG_4V, "Q2": loong64.ARNG_2Q, } // Loong64RegisterExtension constructs an Loong64 register with extension or arrangement. func Loong64RegisterExtension(a *obj.Addr, ext string, reg, num int16, isAmount, isIndex bool) error { var ok bool var arng_type int16
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Tue Aug 05 17:31:25 UTC 2025 - 3.8K bytes - Viewed (0) -
misc/chrome/gophertool/popup.js
console.log("submitting form"); var box = document.getElementById("inputbox"); box.focus(); var t = box.value; if (t == "") { return false; } var success = function(url) { console.log("matched " + t + " to: " + url) box.value = ""; openURL(url); return false; // cancel form submission }; var url = urlForInput(t); if (url) { return success(url);
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Sun Oct 21 17:05:21 UTC 2012 - 1020 bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
internal val name: String, ) { internal var shutdown = false /** This queue's currently-executing task, or null if none is currently executing. */ internal var activeTask: Task? = null /** Scheduled tasks ordered by [Task.nextExecuteNanoTime]. */ internal val futureTasks = mutableListOf<Task>() /** True if the [activeTask] should be canceled when it completes. */ internal var cancelActiveTask = false /**
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 7.3K bytes - Viewed (0)