- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 62 for goroutines (0.15 sec)
-
pkg/controller/nodelifecycle/node_lifecycle_controller.go
// This function will // - add nodes which are not ready or not reachable for a long period of time to a rate-limited // queue so that NoExecute taints can be added by the goroutine running the doNoExecuteTaintingPass function, // - update the PodReady condition Pods according to the state of the Node Ready condition. func (nc *Controller) monitorNodeHealth(ctx context.Context) error { start := nc.now()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0) -
src/crypto/tls/handshake_server_test.go
testClientHelloFailure(t, serverConfig, m, "") } // testFatal is a hack to prevent the compiler from complaining that there is a // call to t.Fatal from a non-test goroutine func testFatal(t *testing.T, err error) { t.Helper() t.Fatal(err) } func testClientHelloFailure(t *testing.T, serverConfig *Config, m handshakeMessage, expectedSubStr string) { c, s := localPipe(t)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:25 UTC 2024 - 64.7K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 65K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
errc := make(chan error, 1) var wg sync.WaitGroup wg.Add(1) // We must wait for the waitgroup to exit before we terminate the cache or the server in prior defers. defer wg.Wait() // Call close first, so the goroutine knows to exit. defer close(done) go func() { defer wg.Done() for i := 0; i < 100; i++ { select { case <-done: return default: out := &example.Pod{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0) -
android/guava/src/com/google/common/base/CharMatcher.java
void setBits(BitSet table) { for (int c = Character.MAX_VALUE; c >= Character.MIN_VALUE; c--) { if (matches((char) c)) { table.set(c); } } } // Text processing routines /** * Returns {@code true} if a character sequence contains at least one matching BMP character. * Equivalent to {@code !matchesNoneOf(sequence)}. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Feb 09 15:49:48 UTC 2024 - 53.7K bytes - Viewed (0) -
guava/src/com/google/common/base/CharMatcher.java
void setBits(BitSet table) { for (int c = Character.MAX_VALUE; c >= Character.MIN_VALUE; c--) { if (matches((char) c)) { table.set(c); } } } // Text processing routines /** * Returns {@code true} if a character sequence contains at least one matching BMP character. * Equivalent to {@code !matchesNoneOf(sequence)}. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Feb 09 15:49:48 UTC 2024 - 53.8K bytes - Viewed (0) -
pkg/proxy/iptables/proxier.go
proxier.healthzServer.QueuedUpdate(proxier.ipFamily) } metrics.SyncProxyRulesLastQueuedTimestamp.SetToCurrentTime() proxier.syncRunner.Run() } // SyncLoop runs periodic work. This is expected to run as a goroutine or as the main loop of the app. It does not return. func (proxier *Proxier) SyncLoop() { // Update healthz timestamp at beginning in case Sync() never succeeds. if proxier.healthzServer != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/filesystem_interface.h
/// * `TF_FilesystemPluginInfo` struct: similar to the above structure, but /// collects information about all the file schemes that the plugin provides /// support for, as well as about the plugin's memory handling routines; /// * `TF_SetFilesystemVersionMetadata` function: must be called by plugins in /// their `TF_InitPlugin` to record the versioning information the plugins /// are compiled against. ///
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 27 17:36:54 UTC 2022 - 53.1K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier.go
proxier.healthzServer.QueuedUpdate(proxier.ipFamily) } metrics.SyncProxyRulesLastQueuedTimestamp.SetToCurrentTime() proxier.syncRunner.Run() } // SyncLoop runs periodic work. This is expected to run as a goroutine or as the main loop of the app. It does not return. func (proxier *Proxier) SyncLoop() { // Update healthz timestamp at beginning in case Sync() never succeeds. if proxier.healthzServer != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 77.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
// the following conditions: // 1) in total we create 11 events that has to be processed by the watcher // 2) the size of the channels are set to 10 for the watcher // 3) if the test is cpu-starved and the internal goroutine is not picking // up these events from the channel, after consuming the whole time // budget (defaulted to 100ms) on waiting, we will simply close the watch, // which will cause the test failure
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0)