Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 61 for MakeOp (0.33 sec)

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