Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 31 for pusha (2.99 sec)

  1. pilot/pkg/networking/core/cluster_tls_test.go

    		Type:         model.SidecarProxy,
    		Metadata:     &model.NodeMetadata{},
    		IstioVersion: &model.IstioVersion{Major: 1, Minor: 5},
    	}
    	push := model.NewPushContext()
    	for _, test := range tests {
    		t.Run(test.name, func(t *testing.T) {
    			cb := NewClusterBuilder(proxy, &model.PushRequest{Push: push}, model.DisabledCache{})
    			opts := &buildClusterOpts{
    				mutable: newClusterWrapper(&cluster.Cluster{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 03:53:05 UTC 2024
    - 60.9K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/HttpUrl.kt

            val segmentHasTrailingSlash = pathSegmentDelimiterOffset < limit
            push(input, i, pathSegmentDelimiterOffset, segmentHasTrailingSlash, true)
            i = pathSegmentDelimiterOffset
            if (segmentHasTrailingSlash) i++
          }
        }
    
        /** Adds a path segment. If the input is ".." or equivalent, this pops a path segment. */
        private fun push(
          input: String,
          pos: Int,
          limit: Int,
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Tue Jan 09 12:33:05 UTC 2024
    - 63.5K bytes
    - Viewed (0)
  3. src/runtime/mgcpacer.go

    		extHeapGoal := int64(float64(heapGoal-int64(c.triggered))/float64(scanWorkExpected)*float64(maxScanWork)) + int64(c.triggered)
    		scanWorkExpected = maxScanWork
    
    		// hardGoal is a hard limit on the amount that we're willing to push back the
    		// heap goal, and that's twice the heap goal (i.e. if GOGC=100 and the heap and/or
    		// stacks and/or globals grow to twice their size, this limits the current GC cycle's
    		// growth to 4x the original live heap's size).
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 55.4K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/httproute_test.go

    				Configs:  tt.config,
    			})
    
    			vHostCache := make(map[int][]*route.VirtualHost)
    			resource, _ := cg.ConfigGen.buildSidecarOutboundHTTPRouteConfig(
    				cg.SetupProxy(nil), &model.PushRequest{Push: cg.PushContext()}, "80", vHostCache, nil, nil)
    			routeCfg := &route.RouteConfiguration{}
    			resource.Resource.UnmarshalTo(routeCfg)
    			xdstest.ValidateRouteConfiguration(t, routeCfg)
    
    			got := map[string][]string{}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 51.4K bytes
    - Viewed (0)
  5. src/cmd/link/internal/loader/loader.go

    			// symbol definitions, so we don't yet know all the push linknames. So we add to a
    			// list and check later after all symbol defs are loaded. Linknamed vars are rare,
    			// so this list won't be long.
    			// Only check references (pull), not definitions (push, with non-zero size),
    			// so push is always allowed.
    			// This use of linkname is usually for referencing C symbols, so allow symbols
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 20:26:10 UTC 2024
    - 81.5K bytes
    - Viewed (0)
  6. platforms/core-configuration/model-core/src/main/java/org/gradle/model/internal/manage/schema/extract/ManagedProxyClassGenerator.java

            methodVisitor.visitVarInsn(ALOAD, 1); // put var #1 ('foo') on the stack
            methodVisitor.visitLdcInsn(boxedType); // push the constant Class onto the stack
            methodVisitor.visitInsn(propertyClass.isPrimitive() ? ICONST_1 : ICONST_0); // push int 1 or 0 (interpreted as true or false) onto the stack
            Label startTry = new Label();
            methodVisitor.visitLabel(startTry);
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Dec 11 13:37:56 UTC 2023
    - 55.3K bytes
    - Viewed (0)
  7. pilot/pkg/serviceregistry/kube/controller/controller_test.go

    	// create vs1 in nsB
    	createVirtualService(controller, "vs2", nsB, map[string]string{}, t)
    
    	// expand namespaces to nsA and nsB with selectors (expect events svc3 and a full push event for nsB selected)
    	updateMeshConfig(
    		&meshconfig.MeshConfig{
    			DiscoverySelectors: []*meshconfig.LabelSelector{
    				{
    					MatchExpressions: []*meshconfig.LabelSelectorRequirement{
    						{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 85K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

          // afterDone() should be generally fast and only used for cleanup work... but in theory can
          // also be recursive and create StackOverflowErrors
          future.afterDone();
          // push the current set of listeners onto next
          next = future.clearListeners(next);
          future = null;
          while (next != null) {
            Listener curr = next;
            next = next.next;
            /*
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 63.1K bytes
    - Viewed (1)
  9. guava/src/com/google/common/util/concurrent/AbstractFuture.java

          // afterDone() should be generally fast and only used for cleanup work... but in theory can
          // also be recursive and create StackOverflowErrors
          future.afterDone();
          // push the current set of listeners onto next
          next = future.clearListeners(next);
          future = null;
          while (next != null) {
            Listener curr = next;
            next = next.next;
            /*
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 62.8K bytes
    - Viewed (1)
  10. okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

                  override fun contentLength(): Long = postBytes.size.toLong()
    
                  override fun writeTo(sink: BufferedSink) {
                    sink.write(postBytes) // push bytes into the stream's buffer
                    sink.flush() // Http2Connection.writeData subject to write window
                    sink.close() // Http2Connection.writeData empty frame
                  }
                },
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 75.3K bytes
    - Viewed (0)
Back to top