- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 61 for MakeOp (0.14 sec)
-
src/runtime/HACKING.md
For one-shot notifications, use `note`, which provides `notesleep` and `notewakeup`. Unlike traditional UNIX `sleep`/`wakeup`, `note`s are race-free, so `notesleep` returns immediately if the `notewakeup` has already happened. A `note` can be reset after use with `noteclear`, which must not race with a sleep or wakeup. Like `mutex`, blocking on a `note` blocks the M. However, there are different ways to sleep on a
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 13.9K bytes - Viewed (0) -
src/runtime/lock_js.go
notesWithTimeout = make(map[*note]noteWithTimeout) ) func noteclear(n *note) { n.key = note_cleared } func notewakeup(n *note) { // gp := getg() if n.key == note_woken { throw("notewakeup - double wakeup") } cleared := n.key == note_cleared n.key = note_woken if cleared { goready(notes[n], 1) } } func notesleep(n *note) { throw("notesleep not supported by js") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 21:02:20 UTC 2023 - 7.3K bytes - Viewed (0) -
fess-crawler-lasta/src/main/resources/crawler/extractor.xml
"application/vnd.japannet-jpnstore-wakeup", "application/vnd.japannet-payment-wakeup", "application/vnd.japannet-registration", "application/vnd.japannet-registration-wakeup", "application/vnd.japannet-setstore-wakeup", "application/vnd.japannet-verification", "application/vnd.japannet-verification-wakeup", "application/vnd.jcp.javame.midlet-rms", "application/vnd.jisp",
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Sat Aug 01 21:40:30 UTC 2020 - 49K bytes - Viewed (0) -
src/sync/mutex.go
} } else { // Starving mode: handoff mutex ownership to the next waiter, and yield // our time slice so that the next waiter can start to run immediately. // Note: mutexLocked is not set, the waiter will set it after wakeup. // But mutex is still considered locked if mutexStarving is set, // so new coming goroutines won't acquire it. runtime_Semrelease(&m.sema, true, 1) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 8.4K bytes - Viewed (0) -
src/runtime/tracecpu.go
// Sleep here because traceReadCPU is non-blocking. This mirrors // how the runtime/pprof package obtains CPU profile data. // // We can't do a blocking read here because Darwin can't do a // wakeup from a signal handler, so all CPU profiling is just // non-blocking. See #61768 for more details. // // Like the runtime/pprof package, even if that bug didn't exist
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 17:03:35 UTC 2024 - 8.7K 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) -
src/runtime/netpoll_windows.go
// nothing to do return 0 } func netpollarm(pd *pollDesc, mode int) { throw("runtime: unused") } func netpollBreak() { // Failing to cas indicates there is an in-flight wakeup, so we're done here. if !netpollWakeSig.CompareAndSwap(0, 1) { return } key := packNetpollKey(netpollSourceBreak, nil) if stdcall4(_PostQueuedCompletionStatus, iocphandle, 0, key, 0) == 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 9.4K bytes - Viewed (0) -
src/runtime/os_darwin.go
} } //go:nosplit func semasleep(ns int64) int32 { var start int64 if ns >= 0 { start = nanotime() } g := getg() mp := g.m if g == mp.gsignal { // sema sleep/wakeup are implemented with pthreads, which are not async-signal-safe on Darwin. throw("semasleep on Darwin signal stack") } pthread_mutex_lock(&mp.mutex) for { if mp.count > 0 { mp.count--
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Dec 05 20:34:30 UTC 2023 - 11.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller_test.go
t.Fatal("Returned Instance is incorrect") } } // Get Instances from mockAdapter2 instances = aggregateCtl.GetProxyServiceTargets(&model.Proxy{IPAddresses: []string{mock.MakeIP(mock.WorldService, 1)}}) if len(instances) != 6 { t.Fatalf("Returned GetProxyServiceTargets' amount %d is not correct", len(instances)) } for _, inst := range instances {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 14.5K bytes - Viewed (0) -
pkg/workloadapi/workload.proto
// TODO: support this field string hostname = 21; // Network represents the network this workload is on. This may be elided for the default network. // A (network,address) pair makeup a unique key for a workload *at a point in time*. string network = 4; // Protocol that should be used to connect to this workload. TunnelProtocol tunnel_protocol = 5;
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:02:35 UTC 2024 - 12.9K bytes - Viewed (0)