- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 69 for unpacked (0.27 sec)
-
src/syscall/forkpipe2.go
// But we haven't promised that serialization, and it is essentially // undetectable by other users of ForkLock, which is good. // Avoid the serialization by ensuring that ForkLock is locked // at the first fork and unlocked when there are no more forks. func acquireForkLock() { forkingLock.Lock() defer forkingLock.Unlock() if forking == 0 { // There is no current write lock on ForkLock. ForkLock.Lock() forking++
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jul 10 19:19:59 UTC 2023 - 2.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/cel/library/cidr_test.go
}, { name: "masks masked ipv4", expr: `cidr("192.168.0.0/24").masked()`, expectResult: apiservercel.CIDR{Prefix: netip.PrefixFrom(ipv4Addr, 24)}, }, { name: "masks unmasked ipv4", expr: `cidr("192.168.0.1/24").masked()`, expectResult: apiservercel.CIDR{Prefix: netip.PrefixFrom(ipv4Addr, 24)}, }, { name: "returns prefix length ipv4",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 12:03:09 UTC 2023 - 8.3K bytes - Viewed (0) -
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/maven/MavenFileRepoResolveIntegrationTest.groovy
import org.gradle.integtests.fixtures.AbstractDependencyResolutionTest class MavenFileRepoResolveIntegrationTest extends AbstractDependencyResolutionTest { void "can resolve snapshots uncached from local Maven repository"() { given: def moduleA = mavenRepo().module('group', 'projectA', '1.2-SNAPSHOT') def moduleB = mavenRepo().module('group', 'projectB', '9.1') moduleA.publish()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 5K bytes - Viewed (0) -
internal/dsync/dsync-server_test.go
} l.mutex.Lock() defer l.mutex.Unlock() var locksHeld int64 if locksHeld, reply = l.lockMap[args.Resources[0]]; !reply { // No lock is held on the given name return false, fmt.Errorf("Unlock attempted on an unlocked entity: %s", args.Resources[0]) } if reply = locksHeld == WriteLock; !reply { // Unless it is a write lock
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jan 23 16:46:37 UTC 2023 - 8.3K bytes - Viewed (0) -
src/runtime/mfixalloc.go
// Since assignments to mlink.next will result in a write barrier being performed // this cannot be used by some of the internal GC structures. For example when // the sweeper is placing an unmarked object on the free list it does not want the // write barrier to be called since that could result in the object being reachable. type mlink struct { _ sys.NotInHeap next *mlink }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 24 20:28:25 UTC 2023 - 3.1K bytes - Viewed (0) -
platforms/core-execution/build-cache/src/test/groovy/org/gradle/caching/internal/controller/DefaultBuildCacheControllerPackOperationExecutorTest.groovy
def key = new DefaultBuildCacheKey(TestHashCodes.hashCodeFrom(1234)) def originMetadata = Mock(OriginMetadata) def originReader = Mock(OriginReader) def originWriter = Mock(OriginWriter) def "unpack invokes unpacker and fingerprints trees"() { def outputFile = temporaryFolder.file("output.txt") def outputDir = temporaryFolder.file("outputDir") def outputDirFile = outputDir.file("file.txt")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 05 22:18:26 UTC 2024 - 7.6K bytes - Viewed (0) -
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/locking/DependencyLockingIntegrationTest.groovy
""" when: succeeds 'dependencies' then: lockfileFixture.expectLockStateMissing('unlockedConf') } def "version selector combinations are resolved equally for locked and unlocked configurations"() { ['foo', 'foz', 'bar', 'baz'].each { artifact -> mavenRepo.module('org', artifact, '1.0').publish() mavenRepo.module('org', artifact, '1.1').publish()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 30 12:42:25 UTC 2023 - 6.1K bytes - Viewed (0) -
internal/lock/lock_test.go
l, err := LockedOpenFile(f.Name(), os.O_WRONLY, 0o600) if err != nil { t.Fatal(err) } // unlock the file if err = l.Close(); err != nil { t.Fatal(err) } // try lock the unlocked file dupl, err := LockedOpenFile(f.Name(), os.O_WRONLY|os.O_CREATE, 0o600) if err != nil { t.Errorf("err = %v, want %v", err, nil) } // blocking on locked file locked := make(chan struct{}, 1)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 3.6K bytes - Viewed (0) -
src/runtime/lock_futex.go
} } func unlock(l *mutex) { unlockWithRank(l) } func unlock2(l *mutex) { v := atomic.Xchg(key32(&l.key), mutex_unlocked) if v == mutex_unlocked { throw("unlock of unlocked lock") } if v == mutex_sleeping { futexwakeup(key32(&l.key), 1) } gp := getg() gp.m.mLockProfile.recordUnlock(l) gp.m.locks-- if gp.m.locks < 0 { throw("runtimeĀ·unlock: lock count")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:34 UTC 2024 - 5.4K bytes - Viewed (0) -
cmd/jwt_test.go
if err != nil { b.Fatal(err) } defer os.RemoveAll(fsDir) if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil { b.Fatal(err) } creds := globalActiveCred b.Run("uncached", func(b *testing.B) { fn := authenticateNode b.ResetTimer() b.ReportAllocs() for i := 0; i < b.N; i++ { fn(creds.AccessKey, creds.SecretKey, "aud") } })
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Apr 19 16:45:14 UTC 2024 - 4.5K bytes - Viewed (0)