- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 230 for unpacked (0.21 sec)
-
pkg/kube/kclient/clienttest/test_helpers.go
// Reads may be cached or uncached, depending on the input client. func WrapReadWriter[T controllers.Object](t test.Failer, c kclient.ReadWriter[T]) TestClient[T] { return TestClient[T]{ c: c, t: t, TestWriter: TestWriter[T]{ c: c, t: t, }, } } // Wrap returns a client that calls t.Fatal on errors. // Reads may be cached or uncached, depending on the input client.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 19:18:21 UTC 2024 - 3.9K bytes - Viewed (0) -
src/sync/rwmutex_test.go
} if m.TryRLock() { t.Fatalf("TryRLock succeeded with mutex locked") } m.Unlock() if !m.TryLock() { t.Fatalf("TryLock failed with mutex unlocked") } m.Unlock() if !m.TryRLock() { t.Fatalf("TryRLock failed with mutex unlocked") } if !m.TryRLock() { t.Fatalf("TryRLock failed with mutex rlocked") } if m.TryLock() { t.Fatalf("TryLock succeeded with mutex rlocked") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 29 17:13:13 UTC 2021 - 4.9K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/ResourceLockState.java
* fails. */ void registerLocked(ResourceLock resourceLock); /** * Registers a resource lock that has been unlocked during the transform so that the coordination service can * notify threads waiting on a lock. */ void registerUnlocked(ResourceLock resourceLock); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:40 UTC 2024 - 1.3K bytes - Viewed (0) -
src/cmd/go/internal/lockedfile/internal/filelock/filelock_test.go
// same inode through two different descriptors at the same time: when the // first descriptor is closed, the second descriptor would still be open but // silently unlocked. So a second RLock must block instead of proceeding. lockF2 := mustBlock(t, "RLock", f2) unlock(t, f) lockF2(t) default: rLock(t, f2) doUnlockTF = true } other := mustOpen(t, f.Name())
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 06 22:37:50 UTC 2023 - 4K bytes - Viewed (0) -
src/sync/rwmutex.go
// A RWMutex is a reader/writer mutual exclusion lock. // The lock can be held by an arbitrary number of readers or a single writer. // The zero value for a RWMutex is an unlocked mutex. // // A RWMutex must not be copied after first use. // // If any goroutine calls [RWMutex.Lock] while the lock is already held by // one or more readers, concurrent calls to [RWMutex.RLock] will block until
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 7.2K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/jmh/java/org/gradle/internal/reflect/CachedConstructorsBenchmark.java
for (int i = 0; i < randomClasses.length; i++) { randomClasses[i] = CLAZZ_ARRAY[RANDOM.nextInt(CLAZZ_ARRAY.length)]; } } private int i; @Benchmark public void uncached(Blackhole bh) { bh.consume(randomClasses[++i % ARR_LEN].getConstructors()); } @Benchmark public void cached(Blackhole bh) { bh.consume(cache.get(randomClasses[++i % ARR_LEN], EMPTY));
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 1.9K bytes - Viewed (0) -
src/runtime/lock_wasip1.go
throw("lock count") } gp.m.locks++ l.key = mutex_locked } func unlock(l *mutex) { unlockWithRank(l) } func unlock2(l *mutex) { if l.key == mutex_unlocked { throw("unlock of unlocked lock") } gp := getg() gp.m.locks-- if gp.m.locks < 0 { throw("lock count") } l.key = mutex_unlocked } // One-time notifications. func noteclear(n *note) { n.key = 0 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 21:02:20 UTC 2023 - 2K bytes - Viewed (0) -
src/runtime/rwmutex.go
} }) } } // runlock undoes a single rlock call on rw. func (rw *rwmutex) runlock() { if r := rw.readerCount.Add(-1); r < 0 { if r+1 == 0 || r+1 == -rwmutexMaxReaders { throw("runlock of unlocked rwmutex") } // A writer is pending. if rw.readerWait.Add(-1) == 0 { // The last reader unblocks the writer. lock(&rw.rLock) w := rw.writer.ptr() if w != nil { notewakeup(&w.park)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 14:29:04 UTC 2024 - 5K bytes - Viewed (0) -
okhttp-dnsoverhttps/src/test/java/okhttp3/dnsoverhttps/TestDohMain.kt
} fun main() { Security.insertProviderAt(OpenSSLProvider(), 1) var bootstrapClient = OkHttpClient() var names = listOf("google.com", "graph.facebook.com", "sdflkhfsdlkjdf.ee") try { println("uncached\n********\n") var dnsProviders = providers( client = bootstrapClient, http2Only = false, workingOnly = false, getOnly = false, ) runBatch(dnsProviders, names)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.2K bytes - Viewed (0) -
pkg/securitycontext/util.go
// ConvertToRuntimeMaskedPaths converts the ProcMountType to the specified or default // masked paths. func ConvertToRuntimeMaskedPaths(opt *v1.ProcMountType) []string { if opt != nil && *opt == v1.UnmaskedProcMount { // Unmasked proc mount should have no paths set as masked. return []string{} } // Otherwise, add the default masked paths to the runtime security context. return defaultMaskedPaths }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 15 07:28:24 UTC 2023 - 7.5K bytes - Viewed (0)