- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 87 for suspending (0.5 sec)
-
platforms/core-configuration/graph-serialization/src/main/kotlin/org/gradle/internal/serialize/graph/Running.kt
*/ fun <T : WriteContext, U> T.runWriteOperation(writeOperation: suspend T.() -> U): U = runToCompletion { writeOperation() } /** * [Starts][startCoroutine] the suspending [block], asserts it runs * to completion and returns its result. */ private fun <R> runToCompletion(block: suspend () -> R): R { var completion: Result<R>? = null block.startCoroutine(
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 22 20:48:51 UTC 2024 - 1.8K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl/src/main/kotlin/org/gradle/kotlin/dsl/concurrent/future.kt
import kotlin.coroutines.Continuation import kotlin.coroutines.CoroutineContext import kotlin.coroutines.EmptyCoroutineContext import kotlin.coroutines.startCoroutine /** * Starts and exposes the given suspending [computation] as a [Future] value. * * The [computation] executes synchronously until its first suspension point. */ internal
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Aug 02 08:06:49 UTC 2023 - 2.2K bytes - Viewed (0) -
platforms/core-configuration/graph-serialization/src/main/kotlin/org/gradle/internal/serialize/graph/Codec.kt
val classLoader: ClassLoader fun beanStateReaderFor(beanType: Class<*>): BeanStateReader /** * When in immediate mode, [read] calls are NOT suspending. * Useful for bridging with non-suspending serialization protocols such as [java.io.Serializable]. */ var immediateMode: Boolean // TODO:configuration-cache prevent StackOverflowErrors when crossing protocols
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 23:09:56 UTC 2024 - 7.9K bytes - Viewed (0) -
helm/minio/templates/_helper_create_bucket.txt
if [ ! -z $VERSIONING ]; then if [ $VERSIONING = true ]; then echo "Enabling versioning for '$BUCKET'" ${MC} version enable myminio/$BUCKET elif [ $VERSIONING = false ]; then echo "Suspending versioning for '$BUCKET'" ${MC} version suspend myminio/$BUCKET fi fi else echo "Bucket '$BUCKET' versioning unchanged." fi # At this point, the bucket should exist, skip checking for existence
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jan 12 18:18:57 UTC 2024 - 3.5K bytes - Viewed (0) -
src/runtime/preempt.go
// state was observed, so the caller must not assume that it // remains dead. dead bool // stopped indicates that this suspendG transitioned the G to // _Gwaiting via g.preemptStop and thus is responsible for // readying it when done. stopped bool } // suspendG suspends goroutine gp at a safe-point and returns the // state of the suspended goroutine. The caller gets read access to
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/os_windows.go
// external C code. // // This protects against races between preemptM calling // SuspendThread and external code on this thread calling // ExitProcess. If these happen concurrently, it's possible to // exit the suspending thread and suspend the exiting thread, // leading to deadlock. // // 0 indicates this M is not being preempted or in external // code. Entering external code CASes this from 0 to 1. If
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 22:55:25 UTC 2024 - 41.5K bytes - Viewed (0) -
docs/bucket/versioning/README.md
Versioning must be explicitly enabled on a bucket, versioning is not enabled by default. Object locking enabled buckets have versioning enabled automatically. Enabling and suspending versioning is done at the bucket level.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 04 21:43:52 UTC 2023 - 11.9K bytes - Viewed (0) -
src/syscall/syscall_darwin.go
continue } reclen := int(entry.Reclen) if reclen > len(buf) { // Not enough room. Return for now. // The counter will let us know where we should start up again. // Note: this strategy for suspending in the middle and // restarting is O(n^2) in the length of the directory. Oh well. break } // Copy entry into return buffer. copy(buf, unsafe.Slice((*byte)(unsafe.Pointer(&entry)), reclen))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:50 UTC 2024 - 11K bytes - Viewed (0) -
common-protos/k8s.io/api/batch/v1/generated.proto
// false to true), the Job controller will delete all active Pods associated // with this Job. Users must design their workload to gracefully handle this. // Suspending a Job will reset the StartTime field of the Job, effectively // resetting the ActiveDeadlineSeconds timer too. Defaults to false. // // +optional optional bool suspend = 10; }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 21.1K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
expectedDeletions: 2, expectedCompletedIdxs: "0", expectedActive: 0, expectedFailed: 0, expectedPodPatches: 5, expectedReady: ptr.To[int32](0), }, "suspending a job with satisfied expectations": { // Suspended Job should delete active pods when expectations are // satisfied. suspend: true, parallelism: 2,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0)