Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for semrelease1 (0.31 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top