- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 131 for getm (0.06 sec)
-
cmd/kubeadm/app/phases/upgrade/staticpods.go
PatchesDir() string // RealManifestPath gets the file path for the component in the "real" static pod manifest directory used by the kubelet RealManifestPath(component string) string // RealManifestDir should point to the static pod manifest directory used by the kubelet RealManifestDir() string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 10:07:41 UTC 2024 - 30.7K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/FeatureSpecificTestSuiteBuilder.java
@SuppressWarnings("unchecked") protected B self() { return (B) this; } // Test Data private @Nullable G subjectGenerator; // Gets run before every test. private Runnable setUp; // Gets run at the conclusion of every test. private Runnable tearDown; @CanIgnoreReturnValue protected B usingGenerator(G subjectGenerator) { this.subjectGenerator = subjectGenerator;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Feb 26 19:46:10 UTC 2024 - 10.2K bytes - Viewed (0) -
platforms/jvm/jacoco/src/main/java/org/gradle/testing/jacoco/plugins/JacocoTaskExtension.java
/** * The types of output that the agent can use for execution data. */ public enum Output { FILE, TCP_SERVER, TCP_CLIENT, NONE; /** * Gets type in format of agent argument. */ public String getAsArg() { return toString().toLowerCase(Locale.US).replaceAll("_", ""); } } private final JacocoAgentJar agent;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 22 14:04:39 UTC 2024 - 10.6K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/parallel_execute_to_islands.cc
execute.getOutputs().end()); for (auto result : llvm::zip(island_op.getOutputs(), parallel_execute_outputs)) std::get<0>(result).replaceAllUsesWith(std::get<1>(result)); // Add sink island to pin all islands as a control dependency if there is a // control dependency leading from the parallel_execute originally. if (!island_op.getControl().use_empty()) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Jan 19 19:47:16 UTC 2023 - 11.1K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/upgrade/common.go
// API Server's version realServerVersion, err := dryRunGetter.Client().Discovery().ServerVersion() if err != nil { return nil, errors.Wrap(err, "failed to get server version") } // Get the fake clientset dryRunOpts := apiclient.GetDefaultDryRunClientOptions(dryRunGetter, os.Stdout) // Print GET and LIST requests dryRunOpts.PrintGETAndLIST = true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 08:34:39 UTC 2024 - 10.1K bytes - Viewed (0) -
pkg/registry/flowcontrol/rest/storage_flowcontrol.go
if err != nil { return fmt.Errorf("failed to initialize clientset for APF - %w", err) } err = func() error { // get a derived context that gets cancelled after 5m or // when the StopCh gets closed, whichever happens first. ctx, cancel := contextFromChannelAndMaxWaitDuration(hookContext.StopCh, 5*time.Minute) defer cancel()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 12.3K bytes - Viewed (0) -
security/pkg/nodeagent/cache/secretcache_test.go
if err == nil { t.Fatalf("expected to get error") } if gotSecret != nil { t.Fatalf("Expected to get nil secret but got %v", gotSecret) } rootResource := "file-root:" + rootCertPath gotSecretRoot, err := sc.GenerateSecret(rootResource) if err == nil { t.Fatalf("Expected to get error, but did not get") } if !strings.Contains(err.Error(), "no such file or directory") {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 23.9K bytes - Viewed (0) -
src/runtime/sema.go
func semacquire(addr *uint32) { semacquire1(addr, false, 0, 0, waitReasonSemacquire) } func semacquire1(addr *uint32, lifo bool, profile semaProfileFlags, skipframes int, reason waitReason) { gp := getg() if gp != gp.m.curg { throw("semacquire not on the G stack") } // Easy case. if cansemacquire(addr) { return } // Harder case: // increment waiter count
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 19K bytes - Viewed (0) -
src/runtime/iface.go
func itabAdd(m *itab) { // Bugs can lead to calling this while mallocing is set, // typically because this is called while panicking. // Crash reliably, rather than only when we need to grow // the hash table. if getg().m.mallocing != 0 { throw("malloc deadlock") } t := itabTable if t.count >= 3*(t.size/4) { // 75% load factor // Grow hash table. // t2 = new(itabTableType) + some additional entries
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 22.5K bytes - Viewed (0) -
src/runtime/netpoll_solaris.go
libc_port_associate, libc_port_dissociate, libc_port_getn, libc_port_alert libcFunc netpollWakeSig atomic.Uint32 // used to avoid duplicate calls of netpollBreak ) func errno() int32 { return *getg().m.perrno } func port_create() int32 { return int32(sysvicall0(&libc_port_create)) } func port_associate(port, source int32, object uintptr, events uint32, user uintptr) int32 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 11.2K bytes - Viewed (0)