- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,769 for Forever (0.18 sec)
-
pilot/pkg/xds/rds_test.go
}, { // Even if we get a bad route, we should still send Envoy an empty response, rather than // ignore it. If we ignore the route, the listeners can get stuck waiting forever. "sidecar_badroute", sidecarID(app3Ip, "app3"), []string{"ht&p"}, }, } s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{}) for _, tt := range tests { t.Run(tt.name, func(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 2.1K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/repositories/metadata/GradleModuleMetadataCompatibilityConverter.java
// This code path will always be a no-op following the changes in DefaultImmutableAttributesFactory // However this code will have to remain forever while the other one should be removed at some point (Gradle 7.0?) for (MutableComponentVariant variant : metaDataFromResource.getMutableVariants()) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 5.3K bytes - Viewed (0) -
src/cmd/go/testdata/script/test_timeout_stdin.txt
# Regression test for https://go.dev/issue/24050: # a test that exits with an I/O stream held open # should fail after a reasonable delay, not wait forever. # (As of the time of writing, that delay is 10% of the timeout, # but this test does not depend on its specific value.) [short] skip 'runs a test that hangs until its WaitDelay expires' ! go test -v -timeout=1m . # After the test process itself prints PASS and exits,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 02 20:23:27 UTC 2023 - 2.2K bytes - Viewed (0) -
src/runtime/tracetype.go
type traceTypeTable struct { tab traceMap } // put returns a unique id for the type typ and caches it in the table, // if it's seeing it for the first time. // // N.B. typ must be kept alive forever for this to work correctly. func (t *traceTypeTable) put(typ *abi.Type) uint64 { if typ == nil { return 0 } // Insert the pointer to the type itself.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 20:31:27 UTC 2024 - 2.3K bytes - Viewed (0) -
pkg/kubelet/winstats/perfcounter_nodestats.go
networkAdapterCounter, err := newNetworkCounters() if err != nil { return err } go wait.Forever(func() { p.collectMetricsData(cpuCounter, memWorkingSetCounter, memCommittedBytesCounter, networkAdapterCounter) }, perfCounterUpdatePeriod) // Cache the CPU usage every defaultCachePeriod go wait.Forever(func() { newValue := p.nodeMetrics.cpuUsageCoreNanoSeconds p.mu.Lock() defer p.mu.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 26 18:37:21 UTC 2024 - 9.2K bytes - Viewed (0) -
src/main/java/jcifs/netbios/NameServiceClientImpl.java
this.unknownAddress = new NbtAddress(this.unknownName, 0, false, NbtAddress.B_NODE); this.addressCache.put(this.unknownName, new CacheEntry(this.unknownName, this.unknownAddress, SmbConstants.FOREVER)); /* * Determine the InetAddress of the local interface * if one was not specified. */ InetAddress localInetAddress = tc.getConfig().getNetbiosLocalAddress();
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Aug 14 14:26:22 UTC 2022 - 38.2K bytes - Viewed (0) -
platforms/jvm/plugins-application/src/integTest/groovy/org/gradle/internal/deployment/JavaApplicationDeploymentIntegrationTest.groovy
for (String arg : args) { writer.println(Message.message + " > " + arg); } writer.close(); // wait forever new File(args[1]).createNewFile(); new CountDownLatch(1).await(10, TimeUnit.MINUTES); } } """
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 08 04:59:12 UTC 2024 - 4K bytes - Viewed (0) -
internal/lock/lock_nix.go
} // TryLockedOpenFile - tries a new write lock, functionality // it is similar to LockedOpenFile with with syscall.LOCK_EX // mode but along with syscall.LOCK_NB such that the function // doesn't wait forever but instead returns if it cannot // acquire a write lock. func TryLockedOpenFile(path string, flag int, perm os.FileMode) (*LockedFile, error) { return lockedOpenFile(path, flag, perm, syscall.LOCK_NB) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Aug 19 01:35:22 UTC 2021 - 2.8K bytes - Viewed (0) -
tensorflow/compiler/jit/device_compilation_profiler.h
// True if we have decided that this cluster is too dynamic (i.e. its shapes // change too frequently) to profitably JIT compile. Once a cluster is // tagged megamorphic, it stays megamorphic forever. bool is_megamorphic = false; std::string DebugString() const { return absl::StrCat( "DeviceCompilationProfiler::ClusterCompileStats {compile_count=",
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 22 06:59:07 UTC 2024 - 3.9K bytes - Viewed (0) -
pkg/util/coverage/coverage.go
} } // Set up the unit test framework with the required arguments to activate test coverage. flag.CommandLine.Parse([]string{"-test.coverprofile", tempCoveragePath()}) // Begin periodic logging go wait.Forever(FlushCoverage, flushInterval) } // FlushCoverage flushes collected coverage information to disk. // The destination file is configured at startup and cannot be changed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 05 21:00:21 UTC 2022 - 3.2K bytes - Viewed (0)