- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 60 for makeEp (0.3 sec)
-
src/runtime/netpoll_aix.go
func netpollinit() { // Create the pipe we use to wakeup poll. r, w, errno := nonblockingPipe() if errno != 0 { throw("netpollinit: failed to create pipe") } rdwake = r wrwake = w // Pre-allocate array of pollfd structures for poll. pfds = make([]pollfd, 1, 128) // Poll the read side of the pipe. pfds[0].fd = rdwake pfds[0].events = _POLLIN pds = make([]*pollDesc, 1, 128) pds[0] = nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 5.1K bytes - Viewed (0) -
src/runtime/trace.go
// timer *and* nothing else will call wake concurrently. func (s *wakeableSleep) close() { // Set wakeup to nil so that a late timer ends up being a no-op. lock(&s.lock) if raceenabled { raceacquire(unsafe.Pointer(&s.lock)) } wakeup := s.wakeup s.wakeup = nil // Close the channel. close(wakeup) if raceenabled { racerelease(unsafe.Pointer(&s.lock)) } unlock(&s.lock)
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/reflect/export_test.go
// license that can be found in the LICENSE file. package reflect import ( "internal/abi" "internal/goarch" "sync" "unsafe" ) // MakeRO returns a copy of v with the read-only flag set. func MakeRO(v Value) Value { v.flag |= flagStickyRO return v } // IsRO reports whether v's read-only flag is set. func IsRO(v Value) bool { return v.flag&flagStickyRO != 0 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 15:10:48 UTC 2024 - 3.8K bytes - Viewed (0) -
src/runtime/sema.go
// Intended use is provide a sleep and wakeup // primitive that can be used in the contended case // of other synchronization primitives. // Thus it targets the same goal as Linux's futex, // but it has much simpler semantics. // // That is, don't think of these as semaphores. // Think of them as a way to implement sleep and wakeup // such that every sleep is paired with a single wakeup,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 19K bytes - Viewed (0) -
src/cmd/compile/internal/walk/builtin.go
// Handling make(map[any]any) and // make(map[any]any, hint) where hint <= BUCKETSIZE // special allows for faster map initialization and // improves binary size by using calls with fewer arguments. // For hint <= BUCKETSIZE overLoadFactor(hint, 0) is false // and no buckets will be allocated by makemap. Therefore, // no buckets need to be allocated in this code path.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 08 22:35:22 UTC 2024 - 31.2K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector_test.go
func TestConflictingData(t *testing.T) { pod1ns1 := makeID("v1", "Pod", "ns1", "podname1", "poduid1") pod2ns1 := makeID("v1", "Pod", "ns1", "podname2", "poduid2") pod2ns2 := makeID("v1", "Pod", "ns2", "podname2", "poduid2") node1 := makeID("v1", "Node", "", "nodename", "nodeuid1") role1v1beta1 := makeID("rbac.authorization.k8s.io/v1beta1", "Role", "ns1", "role1", "roleuid1")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.6K bytes - Viewed (0) -
platforms/core-runtime/client-services/src/main/java/org/gradle/internal/daemon/client/serialization/ClasspathInferer.java
private final Lock lock = new ReentrantLock(); private final Map<Class<?>, Collection<URI>> classPathCache; public ClasspathInferer() { this.classPathCache = new MapMaker().weakKeys().makeMap(); } public void getClassPathFor(Class<?> targetClass, Collection<URI> dest) { lock.lock(); try { Collection<URI> classPath = classPathCache.get(targetClass);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:53:31 UTC 2024 - 5.9K bytes - Viewed (0) -
src/math/big/bits_test.go
x.SetBit(x, badj, 0) badj++ } x.SetBit(x, badj, 1) } // create corresponding float z := new(Float).SetInt(x) // normalized if e := int64(z.exp) + int64(min); MinExp <= e && e <= MaxExp { z.exp = int32(e) } else { // this should never happen for our test cases panic("exponent out of range") } return z } func TestFromBits(t *testing.T) { for _, test := range []struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 5.1K bytes - Viewed (0) -
src/runtime/netpoll_kqueue.go
return 0 } func netpollarm(pd *pollDesc, mode int) { throw("runtime: unused") } // netpollBreak interrupts a kevent. func netpollBreak() { // Failing to cas indicates there is an in-flight wakeup, so we're done here. if !netpollWakeSig.CompareAndSwap(0, 1) { return } wakeNetpoll(kq) } // netpoll checks for ready network connections. // Returns list of goroutines that become runnable.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 12 21:17:22 UTC 2024 - 4.6K bytes - Viewed (0) -
src/cmd/trace/main.go
mux.Handle("/", traceviewer.MainHandler([]traceviewer.View{ {Type: traceviewer.ViewProc, Ranges: ranges}, // N.B. Use the same ranges for threads. It takes a long time to compute // the split a second time, but the makeup of the events are similar enough // that this is still a good split. {Type: traceviewer.ViewThread, Ranges: ranges}, })) // Catapult handlers. mux.Handle("/trace", traceviewer.TraceHandler())
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 10.4K bytes - Viewed (0)