- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 1,597 for held (0.04 sec)
-
src/runtime/mpagealloc.go
// // Returns a 0 base address on failure, in which case other returned values // should be ignored. // // p.mheapLock must be held. // // Must run on the system stack because p.mheapLock must be held. // //go:systemstack func (p *pageAlloc) alloc(npages uintptr) (addr uintptr, scav uintptr) { assertLockHeld(p.mheapLock)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 39.2K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/FixedExclusiveModeCrossProcessCacheAccess.java
import java.util.function.Supplier; import static org.gradle.cache.FileLockManager.LockMode.Exclusive; /** * A {@link CrossProcessCacheAccess} implementation used when a cache is opened with an exclusive lock that is held until the cache is closed. This implementation is simply a no-op for these methods. */ public class FixedExclusiveModeCrossProcessCacheAccess extends AbstractCrossProcessCacheAccess { private final String cacheDisplayName;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 01 12:21:15 UTC 2024 - 3.6K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/api/internal/file/archive/DecompressionCoordinator.java
* <p> * The key is based on the given expanded directory used to extract the archive file. * * @param expandedDir The directory in use for the action * @param action The action to run while the cache is held for the given key */ void exclusiveAccessTo(File expandedDir, Runnable action);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 26 15:15:04 UTC 2024 - 2.1K bytes - Viewed (0) -
platforms/core-execution/build-cache-spi/src/main/java/org/gradle/caching/BuildCacheService.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Feb 09 12:59:40 UTC 2024 - 2.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go
// A lock for writing is needed // for writing to any of the following: // - the flowSchemas field // - the slice held in the flowSchemas field // - the priorityLevelStates field // - the map held in the priorityLevelStates field // - any field of a priorityLevelState held in that map lock sync.RWMutex // flowSchemas holds the flow schema objects, sorted by increasing
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 48.8K bytes - Viewed (0) -
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)