- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for Preemptable (0.14 sec)
-
src/runtime/preempt.go
// // This must be called from the system stack and the user goroutine on // the current M (if any) must be in a preemptible state. This // prevents deadlocks where two goroutines attempt to suspend each // other and both are in non-preemptible states. There are other ways // to resolve this deadlock, but this seems simplest. // // TODO(austin): What if we instead required this to be called from a
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 15:41:45 UTC 2024 - 15.1K bytes - Viewed (0) -
src/runtime/mgcmark.go
// would be a performance hit. // Instead we recheck it here on the non-preemptible system // stack to determine if we should perform an assist. // GC is done, so ignore any remaining debt. gp.gcAssistBytes = 0 return } // Track time spent in this assist. Since we're on the // system stack, this is non-preemptible, so we can // just measure start and end time. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 18 21:25:11 UTC 2024 - 52.5K bytes - Viewed (0) -
cluster/gce/config-test.sh
NODE_LABELS="${NODE_LABELS},cloud.google.com/gke-preemptible=true" WINDOWS_NODE_LABELS="${WINDOWS_NODE_LABELS},cloud.google.com/gke-preemptible=true" elif [[ "${PREEMPTIBLE_NODE}" = 'true' ]]; then NON_MASTER_NODE_LABELS="${NON_MASTER_NODE_LABELS},cloud.google.com/gke-preemptible=true" WINDOWS_NON_MASTER_NODE_LABELS="${WINDOWS_NON_MASTER_NODE_LABELS},cloud.google.com/gke-preemptible=true" fi # Optional: Enable netd.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 17:20:24 UTC 2024 - 29.8K bytes - Viewed (0) -
cluster/gce/config-default.sh
NODE_LABELS="${NODE_LABELS},cloud.google.com/gke-preemptible=true" WINDOWS_NODE_LABELS="${WINDOWS_NODE_LABELS},cloud.google.com/gke-preemptible=true" elif [[ "${PREEMPTIBLE_NODE}" == "true" ]]; then NON_MASTER_NODE_LABELS="${NON_MASTER_NODE_LABELS},cloud.google.com/gke-preemptible=true" WINDOWS_NON_MASTER_NODE_LABELS="${WINDOWS_NON_MASTER_NODE_LABELS},cloud.google.com/gke-preemptible=true" fi
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 20:16:32 UTC 2024 - 26.9K bytes - Viewed (0) -
src/runtime/mcache.go
}) } // getMCache is a convenience function which tries to obtain an mcache. // // Returns nil if we're not bootstrapping or we don't have a P. The caller's // P must not change, so we must be in a non-preemptible state. func getMCache(mp *m) *mcache { // Grab the mcache, since that's where stats live. pp := mp.p.ptr() var c *mcache if pp == nil { // We will be called without a P while bootstrapping,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 10K bytes - Viewed (0) -
src/runtime/mgclimit.go
// Drain the pool of idle time. idleTime := l.idleTimePool.Load() if idleTime != 0 { l.idleTimePool.Add(-idleTime) } if !l.test { // Consume time from in-flight events. Make sure we're not preemptible so allp can't change. // // The reason we do this instead of just waiting for those events to finish and push updates // is to ensure that all the time we're accounting for happened sometime between lastUpdate
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 22:07:41 UTC 2024 - 17.3K bytes - Viewed (0) -
src/runtime/mgcwork.go
// true if it should be called again to free more. func freeSomeWbufs(preemptible bool) bool { const batchSize = 64 // ~1–2 µs per span. lock(&work.wbufSpans.lock) if gcphase != _GCoff || work.wbufSpans.free.isEmpty() { unlock(&work.wbufSpans.lock) return false } systemstack(func() { gp := getg().m.curg for i := 0; i < batchSize && !(preemptible && gp.preempt); i++ { span := work.wbufSpans.free.first
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 12.9K bytes - Viewed (0) -
src/runtime/arena.go
} // setUserArenaChunkToFault sets the address space for the user arena chunk to fault // and releases any underlying memory resources. // // Must be in a non-preemptible state to ensure the consistency of statistics // exported to MemStats. func (s *mspan) setUserArenaChunkToFault() { if !s.isUserArenaChunk { throw("invalid span in heapArena for user arena") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:44:56 UTC 2024 - 37.9K bytes - Viewed (0) -
src/runtime/mwbbuf.go
// // This must not have write barriers because it is part of the write // barrier implementation, so this may lead to infinite loops or // buffer corruption. // // This must be non-preemptible because it uses the P's workbuf. // //go:nowritebarrierrec //go:systemstack func wbBufFlush1(pp *p) { // Get the buffered pointers. start := uintptr(unsafe.Pointer(&pp.wbBuf.buf[0]))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 8.1K bytes - Viewed (0) -
hack/make-rules/test-e2e-node.sh
--image-config-file="${image_config_file}" --system-spec-name="${system_spec_name}" \ --runtime-config="${runtime_config}" --preemptible-instances="${preemptible_instances}" \ --ssh-user="${ssh_user}" --ssh-key="${ssh_key}" --ssh-options="${ssh_options}" \ --image-config-dir="${image_config_dir}" --node-env="${node_env}" \
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 16 09:46:28 UTC 2024 - 10.7K bytes - Viewed (0)