- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for MakeOp (0.26 sec)
-
src/internal/trace/testdata/testprog/futile-wakeup.go
Carlos Amedee <******@****.***> 1715265901 -0400
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.8K bytes - Viewed (0) -
src/internal/trace/parser.go
EvHeapGoal = 34 // gcController.heapGoal change [timestamp, heap goal bytes] EvTimerGoroutine = 35 // denotes timer goroutine [timer goroutine id] EvFutileWakeup = 36 // denotes that the previous wakeup of this goroutine was futile [timestamp] EvString = 37 // string dictionary entry [ID, length, string] EvGoStartLocal = 38 // goroutine starts running on the same P as the last event [timestamp, goroutine id]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:31:04 UTC 2024 - 4.7K bytes - Viewed (0) -
src/runtime/lock_sema.go
throw("notewakeup - double wakeup") default: // Must be the waiting m. Wake it up. semawakeup((*m)(unsafe.Pointer(v))) } } func notesleep(n *note) { gp := getg() if gp != gp.m.g0 { throw("notesleep not on g0") } semacreate(gp.m) if !atomic.Casuintptr(&n.key, 0, uintptr(unsafe.Pointer(gp.m))) { // Must be locked (got wakeup). if n.key != locked {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 6.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/mock/discovery.go
MeshExternal: isMeshExternal, Ports: []*model.Port{{ Name: "https", Port: 443, Protocol: protocol.HTTPS, }}, } } // MakeIP creates a fake IP address for a service and instance version func MakeIP(service *model.Service, version int) string { // external services have no instances if service.External() { return "" } ipa, ise := netip.ParseAddr(service.DefaultAddress)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 07 18:40:05 UTC 2023 - 3.7K bytes - Viewed (0) -
src/runtime/netpoll_aix.go
rdwake int32 wrwake int32 pendingUpdates int32 netpollWakeSig atomic.Uint32 // used to avoid duplicate calls of netpollBreak ) 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.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 5.1K bytes - Viewed (0) -
pilot/pkg/xds/xds_cache_test.go
} } func TestXdsCache(t *testing.T) { makeEp := func(subset string, dr *model.ConsolidatedDestRule) *endpoints.EndpointBuilder { svc := &model.Service{Hostname: "foo.com"} b := endpoints.NewCDSEndpointBuilder( proxy, nil, fmt.Sprintf("outbound|%s|foo.com", subset), model.TrafficDirectionOutbound, subset, "foo.com", 80, svc, dr) return b } ep1 := makeEp("1", nil) ep2 := makeEp("2", nil)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Aug 31 20:43:08 UTC 2023 - 7.8K bytes - Viewed (0) -
src/runtime/lock_futex.go
// One-time notifications. func noteclear(n *note) { n.key = 0 } func notewakeup(n *note) { old := atomic.Xchg(key32(&n.key), 1) if old != 0 { print("notewakeup - double wakeup (", old, ")\n") throw("notewakeup - double wakeup") } futexwakeup(key32(&n.key), 1) } func notesleep(n *note) { gp := getg() if gp != gp.m.g0 { throw("notesleep not on g0") } ns := int64(-1)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:34 UTC 2024 - 5.4K bytes - Viewed (0) -
src/runtime/lock_wasip1.go
} l.key = mutex_unlocked } // One-time notifications. func noteclear(n *note) { n.key = 0 } func notewakeup(n *note) { if n.key != 0 { print("notewakeup - double wakeup (", n.key, ")\n") throw("notewakeup - double wakeup") } n.key = 1 } func notesleep(n *note) { throw("notesleep not supported by wasi") } func notetsleep(n *note, ns int64) bool { throw("notetsleep not supported by wasi")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 21:02:20 UTC 2023 - 2K bytes - Viewed (0) -
cni/pkg/plugin/cnieventclient_test.go
Netns: "someNetNS", IfName: "ethBro", ContainerID: "bbb-eee-www", } var ( fakeIP = net.ParseIP("99.9.9.9") fakeGW = net.ParseIP("88.9.9.9") fakeIDX = 0 fakePrevResultIPConfig = cniv1.IPConfig{ Interface: &fakeIDX, Address: net.IPNet{ IP: fakeIP, }, Gateway: fakeGW, } ) func TestPushCNIAddEventSucceed(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 26 20:34:28 UTC 2024 - 4.2K bytes - Viewed (0) -
src/runtime/netpoll_epoll.go
} func netpollarm(pd *pollDesc, mode int) { throw("runtime: unused") } // netpollBreak interrupts an epollwait. func netpollBreak() { // Failing to cas indicates there is an in-flight wakeup, so we're done here. if !netpollWakeSig.CompareAndSwap(0, 1) { return } var one uint64 = 1 oneSize := int32(unsafe.Sizeof(one)) for { n := write(netpollEventFd, noescape(unsafe.Pointer(&one)), oneSize)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 4.6K bytes - Viewed (0)