- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 96 for recordLine (0.47 sec)
-
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) -
platforms/core-runtime/launcher/src/main/java/org/gradle/tooling/internal/provider/continuous/BuildInputHierarchy.java
import org.gradle.internal.file.Stat; import org.gradle.internal.snapshot.CaseSensitivity; import org.gradle.internal.snapshot.VfsRelativePath; import java.io.File; import java.util.function.Supplier; /** * Allows recording and querying the input locations of a build. */ public class BuildInputHierarchy { private volatile ValuedVfsHierarchy<InputDeclaration> root; private final SingleFileTreeElementMatcher matcher;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 4.5K bytes - Viewed (0) -
pkg/apis/storagemigration/types.go
// to migrate. When the .status.conditions indicates the migration is // "Running", users can use this token to check the progress of the // migration. // +optional ContinueToken string // TODO: consider recording the storage version hash when the migration // is created. It can avoid races. } // The names of the group, the version, and the resource. type GroupVersionResource struct { // The name of the group. Group string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 4.1K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/internal/resolve/caching/ImplicitInputsCapturingInstantiator.java
* * Not all services have to be capturing. Only services implementing the * {@link ImplicitInputsProvidingService} interface are declaring the inputs they generate. * * If recording inputs is not required, the {@link #newInstance(Class, Object...)} * method can still be called, in which case it creates a non capturing instance. * */ @NonNullApi
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Nov 17 11:08:22 UTC 2023 - 5.3K bytes - Viewed (0) -
platforms/enterprise/enterprise/src/integTest/groovy/org/gradle/internal/enterprise/AbstractDevelocityInputIgnoringServiceIntegrationTest.groovy
// TODO(mlopatkin) Accessing the value source in the background job should not make it an input, // so the configuration should be loaded from the cache. A naive solution of gating the input // recording will break the other test as only the first value source read is broadcasted to // listeners. configurationCache.assertStateStored() // TODO: replace with .assertStateLoaded() once the above is implemented
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Feb 29 16:27:53 UTC 2024 - 5.7K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/telemetry/counter/counter.go
// conventions. func NewStack(name string, depth int) *StackCounter { return counter.NewStack(name, depth) } // Open prepares telemetry counters for recording to the file system. // // If the telemetry mode is "off", Open is a no-op. Otherwise, it opens the // counter file on disk and starts to mmap telemetry counters to the file.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 15 18:02:34 UTC 2024 - 4.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) -
internal/http/response-recorder.go
LogAllBody bool TimeToFirstByte time.Duration StartTime time.Time // number of bytes written bytesWritten int // number of bytes of response headers written headerBytesWritten int // Internal recording buffer headers bytes.Buffer body bytes.Buffer // Indicate if headers are written in the log headersLogged bool } // Hijack - hijacks the underlying connection
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Dec 02 00:13:19 UTC 2023 - 4.9K 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)