- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 30 for Cond (0.05 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) -
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) -
tests/integration/pilot/gateway_test.go
return fmt.Errorf("failed to find gateway") } cond := kstatus.GetCondition(gw.Status.Conditions, string(k8sv1.GatewayConditionProgrammed)) if cond.Status != metav1.ConditionTrue { return fmt.Errorf("failed to find programmed condition: %+v", cond) } if cond.ObservedGeneration != gw.Generation { return fmt.Errorf("stale GWC generation: %+v", cond) } return nil } retry.UntilSuccessOrFail(t, check)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 17.7K bytes - Viewed (0) -
tests/integration/ambient/waypoint_test.go
} cond := kstatus.GetCondition(gwc.Status.Conditions, string(k8s.GatewayClassConditionStatusAccepted)) if cond.Status != metav1.ConditionTrue { return fmt.Errorf("failed to find accepted condition: %+v", cond) } if cond.ObservedGeneration != gwc.Generation { return fmt.Errorf("stale GWC generation: %+v", cond) } return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 11.4K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 15:59:33 UTC 2024 - 16.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go
// observed from a watch. type watchCache struct { sync.RWMutex // Condition on which lists are waiting for the fresh enough // resource version. cond *sync.Cond // Maximum size of history window. capacity int // upper bound of capacity since event cache has a dynamic size. upperBoundCapacity int
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 10:20:57 UTC 2024 - 26.2K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/transforms/legalize_patterns.td
} def LegalizeSelect : Pat<(TF_SelectOp $cond, $x, $y), (TFL_SelectOp $cond, $x, $y)>; def LegalizeSelectV2SameStaticShape : Pat<(TF_SelectV2Op:$src_op $cond, $x, $y), (TFL_SelectOp $cond, $x, $y), [(OpHasSameStaticShapes $src_op)]>; def LegalizeSelectV2NotSameStaticShape : Pat< (TF_SelectV2Op:$src_op $cond, $x, $y), (TFL_SelectV2Op $cond, $x, $y), [(OpHasNotSameStaticShapes $src_op)]>;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Jun 04 13:30:42 UTC 2024 - 28.5K bytes - Viewed (0) -
callbacks/preload.go
column, values := schema.ToQueryValues(clause.CurrentTable, relForeignKeys, foreignValues) if len(values) != 0 { for _, cond := range conds { if fc, ok := cond.(func(*gorm.DB) *gorm.DB); ok { tx = fc(tx) } else { inlineConds = append(inlineConds, cond) } }
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Wed Jun 12 10:52:33 UTC 2024 - 11.6K bytes - Viewed (0) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirExpressionTypeProvider.kt
private fun PsiElement.isWhileLoopCondition() = unwrapQualified<KtWhileExpressionBase> { whileExpr, cond -> whileExpr.condition == cond } != null private fun PsiElement.isIfCondition() = unwrapQualified<KtIfExpression> { ifExpr, cond -> ifExpr.condition == cond } != null override fun isDefinitelyNull(expression: KtExpression): Boolean =
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Tue Jun 11 15:45:42 UTC 2024 - 24.4K bytes - Viewed (0)