- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for Cond (0.03 sec)
-
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) -
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) -
chainable_api.go
tx = db.getInstance() var whereConds []interface{} for _, cond := range conds { if c, ok := cond.(clause.Interface); ok { tx.Statement.AddClause(c) } else if optimizer, ok := cond.(StatementModifier); ok { optimizer.ModifyStatement(tx.Statement) } else { whereConds = append(whereConds, cond) } } if len(whereConds) > 0 {
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Wed Jun 12 09:47:34 UTC 2024 - 14.5K bytes - Viewed (0) -
pkg/registry/core/pod/storage/eviction_test.go
t.Errorf("expected DisruptionsAllowed to be %d, but got %d", want, got) } cond := apimeta.FindStatusCondition(existingPDB.Status.Conditions, policyv1.DisruptionAllowedCondition) if want, got := tc.expectedReason, cond.Reason; want != got { t.Errorf("expected Reason to be %q, but got %q", want, got) } }) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 09:26:37 UTC 2024 - 40K bytes - Viewed (0) -
internal/grid/connection.go
// connChange will be signaled whenever State has been updated, or at regular intervals. // Holding the lock allows safe reads of State, and guarantees that changes will be detected. connChange *sync.Cond handlers *handlers remote *RemoteClient auth AuthFn clientPingInterval time.Duration connPingInterval time.Duration tlsConfig *tls.Config
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0) -
src/cmd/compile/internal/liveness/plive.go
} // Common case: just flow backwards. if len(v.Args) == 1 || len(v.Args) == 2 && v.Args[0] == v.Args[1] { // Note: 386 lowers Neq32 to (TESTL cond cond), v = v.Args[0] continue } v.Fatalf("write barrier control value has more than one argument: %s", v.LongString()) } // Mark everything after the load unsafe. found := false
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 15:22:22 UTC 2024 - 45.2K bytes - Viewed (0)