- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 842 for held (0.15 sec)
-
src/runtime/pprof/label.go
func labelValue(ctx context.Context) labelMap { labels, _ := ctx.Value(labelContextKey{}).(*labelMap) if labels == nil { return labelMap(nil) } return *labels } // labelMap is the representation of the label set held in the context type. // This is an initial implementation, but it will be replaced with something // that admits incremental immutable modification more efficiently. type labelMap map[string]string
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 3K bytes - Viewed (0) -
src/runtime/mheap.go
// Try directly allocating from the current head arena. head := (*gcBitsArena)(atomic.Loadp(unsafe.Pointer(&gcBitsArenas.next))) if p := head.tryAlloc(bytesNeeded); p != nil { return p } // There's not enough room in the head arena. We may need to // allocate a new arena. lock(&gcBitsArenas.lock) // Try the head arena again, since it may have changed. Now // that we hold the lock, the list head can't change, but its
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:31:00 UTC 2024 - 78K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
override fun clone(): Call = RealCall(client, originalRequest, forWebSocket) override fun request(): Request = originalRequest /** * Immediately closes the socket connection if it's currently held. Use this to interrupt an * in-flight request from any thread. It's the caller's responsibility to close the request body * and response body streams; otherwise resources may be leaked. *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 17.9K bytes - Viewed (0) -
src/sync/map.go
// concurrent access (with or without mu held). // // The read field itself is always safe to load, but must only be stored with // mu held. // // Entries stored in read may be updated concurrently without mu, but updating // a previously-expunged entry requires that the entry be copied to the dirty // map and unexpunged with mu held. read atomic.Pointer[readOnly]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 15.6K bytes - Viewed (0) -
platforms/core-runtime/build-process-services/src/test/groovy/org/gradle/internal/installation/CurrentGradleInstallationLocatorTest.groovy
it.write(cw.toByteArray()) } contents.zipTo(jar) } private Class loadClassFromJar(TestFile jar) { // This is to prevent the jar file being held open URL url = new URL("jar:file://valid_jar_url_syntax.jar!/") URLConnection urlConnection = url.openConnection() def original = urlConnection.getDefaultUseCaches()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 24 06:16:07 UTC 2024 - 3.9K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/moduleconverter/dependencies/DefaultLocalConfigurationMetadataBuilder.java
for (PublishArtifact ownArtifact : ownArtifacts) { // The following line may realize tasks, so project lock must be held. result.add(new PublishArtifactLocalArtifactMetadata(componentId, ownArtifact)); } // TODO: Deprecate the behavior of inheriting artifacts from parent configurations.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 22 16:00:57 UTC 2024 - 18K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sync/semaphore/semaphore.go
} // Release releases the semaphore with a weight of n. func (s *Weighted) Release(n int64) { s.mu.Lock() s.cur -= n if s.cur < 0 { s.mu.Unlock() panic("semaphore: released more than held") } s.notifyWaiters() s.mu.Unlock() } func (s *Weighted) notifyWaiters() { for { next := s.waiters.Front() if next == nil { break // No more waiters blocked. }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 02:38:00 UTC 2024 - 4.3K bytes - Viewed (0) -
platforms/extensibility/unit-test-fixtures/src/test/groovy/org/gradle/testfixtures/ProjectBuilderTest.groovy
def task = project.task('custom', type: CustomTask) task.doStuff() then: task.property == 'some value' } @LeaksFileHandles("script jar is held open") def canApplyABuildScript() { when: def project = buildProject() project.apply from: resources.getResource('ProjectBuilderTest.gradle') then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 13 21:54:27 UTC 2024 - 5.5K bytes - Viewed (0) -
src/cmd/trace/gstate.go
stk = ctx.Stack(viewerFrames(gs.lastStopStack)) } // Check invariants. if gs.startRunningTime == 0 { panic("silently broken trace or generator invariant (startRunningTime != 0) not held") } if gs.executing == R(noResource) { panic("non-executing goroutine stopped") } ctx.Slice(traceviewer.SliceEvent{ Name: gs.name(), Ts: ctx.elapsed(gs.startRunningTime),
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 11.9K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/DefaultFileLockManager.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 26 16:02:32 UTC 2024 - 22.3K bytes - Viewed (0)