Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 1,895 for late (0.04 sec)

  1. pilot/pkg/serviceregistry/aggregate/controller_test.go

    		ctrl.DeleteRegistry("missed", "test")
    		expectRunningOrFail(t, ctrl, true)
    	})
    	t.Run("AddRegistryAndRun after aggregate Run starts registry", func(t *testing.T) {
    		ctrl.AddRegistryAndRun(runnableRegistry("late"), stop)
    		expectRunningOrFail(t, ctrl, true)
    	})
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 06:28:11 UTC 2024
    - 14.5K bytes
    - Viewed (0)
  2. platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/DefaultConfigurationCache.kt

        override fun initializeCacheEntry() {
            cacheAction = determineCacheAction()
            problems.action(cacheAction)
            // TODO:isolated find a way to avoid this late binding
            modelSideEffectExecutor.sideEffectStore = buildTreeModelSideEffects
        }
    
        override fun attachRootBuild(host: Host) {
            this.host = host
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sat Jun 08 11:29:30 UTC 2024
    - 24.3K bytes
    - Viewed (0)
  3. src/net/http/serve_test.go

    	c := ts.Client()
    
    	var wg sync.WaitGroup
    	gate := make(chan bool, 10)
    	n := 50
    	if testing.Short() {
    		n = 10
    		gate = make(chan bool, 3)
    	}
    	for i := 0; i < n; i++ {
    		gate <- true
    		wg.Add(1)
    		go func() {
    			defer wg.Done()
    			defer func() { <-gate }()
    			res, err := c.Get(fmt.Sprintf("%s/%d", ts.URL, rand.Intn(50)))
    			if err == nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 17:57:01 UTC 2024
    - 202K bytes
    - Viewed (0)
  4. src/cmd/compile/internal/ssa/_gen/dec64.rules

    (Store {t} dst (Int64Make hi lo) mem) && t.Size() == 8 && config.BigEndian =>
    	(Store {lo.Type}
    		(OffPtr <lo.Type.PtrTo()> [4] dst)
    		lo
    		(Store {hi.Type} dst hi mem))
    
    // These are not enabled during decomposeBuiltin if late call expansion, but they are always enabled for softFloat
    (Arg {n} [off]) && is64BitInt(v.Type) && !config.BigEndian && v.Type.IsSigned() && !(b.Func.pass.name == "decompose builtin") =>
      (Int64Make
        (Arg <typ.Int32> {n} [off+4])
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Oct 04 19:35:46 UTC 2022
    - 14.2K bytes
    - Viewed (0)
  5. pilot/pkg/serviceregistry/kube/controller/ambient/workloads.go

    	// NodeName is set by the scheduler after the pod is created
    	// https://github.com/kubernetes/community/blob/master/contributors/devel/sig-architecture/api-conventions.md#late-initialization
    	node := ptr.Flatten(krt.FetchOne(ctx, Nodes, krt.FilterKey(pod.Spec.NodeName)))
    	if node == nil {
    		if pod.Spec.NodeName != "" {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 16:51:29 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  6. operator/pkg/object/objects.go

    			return 1000
    
    			// Autoscalers typically act on a deployment
    		case gk == "autoscaling/HorizontalPodAutoscaler":
    			return 1001
    
    			// Create services late - after pods have been started
    		case gk == "/Service":
    			return 10000
    
    		default:
    			return 1000
    		}
    	}
    }
    
    func ObjectsNotInLists(objects K8sObjects, lists ...K8sObjects) K8sObjects {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Sep 21 07:16:46 UTC 2023
    - 15.5K bytes
    - Viewed (1)
  7. src/cmd/compile/internal/dwarfgen/dwinl.go

    		if c.Root {
    			checkInlCall(fnsym.Name, inlcalls, fnsym.Size, k, -1)
    		}
    	}
    
    	return inlcalls
    }
    
    // Secondary hook for DWARF inlined subroutine generation. This is called
    // late in the compilation when it is determined that we need an
    // abstract function DIE for an inlined routine imported from a
    // previously compiled package.
    func AbstractFunc(fn *obj.LSym) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Feb 26 20:45:07 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  8. src/cmd/internal/obj/sym.go

    		// TODO: Find a better place and optimize to only sort TOC symbols.
    		sort.SliceStable(ctxt.Data, func(i, j int) bool {
    			return ctxt.Data[i].Name < ctxt.Data[j].Name
    		})
    	}
    
    	// Constant symbols are created late in the concurrent phase. Sort them
    	// to ensure a deterministic order.
    	sort.Slice(ctxt.constSyms, func(i, j int) bool {
    		return ctxt.constSyms[i].Name < ctxt.constSyms[j].Name
    	})
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 14:41:10 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  9. src/cmd/compile/internal/ssa/schedule.go

    		return x.Pos.Before(y.Pos)
    	}
    	if x.Op != OpPhi {
    		if c := len(x.Args) - len(y.Args); c != 0 {
    			return c > 0 // smaller args come later
    		}
    	}
    	if c := x.Uses - y.Uses; c != 0 {
    		return c > 0 // smaller uses come later
    	}
    	// These comparisons are fairly arbitrary.
    	// The goal here is stability in the face
    	// of unrelated changes elsewhere in the compiler.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 08 15:53:17 UTC 2024
    - 16.4K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

        assertTrue(elapsedMillis < timelimitMillis);
      }
    
      /**
       * Await an interrupt, then clear the interrupt status. Similar to {@code
       * assertTrue(Thread.interrupted())} except that this version tolerates late interrupts.
       */
      private static void assertInterrupted() {
        try {
          /*
           * The sleep() will end immediately if we've already been interrupted or
           * wait patiently for the interrupt if not.
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Jun 10 16:06:39 UTC 2024
    - 31.7K bytes
    - Viewed (0)
Back to top