- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 128 for Cond (0.18 sec)
-
src/sync/cond.go
// a call to [Cond.Broadcast] or [Cond.Signal] “synchronizes before” any Wait call // that it unblocks. // // For many simple use cases, users will be better off using channels than a // Cond (Broadcast corresponds to closing a channel, and Signal corresponds to // sending on a channel). // // For more on replacements for [sync.Cond], see [Roberto Clapis's series on
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 4.1K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/nonstructuralschema/nonstructuralschema_controller.go
return nil } // check old condition cond := calculateCondition(inCustomResourceDefinition) old := apiextensionshelpers.FindCRDCondition(inCustomResourceDefinition, apiextensionsv1.NonStructuralSchema) if cond == nil && old == nil { return nil } if cond != nil && old != nil && old.Status == cond.Status && old.Reason == cond.Reason && old.Message == cond.Message { return nil } // update condition
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.3K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/rewritePPC64latelower.go
// cond: v.Block == z.Block // result: (CMPconst [0] convertPPC64OpToOpCC(z)) for { if auxIntToInt64(v.AuxInt) != 0 { break } z := v_0 if z.Op != OpPPC64CNTLZD { break } if !(v.Block == z.Block) { break } v.reset(OpPPC64CMPconst) v.AuxInt = int64ToAuxInt(0) v.AddArg(convertPPC64OpToOpCC(z)) return true } // match: (CMPconst [0] z:(RLDICL x))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 19:59:38 UTC 2024 - 16.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_progress.go
type conditionalProgressRequester struct { clock TickerFactory requestWatchProgress WatchProgressRequester contextMetadata metadata.MD mux sync.Mutex cond *sync.Cond waiting int stopped bool } func (pr *conditionalProgressRequester) Run(stopCh <-chan struct{}) { ctx := wait.ContextForChannel(stopCh) if pr.contextMetadata != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 24 09:56:38 UTC 2024 - 3K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/rewriteARM64.go
} // match: (CMPWconst (MOVBUreg _) [c]) // cond: 0xff < c // result: (FlagConstant [subFlags64(0,1)]) for { c := auxIntToInt32(v.AuxInt) if v_0.Op != OpARM64MOVBUreg || !(0xff < c) { break } v.reset(OpARM64FlagConstant) v.AuxInt = flagConstantToAuxInt(subFlags64(0, 1)) return true } // match: (CMPWconst (MOVHUreg _) [c]) // cond: 0xffff < c
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 15:49:20 UTC 2024 - 608.6K bytes - Viewed (0) -
analysis/analysis-api/testData/components/dataFlowInfoProvider/exitPointSnapshot/controlFlow/differentTargets/break.txt
KaDataFlowExitPointSnapshot: defaultExpressionInfo = DefaultExpressionInfo: expression = if (cond()) { break } else if (cond()) { break@outer } type = kotlin.Unit hasEscapingJumps = true hasJumps = true hasMultipleJumpKinds = false hasMultipleJumpTargets = true jumpExpressions = [ break, break@outer ] returnValueType = null
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Wed May 29 17:43:55 UTC 2024 - 489 bytes - Viewed (0) -
pkg/controller/job/success_policy.go
return successCriteriaMet } } return nil } func isSuccessCriteriaMetCondition(cond *batch.JobCondition) bool { return feature.DefaultFeatureGate.Enabled(features.JobSuccessPolicy) && cond != nil && cond.Type == batch.JobSuccessCriteriaMet && cond.Status == v1.ConditionTrue } func matchSucceededIndexesRule(ruleIndexes, succeededIndexes orderedIntervals, succeededCount *int32) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 3.4K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/rewritePPC64.go
typ := &b.Func.Config.Types // match: (Load <t> ptr mem) // cond: (is64BitInt(t) || isPtr(t)) // result: (MOVDload ptr mem) for { t := v.Type ptr := v_0 mem := v_1 if !(is64BitInt(t) || isPtr(t)) { break } v.reset(OpPPC64MOVDload) v.AddArg2(ptr, mem) return true } // match: (Load <t> ptr mem) // cond: is32BitInt(t) && t.IsSigned() // result: (MOVWload ptr mem)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 19:02:52 UTC 2024 - 360.2K bytes - Viewed (0) -
tensorflow/compiler/mlir/tfrt/tests/tf_to_corert/control_flow.mlir
func.return %1 : tensor<i32> } // CHECK-LABEL: func @cond(%arg0: !tfrt.chain, %arg1: !tfrt_fallback.tf_tensor, %arg2: !tfrt_fallback.tf_tensor) -> (!tfrt.chain, !tfrt_fallback.tf_tensor) func.func @cond(%arg0: tensor<i1>, %arg1: tensor<i32>) -> tensor<i32> { // CHECK: [[cond:%.*]] = tfrt_fallback_async.predicate // CHECK: [[cond_res:%.*]]:2 = tfrt.cond [[cond]]
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue May 14 00:40:32 UTC 2024 - 17.5K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/apiapproval/apiapproval_controller.go
if old != nil && old.Status == cond.Status && old.Reason == cond.Reason && old.Message == cond.Message { // no need to update annotation because we took no action. return nil } // update condition crd := inCustomResourceDefinition.DeepCopy() apihelpers.SetCRDCondition(crd, *cond)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0)