- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 35 for unblockSend (0.33 sec)
-
src/runtime/traceruntime.go
} // GoUnpark emits a GoUnblock event. func (tl traceLocker) GoUnpark(gp *g, skip int) { // Emit a GoWaiting status if necessary for the unblocked goroutine. w := tl.eventWriter(traceGoRunning, traceProcRunning) // Careful: don't use the event writer. We never want status or in-progress events // to trigger more in-progress events.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:31:00 UTC 2024 - 25.7K bytes - Viewed (0) -
src/net/net.go
// time limit; see SetDeadline and SetWriteDeadline. Write(b []byte) (n int, err error) // Close closes the connection. // Any blocked Read or Write operations will be unblocked and return errors. Close() error // LocalAddr returns the local network address, if known. LocalAddr() Addr // RemoteAddr returns the remote network address, if known. RemoteAddr() Addr
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 26.8K bytes - Viewed (0) -
src/runtime/sigqueue.go
// * sigIdle means that there are no new pending signals and signal_recv is not // blocked. // // Transitions between states are done atomically with CAS. // // When signal_recv is unblocked, it resets sig.Note and rechecks sig.mask. // If several sigsends and signal_recv execute concurrently, it can lead to // unnecessary rechecks of sig.mask, but it cannot lead to missed signals // nor deadlocks.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 7.6K bytes - Viewed (0) -
src/runtime/traceevent.go
traceEvGoStop // goroutine yields its time, but is runnable [timestamp, reason, stack ID] traceEvGoBlock // goroutine blocks [timestamp, reason, stack ID] traceEvGoUnblock // goroutine is unblocked [timestamp, goroutine ID, goroutine seq, stack ID] traceEvGoSyscallBegin // syscall enter [timestamp, P seq, stack ID] traceEvGoSyscallEnd // syscall exit [timestamp]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:47:01 UTC 2024 - 9.2K bytes - Viewed (0) -
src/internal/trace/event/go122/event.go
EvGoStop // goroutine yields its time, but is runnable [timestamp, reason, stack ID] EvGoBlock // goroutine blocks [timestamp, reason, stack ID] EvGoUnblock // goroutine is unblocked [timestamp, goroutine ID, goroutine seq, stack ID] EvGoSyscallBegin // syscall enter [timestamp, P seq, stack ID] EvGoSyscallEnd // syscall exit [timestamp]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 14.8K bytes - Viewed (0) -
tensorflow/c/c_api_experimental.h
// from a placeholder node "arg_tensor_enqueue_<tensor_id>". // // `tensor` is still owned by the caller. This call will be blocked if the queue // has reached its capacity, and will be unblocked when the queued tensors again // drop below the capacity due to dequeuing. // // Tensors are dequeued via the corresponding TF dequeue op. // TODO(hongm): Add support for `timeout_ms`.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 27 21:07:00 UTC 2023 - 15.1K bytes - Viewed (0) -
pkg/kubelet/pleg/evented.go
"k8s.io/utils/clock" ) // The frequency with which global timestamp of the cache is to // is to be updated periodically. If pod workers get stuck at cache.GetNewerThan // call, after this period it will be unblocked. const globalCacheUpdatePeriod = 5 * time.Second var ( eventedPLEGUsage = false eventedPLEGUsageMu = sync.RWMutex{} ) // isEventedPLEGInUse indicates whether Evented PLEG is in use. Even after enabling
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 10:46:06 UTC 2024 - 16.4K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller.go
// overlappingServiceCIDRs, given a ServiceCIDR return the ServiceCIDRs that contain or are contained, // this is required because adding or removing a CIDR will require to recompute the // state of each ServiceCIDR to check if can be unblocked on deletion. func (c *Controller) overlappingServiceCIDRs(serviceCIDR *networkingapiv1alpha1.ServiceCIDR) []string { c.muTree.Lock() defer c.muTree.Unlock() serviceCIDRs := sets.New[string]()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18K bytes - Viewed (0) -
src/runtime/netpoll.go
netpollarm(pd, mode) } for !netpollblock(pd, int32(mode), false) { errcode = netpollcheckerr(pd, int32(mode)) if errcode != pollNoError { return errcode } // Can happen if timeout has fired and unblocked us, // but before we had a chance to run, timeout has been reset. // Pretend it has not happened and retry. } return pollNoError }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 19:57:43 UTC 2024 - 20.7K bytes - Viewed (0) -
src/internal/trace/internal/oldtrace/parser.go
EvGoSleep event.Type = 19 // goroutine calls Sleep [timestamp, stack] EvGoBlock event.Type = 20 // goroutine blocks [timestamp, stack] EvGoUnblock event.Type = 21 // goroutine is unblocked [timestamp, goroutine id, seq, stack] EvGoBlockSend event.Type = 22 // goroutine blocks on chan send [timestamp, stack] EvGoBlockRecv event.Type = 23 // goroutine blocks on chan recv [timestamp, stack]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 46.8K bytes - Viewed (0)