Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 19 of 19 for getg (0.06 sec)

  1. pkg/controller/statefulset/stateful_set_control_test.go

    		totalPods int,
    		selector labels.Selector,
    	) []*v1.Pod {
    		// only one pod gets created at a time due to OrderedReady
    		if len(pods) != 5 {
    			t.Fatalf("Expected create pods 5, got pods %v", len(pods))
    		}
    		spc.setPodRunning(set, 4)
    		pods, _ = spc.setPodReady(set, 4)
    
    		// create new pods 4(only one pod gets created at a time due to OrderedReady)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 07 19:01:47 UTC 2024
    - 108.7K bytes
    - Viewed (0)
  2. tensorflow/compiler/mlir/tensorflow/transforms/shape_inference.cc

      for (auto it : llvm::zip(op.getResults(), then_results, else_results)) {
        // If then and else types do not match, skip refinement for that result.
        if (std::get<1>(it) != std::get<2>(it)) continue;
        changed = RefineResultType(op, std::get<0>(it), std::get<1>(it)) || changed;
      }
      return changed;
    }
    
    bool ShapeInference::InferShapeForIfRegion(IfRegionOp op) {
      bool changed = false;
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Sat Jun 08 07:28:49 UTC 2024
    - 134.1K bytes
    - Viewed (0)
  3. tensorflow/compiler/mlir/lite/transforms/optimize.cc

          // Get the sign-extended value (=>int64) if the type is signed.
          float_val = apint_val.getSExtValue();
        } else {
          // Get the zero-extended value (=>uint64) if unsigned or signless.
          float_val = apint_val.getZExtValue();
        }
      }
      return DenseFPElementsAttr::get(
          RankedTensorType::get({}, builder.getF32Type()),
          {llvm::APFloat(float_val)});
    }
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue Apr 30 00:40:15 UTC 2024
    - 102.3K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_test.go

    				destroyCount = destroyCount + 1
    			}
    		}
    		return destroyCount >= 1, nil
    	})
    
    	assert.NoError(t, err, "wait should not return error")
    	// housekeeping can get called multiple times. The cgroup Destroy() is
    	// done within a goroutine and can get called multiple times, so the
    	// Destroy() count in not deterministic on the actual number.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  5. src/net/http/transport_test.go

    	req, _ := NewRequest("GET", "http://foo.com/", nil)
    	req.Method = ""                                 // docs say "For client requests an empty string means GET"
    	got, err := httputil.DumpRequestOut(req, false) // DumpRequestOut uses Transport
    	if err != nil {
    		t.Fatal(err)
    	}
    	if !strings.Contains(string(got), "GET ") {
    		t.Fatalf("expected substring 'GET '; got: %s", got)
    	}
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 21:59:21 UTC 2024
    - 192.6K bytes
    - Viewed (0)
  6. src/cmd/link/internal/ld/data.go

    	}
    	data[len(prefix)+1] |= 2 // signals new pointer-free format
    	data = appendString(data, strdata["runtime.buildVersion"])
    	data = appendString(data, strdata["runtime.modinfo"])
    	// MacOS linker gets very upset if the size os not a multiple of alignment.
    	for len(data)%16 != 0 {
    		data = append(data, 0)
    	}
    	s.SetData(data)
    	s.SetSize(int64(len(data)))
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jun 12 15:10:50 UTC 2024
    - 100.5K bytes
    - Viewed (0)
  7. pkg/kubelet/kubelet_pods_test.go

    			}
    
    			testKubelet.fakeKubeClient.AddReactor("get", "configmaps", func(action core.Action) (bool, runtime.Object, error) {
    				var err error
    				if tc.configMap == nil {
    					err = apierrors.NewNotFound(action.GetResource().GroupResource(), "configmap-name")
    				}
    				return true, tc.configMap, err
    			})
    			testKubelet.fakeKubeClient.AddReactor("get", "secrets", func(action core.Action) (bool, runtime.Object, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
  8. pkg/printers/internalversion/printers_test.go

    			expected: []metav1.TableRow{{Cells: []interface{}{"service3", "LoadBalancer", "1.4.5.6", "2.3.4.5", "80/TCP,8090/UDP,8000/TCP", "<unknown>"}}},
    		},
    		// Long external IP's list gets elided.
    		{
    			service: api.Service{
    				ObjectMeta: metav1.ObjectMeta{Name: "service4"},
    				Spec: api.ServiceSpec{
    					ClusterIPs: []string{"1.5.6.7"},
    					Type:       "LoadBalancer",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 218.6K bytes
    - Viewed (0)
  9. pkg/controller/job/job_controller_test.go

    	key, done = jm.queue.Get()
    	if key == "" || done {
    		t.Fatalf("failed to enqueue controller for pod %v", pod2.Name)
    	}
    	expectedKey, _ = controller.KeyFunc(job2)
    	if got, want := key, expectedKey; got != want {
    		t.Errorf("queue.Get() = %v, want %v", got, want)
    	}
    }
    
    func TestDeletePodOrphan(t *testing.T) {
    	// Disable batching of pod updates to show it does not get requeued at all
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
Back to top