- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 56 for timesTU (0.32 sec)
-
tests/integration/telemetry/api/dashboard_test.go
// Spread out over 20s so rate() queries will behave correctly ticker := time.NewTicker(time.Second) times := 0 for { select { case <-ticker.C: times++ scopes.Framework.Infof("sending traffic %v", times) for _, ing := range ingr { hosts, ports := ing.TCPAddresses() host := hosts[0] port := ports[0] _, err := ing.Call(echo.CallOptions{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 20:46:28 UTC 2024 - 11.4K bytes - Viewed (0) -
cmd/erasure-healing-common.go
} // commonTime returns a maximally occurring time from a list of time. func commonTimeAndOccurrence(times []time.Time, group time.Duration) (maxTime time.Time, maxima int) { timeOccurrenceMap := make(map[int64]int, len(times)) groupNano := group.Nanoseconds() // Ignore the uuid sentinel and count the rest. for _, t := range times { if t.Equal(timeSentinel) || t.IsZero() { continue } nano := t.UnixNano() if group > 0 {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 12.5K bytes - Viewed (0) -
platforms/core-runtime/instrumentation-agent-services/src/main/java/org/gradle/internal/instrumentation/agent/DefaultClassFileTransformer.java
instrumentingLoader.transformFailed(className, th); return null; } } public static boolean tryInstall() { // Installing the same transformer multiple times is very problematic, so additional correctness check is worth it. if (!INSTALLED.compareAndSet(false, true)) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 2.4K bytes - Viewed (0) -
pilot/pkg/features/telemetry.go
EnableControllerQueueMetrics = env.Register("ISTIO_ENABLE_CONTROLLER_QUEUE_METRICS", false, "If enabled, publishes metrics for queue depth, latency and processing times.").Get()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 14:36:01 UTC 2024 - 2.3K bytes - Viewed (0) -
pkg/config/validation/virtualservice.go
} if current != "" { return fmt.Errorf("authority header cannot be set multiple times: have %q, attempting to set %q", current, v) } current = v } for k, v := range headers.GetRequest().GetAdd() { if !isAuthorityHeader(k) { continue } if current != "" { return fmt.Errorf("authority header cannot be set multiple times: have %q, attempting to set %q", current, v) } current = v } return nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 04:03:27 UTC 2024 - 9.3K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/cache/internal/DefaultGeneratedGradleJarCacheIntegrationTest.groovy
def triggeredJarFileGeneration = new AtomicInteger() def jarFiles = Collections.synchronizedList(new ArrayList<File>()) when: jarGenerationInvocations.times { concurrent.start { def jarFile = defaultGeneratedGradleJarCache.get(CACHE_IDENTIFIER, new Action<File>() { @Override void execute(File file) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 5K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/execution/scope/internal/MojoExecutionScope.java
provided.afterExecutionFailure(event); } } private Collection<WeakMojoExecutionListener> getProvidedListeners() { // the same instance can be provided multiple times under different Key's // deduplicate instances to avoid redundant beforeXXX/afterXXX callbacks IdentityHashMap<WeakMojoExecutionListener, Object> listeners = new IdentityHashMap<>();
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 07:23:04 UTC 2024 - 5.7K bytes - Viewed (0) -
src/os/exec_windows.go
} func (p *Process) release() error { // Drop the Process' reference and mark handle unusable for // future calls. // // The API on Windows expects EINVAL if Release is called multiple // times. if old := p.handlePersistentRelease(statusReleased); old == statusReleased { return syscall.EINVAL } // no need for a finalizer anymore runtime.SetFinalizer(p, nil) return nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 22:06:47 UTC 2024 - 5K bytes - Viewed (0) -
cmd/erasure-healing-common_test.go
// time occurrence from a list of time. func TestCommonTime(t *testing.T) { // List of test cases for common modTime. testCases := []struct { times []time.Time time time.Time quorum int }{ { // 1. Tests common times when slice has varying time elements. []time.Time{ time.Unix(0, 1).UTC(), time.Unix(0, 2).UTC(), time.Unix(0, 3).UTC(), time.Unix(0, 3).UTC(),
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 23K bytes - Viewed (0) -
configure.py
n_ask_attempts: (Integer) Number of times to query for valid input before raising an error and quitting. Returns: [String] The value of var_name after querying for input. Raises: UserInputError: if a query has been attempted n_ask_attempts times without success, assume that the user has made a scripting error, and will
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Jun 10 04:32:44 UTC 2024 - 53.8K bytes - Viewed (1)