- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for semrelease1 (0.31 sec)
-
src/runtime/sema.go
break } } if s.releasetime > 0 { blockevent(s.releasetime-t0, 3+skipframes) } releaseSudog(s) } func semrelease(addr *uint32) { semrelease1(addr, false, 0) } func semrelease1(addr *uint32, handoff bool, skipframes int) { root := semtable.rootFor(addr) atomic.Xadd(addr, 1) // Easy case: no waiters?
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 19K bytes - Viewed (0) -
src/runtime/metrics_test.go
return false } runtime.Semacquire(&sem) runtime.Semrelease1(&sem, false, 0) if runtime.MutexContended(runtime.SemRootLock(&sem)) { sawContention.Add(1) } return true } stks := [][]string{ { "runtime.unlock", "runtime.semrelease1", "runtime_test.TestRuntimeLockMetricsAndProfile.func6.1",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:52:17 UTC 2024 - 45K bytes - Viewed (0) -
src/runtime/export_test.go
var MutexContended = mutexContended func SemRootLock(addr *uint32) *mutex { root := semtable.rootFor(addr) return &root.lock } var Semacquire = semacquire var Semrelease1 = semrelease1 func SemNwait(addr *uint32) uint32 { root := semtable.rootFor(addr) return root.nwait.Load() } const SemTableSize = semTabSize
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:50:53 UTC 2024 - 46.1K bytes - Viewed (0) -
src/runtime/trace.go
// other calls to traceAdvance. semrelease1(&traceAdvanceSema, true, 0) if stopTrace { // Stop the traceAdvancer. We can't be holding traceAdvanceSema here because // we'll deadlock (we're blocked on the advancer goroutine exiting, but it // may be currently trying to acquire traceAdvanceSema). traceAdvancer.stop() semrelease(&traceShutdownSema) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:17:41 UTC 2024 - 37.1K bytes - Viewed (0) -
src/runtime/proc.go
// worldsema must be held over startTheWorldWithSema to ensure // gomaxprocs cannot change while worldsema is held. // // Release worldsema with direct handoff to the next waiter, but // acquirem so that semrelease1 doesn't try to yield our time. // // Otherwise if e.g. ReadMemStats is being called in a loop, // it might stomp on other attempts to stop the world, such as
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 207.5K bytes - Viewed (0) -
maven-resolver-provider/src/main/java/org/apache/maven/repository/internal/VersionsMetadata.java
Versioning versioning = new Versioning(); versioning.addVersion(artifact.getBaseVersion()); if (!artifact.isSnapshot()) { versioning.setRelease(artifact.getBaseVersion()); } if ("maven-plugin".equals(artifact.getProperty(ArtifactProperties.TYPE, ""))) { versioning.setLatest(artifact.getBaseVersion()); }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu Apr 25 10:10:21 UTC 2024 - 4.2K bytes - Viewed (0) -
src/runtime/mgc.go
// this goroutine becomes runnable again, and we could // self-deadlock otherwise. semrelease(&worldsema) releasem(mp) // Make sure we block instead of returning to user code // in STW mode. if mode != gcBackgroundMode { Gosched() } semrelease(&work.startSema) } // gcMarkDoneFlushed counts the number of P's with flushed work. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 62K bytes - Viewed (0) -
maven-compat/src/test/java/org/apache/maven/repository/LegacyRepositorySystemTest.java
Repository repository = new Repository(); repository.setId(RepositorySystem.DEFAULT_REMOTE_REPO_ID); repository.setUrl("file://" + repoDir.toURI().getPath()); repository.setReleases(policy); repository.setSnapshots(policy); return Arrays.asList(repositorySystem.buildArtifactRepository(repository)); } protected ArtifactRepository getLocalRepository() throws Exception {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu May 02 15:10:38 UTC 2024 - 8.8K bytes - Viewed (0) -
maven-compat/src/test/java/org/apache/maven/AbstractCoreMavenComponentTestCase.java
Repository repository = new Repository(); repository.setId(MavenRepositorySystem.DEFAULT_REMOTE_REPO_ID); repository.setUrl("file://" + repoDir.toURI().getPath()); repository.setReleases(policy); repository.setSnapshots(policy); return Arrays.asList(repositorySystem.buildArtifactRepository(repository)); }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu May 02 15:10:38 UTC 2024 - 11.7K bytes - Viewed (0) -
maven-core/src/test/java/org/apache/maven/AbstractCoreMavenComponentTestCase.java
Repository repository = new Repository(); repository.setId(MavenRepositorySystem.DEFAULT_REMOTE_REPO_ID); repository.setUrl("file://" + repoDir.toURI().getPath()); repository.setReleases(policy); repository.setSnapshots(policy); return Arrays.asList(mavenRepositorySystem.buildArtifactRepository(repository)); }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Apr 12 10:50:18 UTC 2024 - 11.7K bytes - Viewed (0)