Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 34 for MakeOp (0.47 sec)

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