- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 51 for recordLine (0.44 sec)
-
staging/src/k8s.io/cli-runtime/pkg/genericclioptions/record_flags.go
const ChangeCauseAnnotation = "kubernetes.io/change-cause" // RecordFlags contains all flags associated with the "--record" operation type RecordFlags struct { // Record indicates the state of the recording flag. It is a pointer so a caller can opt out or rebind Record *bool changeCause string } // ToRecorder returns a ChangeCause recorder if --record=false was not // explicitly given by the user
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 5.5K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/InputTrackingState.kt
import kotlin.reflect.KProperty /** * Maintains the current state of the build configuration input tracking. * Input tracking may be disabled for a particular thread to avoid recording inputs that doesn't * directly affect the configuration. * For example, accessing environment variable inside the `ValueSource` being obtained at
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 2.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
* AssertionFailedError thrown, so that the current testcase will fail. */ public void threadAssertFalse(boolean b) { try { assertFalse(b); } catch (AssertionFailedError t) { threadRecordFailure(t); throw t; } } /** * Just like assertNull(x), but additionally recording (using threadRecordFailure) any
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 37.7K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/ConfigurationCacheClassLoaderScopeRegistryListener.kt
private val loaders = mutableMapOf<ClassLoader, Pair<ClassLoaderScopeSpec, ClassLoaderRole>>() override fun afterStart() { listenerManager.add(this) } /** * Stops recording [ClassLoaderScopeSpec]s and releases any recorded state. */ fun dispose() { synchronized(lock) { // TODO:configuration-cache find a way to make `dispose` unnecessary;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:30 UTC 2024 - 4.7K bytes - Viewed (0) -
src/runtime/lockrank_on.go
if l == &debuglock || l == &paniclk || l == &raceFiniLock { // debuglock is only used for println/printlock(). Don't do lock // rank recording for it, since print/println are used when // printing out a lock ordering problem below. // // paniclk is only used for fatal throw/panic. Don't do lock // ranking recording for it, since we throw after reporting a // lock ordering problem. Additionally, paniclk may be taken
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 14:29:04 UTC 2024 - 10.6K bytes - Viewed (0) -
src/internal/trace/parser.go
FakeP = 1000000 + iota TimerP // depicts timer unblocks NetpollP // depicts network unblocks SyscallP // depicts returns from syscalls GCP // depicts GC state ProfileP // depicts recording of CPU profile samples ) // Event types in the trace. // Verbatim copy from src/runtime/trace.go with the "trace" prefix removed. const ( EvNone = 0 // unused
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:31:04 UTC 2024 - 4.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go
if w.isCacheFullLocked() && eventTime.Sub(w.cache[w.startIndex%w.capacity].RecordTime) < eventFreshDuration { capacity := min(w.capacity*2, w.upperBoundCapacity) if capacity > w.capacity { w.doCacheResizeLocked(capacity) } return } if w.isCacheFullLocked() && eventTime.Sub(w.cache[(w.endIndex-w.capacity/4)%w.capacity].RecordTime) > eventFreshDuration { capacity := max(w.capacity/2, w.lowerBoundCapacity)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 10:20:57 UTC 2024 - 26.2K bytes - Viewed (0) -
src/cmd/go/internal/help/help.go
n += n0 if err != nil { return n, err } if b == '\n' { c.wroteSlashes = false } } return len(p), nil } // An errWriter wraps a writer, recording whether a write error occurred. type errWriter struct { w io.Writer err error } func (w *errWriter) Write(b []byte) (int, error) { n, err := w.w.Write(b) if err != nil { w.err = err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 18:15:22 UTC 2024 - 4.7K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
} func (c *connMgr) addConn(conn *ZtunnelConnection) { log.Debug("ztunnel connected") c.mu.Lock() defer c.mu.Unlock() c.connectionSet[conn] = struct{}{} c.latestConn = conn ztunnelConnected.RecordInt(int64(len(c.connectionSet))) } func (c *connMgr) LatestConn() *ZtunnelConnection { c.mu.Lock() defer c.mu.Unlock() return c.latestConn } func (c *connMgr) deleteConn(conn *ZtunnelConnection) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 22:07:03 UTC 2024 - 12.3K bytes - Viewed (0) -
pilot/pkg/xds/monitoring.go
} func recordPushTriggers(reasons model.ReasonStats) { for r, cnt := range reasons { t, f := triggerMetric[r] if f { t.RecordInt(int64(cnt)) } else { pushTriggers.With(typeTag.Value(string(r))).Increment() } } } func isUnexpectedError(err error) bool { s, ok := status.FromError(err)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 6.7K bytes - Viewed (0)