Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 91 for curg (0.04 sec)

  1. cluster/gce/gci/configure.sh

        # shellcheck disable=SC2086
        retry-forever 10 curl ${CURL_FLAGS} \
          -H "X-Google-Metadata-Request: True" \
          -o "${tmp_kubelet_config}" \
          http://metadata.google.internal/computeMetadata/v1/instance/attributes/kubelet-config
        # only write to the final location if curl succeeds
        mv "${tmp_kubelet_config}" "${dest}"
      )
    }
    
    function download-kube-master-certs {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 04:14:02 UTC 2024
    - 36.5K bytes
    - Viewed (0)
  2. pkg/controller/daemon/update.go

    		// Create a new history if the current one isn't found
    		cur, err = dsc.snapshot(ctx, ds, currRevision)
    		if err != nil {
    			return nil, nil, err
    		}
    	default:
    		cur, err = dsc.dedupCurHistories(ctx, ds, currentHistories)
    		if err != nil {
    			return nil, nil, err
    		}
    		// Update revision number if necessary
    		if cur.Revision < currRevision {
    			toUpdate := cur.DeepCopy()
    			toUpdate.Revision = currRevision
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 13 16:53:53 UTC 2024
    - 24.4K bytes
    - Viewed (0)
  3. src/syscall/rlimit.go

    // which Go of course has no choice but to respect.
    func init() {
    	var lim Rlimit
    	if err := Getrlimit(RLIMIT_NOFILE, &lim); err == nil && lim.Cur != lim.Max {
    		origRlimitNofile.Store(&lim)
    		nlim := lim
    		nlim.Cur = nlim.Max
    		adjustFileLimit(&nlim)
    		setrlimit(RLIMIT_NOFILE, &nlim)
    	}
    }
    
    func Setrlimit(resource int, rlim *Rlimit) error {
    	if resource == RLIMIT_NOFILE {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 20:13:57 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        SettableFuture<String> orig = SettableFuture.create();
        SettableFuture<String> prev = orig;
        for (int i = 0; i < 100000; i++) {
          SettableFuture<String> curr = SettableFuture.create();
          prev.setFuture(curr);
          prev = curr;
        }
        // prev represents the 'innermost' future
        prev.set("done");
        assertTrue(orig.isDone());
      }
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        SettableFuture<String> orig = SettableFuture.create();
        SettableFuture<String> prev = orig;
        for (int i = 0; i < 100000; i++) {
          SettableFuture<String> curr = SettableFuture.create();
          prev.setFuture(curr);
          prev = curr;
        }
        // prev represents the 'innermost' future
        prev.set("done");
        assertTrue(orig.isDone());
      }
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  6. pilot/pkg/bootstrap/server.go

    		configHandler := func(prev config.Config, curr config.Config, event model.Event) {
    			if s.statusReporter != nil {
    				defer func() {
    					if event != model.EventDelete {
    						s.statusReporter.AddInProgressResource(curr)
    					} else {
    						s.statusReporter.DeleteInProgressResource(curr)
    					}
    				}()
    			}
    			log.Debugf("Handle event %s for configuration %s", event, curr.Key())
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 17:48:28 UTC 2024
    - 46.3K bytes
    - Viewed (0)
  7. hack/lib/etcd.sh

      ETCD_PID=$!
    
      echo "Waiting for etcd to come up."
      kube::util::wait_for_url "${KUBE_INTEGRATION_ETCD_URL}/health" "etcd: " 0.25 80
      curl -fs -X POST "${KUBE_INTEGRATION_ETCD_URL}/v3/kv/put" -d '{"key": "X3Rlc3Q=", "value": ""}'
    }
    
    kube::etcd::start_scraping() {
      if [[ -d "${ARTIFACTS:-}" ]]; then
        ETCD_SCRAPE_DIR="${ARTIFACTS}/etcd-scrapes"
      else
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 01 03:36:35 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  8. hack/update-kustomize.sh

    set -o pipefail
    
    KUBE_ROOT=$(dirname "${BASH_SOURCE[0]}")/..
    source "${KUBE_ROOT}/hack/lib/init.sh"
    
    kube::golang::setup_env
    kube::util::require-jq
    kube::util::ensure_clean_working_dir
    
    PUBLISHED_RELEASES=$(curl -sL 'http://api.github.com/repos/kubernetes-sigs/kustomize/releases?per_page=100' | jq '[ .[] | select(.draft == false and .prerelease == false) | { "tag_name": .tag_name, "published_at": .published_at } ]')
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:40:04 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  9. cluster/gce/upgrade.sh

      local release_stable
      local release_latest
      local ci_latest
    
      release_stable=$(curl -sL https://dl.k8s.io/release/stable.txt)
      release_latest=$(curl -sL https://dl.k8s.io/release/latest.txt)
      ci_latest=$(curl -sL https://dl.k8s.io/ci/latest.txt)
    
      echo "Right now, versions are as follows:"
      echo "  release/stable: ${0} ${release_stable}"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 21:13:22 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

        while (true) {
          Waiter pred = null;
          Waiter curr = waiters;
          if (curr == Waiter.TOMBSTONE) {
            return; // give up if someone is calling complete
          }
          Waiter succ;
          while (curr != null) {
            succ = curr.next;
            if (curr.thread != null) { // we aren't unlinking this node, update pred.
              pred = curr;
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 63.1K bytes
    - Viewed (1)
Back to top