- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 61 for MakeOp (0.33 sec)
-
pilot/pkg/serviceregistry/mock/discovery_mock.go
ExtHTTPSService = MakeExternalHTTPSService("httpsbin.default.svc.cluster.local", true, "") // HelloInstanceV0 is a mock IP address for v0 of HelloService HelloInstanceV0 = MakeIP(HelloService, 0) // HelloProxyV0 is a mock proxy v0 of HelloService HelloProxyV0 = model.Proxy{ Type: model.SidecarProxy, IPAddresses: []string{HelloInstanceV0}, ID: "v0.default",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 23 02:37:56 UTC 2022 - 2.7K bytes - Viewed (0) -
src/internal/trace/trace_test.go
t.Logf("%d: %q", samples, stack) } t.Logf("CPU profile:\n%s", stderr) } }) } func TestTraceFutileWakeup(t *testing.T) { testTraceProg(t, "futile-wakeup.go", func(t *testing.T, tb, _ []byte, _ bool) { // Check to make sure that no goroutine in the "special" trace region // ends up blocking, unblocking, then immediately blocking again. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 18.5K 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) -
src/runtime/netpoll_solaris.go
default: throw("runtime: bad mode") } unlock(&pd.lock) } // netpollBreak interrupts a port_getn wait. func netpollBreak() { // Failing to cas indicates there is an in-flight wakeup, so we're done here. if !netpollWakeSig.CompareAndSwap(0, 1) { return } // Use port_alert to put portfd into alert mode. // This will wake up all threads sleeping in port_getn on portfd,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 11.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
} catch (InterruptedException ie) { // continue } LockSupport.unpark(Thread.currentThread()); // simulate a spurious wakeup. return null; } @Override boolean isDone() { return false; } @Override String toPendingString() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 6.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
} catch (InterruptedException ie) { // continue } LockSupport.unpark(Thread.currentThread()); // simulate a spurious wakeup. return null; } @Override boolean isDone() { return false; } @Override String toPendingString() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 6.6K bytes - Viewed (0) -
src/runtime/proc.go
// Must be called with a P. // // wakep should be an internal detail, // but widely used packages access it using linkname. // Notable members of the hall of shame include: // - gvisor.dev/gvisor // // Do not remove or change the type signature. // See go.dev/issue/67401. // //go:linkname wakep func wakep() { // Be conservative about spinning threads, only start one if none exist
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 207.5K bytes - Viewed (0) -
src/internal/poll/fd_mutex.go
} // Remove all read and write waiters. new &^= mutexRMask | mutexWMask if atomic.CompareAndSwapUint64(&mu.state, old, new) { // Wake all read and write waiters, // they will observe closed flag after wakeup. for old&mutexRMask != 0 { old -= mutexRWait runtime_Semrelease(&mu.rsema) } for old&mutexWMask != 0 { old -= mutexWWait runtime_Semrelease(&mu.wsema) } return true }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 20 16:55:30 UTC 2018 - 6.4K bytes - Viewed (0) -
pkg/kubelet/eviction/threshold_notifier_linux.go
if event.Fd == int32(eventfd) { if event.Events&unix.EPOLLHUP != 0 || event.Events&unix.EPOLLERR != 0 || event.Events&unix.EPOLLIN != 0 { // EPOLLHUP: should not happen, but if it does, treat it as a wakeup. // EPOLLERR: If an error is waiting on the file descriptor, we should pretend // something is ready to read, and let unix.Read pick up the error. // EPOLLIN: There is data to read.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 01 21:59:54 UTC 2022 - 5.8K 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)