- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 194 for sweeping (0.29 sec)
-
platforms/core-configuration/stdlib-kotlin-extensions/src/main/kotlin/org/gradle/internal/extensions/stdlib/MapExtensions.kt
fun <V> Map<String, V>.filterKeysByPrefix(prefix: String): Map<String, V?> = filterKeys { key -> key.length > prefix.length && key.startsWith(prefix) } /** * Inverts the given map by swapping its keys with their corresponding values and returns the resulting map. * * If the original map contains duplicate values, the resulting map will map each value to the key associated
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:59:39 UTC 2024 - 1.2K bytes - Viewed (0) -
samples/addons/jaeger.yaml
- name: grpc-query port: 16685 protocol: TCP targetPort: 16685 selector: app: jaeger --- # Jaeger implements the Zipkin API. To support swapping out the tracing backend, we use a Service named Zipkin. apiVersion: v1 kind: Service metadata: labels: name: zipkin name: zipkin namespace: istio-system spec: ports: - port: 9411
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:57:35 UTC 2024 - 2.5K bytes - Viewed (0) -
cmd/metacache.go
recursive bool `msg:"rec"` dataVersion uint8 `msg:"v"` } func (m *metacache) finished() bool { return !m.ended.IsZero() } // worthKeeping indicates if the cache by itself is worth keeping. func (m *metacache) worthKeeping() bool { if m == nil { return false } cache := m switch { case !cache.finished() && time.Since(cache.lastUpdate) > metacacheMaxRunningAge:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 5K bytes - Viewed (0) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt
fail<Any>() } catch (expected: IOException) { } server.url("/b").toUrl().openConnection().getInputStream() // Should succeed. } /** * Throttle the request body by sleeping 500ms after every 3 bytes. With a 6-byte request, this * should yield one sleep for a total delay of 500ms. */ @Test fun throttleRequest() { assumeNotWindows() server.enqueue(
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 21.9K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt
val inputStream = server.url("/a").toUrl().openConnection().getInputStream() assertThat(inputStream!!.read()).isEqualTo('B'.code) } /** * Throttle the request body by sleeping 500ms after every 3 bytes. With a 6-byte request, this * should yield one sleep for a total delay of 500ms. */ @Test fun throttleRequest() { assumeNotWindows() server.enqueue(
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 23.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/internal.kt
// 3) Caller specified but assuming the visible defaults in MODERN_CIPHER_SUITES are rejigged // to match legacy i.e. the platform/provider // // Opting for 2 here and keeping MODERN_TLS in line with secure browsers. cipherSuitesAsString.intersect(socketEnabledCipherSuites, CipherSuite.ORDER_BY_NAME) } else { socketEnabledCipherSuites } }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.7K bytes - Viewed (0) -
tests/integration/pilot/proxyconfig/proxyconfig_test.go
t.Helper() for _, i := range instances { i := i attempts := 0 retry.UntilSuccessOrFail(t, func() error { // to avoid sleeping for ProxyConfig propagation, we // can just re-trigger injection on every retry. if attempts > 0 { err := i.Restart() if err != nil { return fmt.Errorf("failed to restart echo instance: %v", err)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 02 21:29:40 UTC 2024 - 6.3K bytes - Viewed (0) -
src/runtime/rwmutex.go
func (rw *rwmutex) rlock() { // The reader must not be allowed to lose its P or else other // things blocking on the lock may consume all of the Ps and // deadlock (issue #20903). Alternatively, we could drop the P // while sleeping. acquireLockRankAndM(rw.readRank) lockWithRankMayAcquire(&rw.rLock, getLockRank(&rw.rLock)) if rw.readerCount.Add(1) < 0 { // A writer is pending. Park on the reader queue. systemstack(func() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 14:29:04 UTC 2024 - 5K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/Sample.java
return testFile(dirNameFor(sampleName)); } return null; } /** * Shortens path as much as possible to prevent long path issues on Windows * by keeping the last segment only, ignoring /groovy or /kotlin suffix. */ @VisibleForTesting static String dirNameFor(String sampleName) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.6K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/problems/DefaultProblemLocationAnalyzer.java
if (startPos == -1) { // No user code in the stack return null; } // Treat Gradle code as the boundary to allow stepping over JDK and Groovy calls endPos = failure.indexOfStackFrame(startPos + 1, GRADLE_CODE); if (endPos == -1) { endPos = stack.size(); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 23 17:15:42 UTC 2024 - 5.5K bytes - Viewed (0)