Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 191 for Handles (0.19 sec)

  1. src/unique/handle_bench_test.go

    }
    
    func BenchmarkMakeManyMany(b *testing.B) {
    	benchmarkMake(b, testDataLarge[:])
    }
    
    func benchmarkMake(b *testing.B, testData []string) {
    	handles := make([]Handle[string], 0, len(testData))
    	for i := range testData {
    		handles = append(handles, Make(testData[i]))
    	}
    
    	b.ReportAllocs()
    	b.ResetTimer()
    
    	b.RunParallel(func(pb *testing.PB) {
    		i := 0
    		for pb.Next() {
    			_ = Make(testData[i])
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 22 18:14:07 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  2. src/unique/handle.go

    	"internal/weak"
    	"runtime"
    	"sync"
    	_ "unsafe"
    )
    
    // Handle is a globally unique identity for some value of type T.
    //
    // Two handles compare equal exactly if the two values used to create the handles
    // would have also compared equal. The comparison of two handles is trivial and
    // typically much more efficient than comparing the values used to create them.
    type Handle[T comparable] struct {
    	value *T
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 16:01:55 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  3. pkg/proxy/node.go

    		klog.FlushAndExit(klog.ExitFlushTimeout, 1)
    	}
    }
    
    // OnNodeDelete is a handler for Node deletes.
    func (n *NodePodCIDRHandler) OnNodeDelete(node *v1.Node) {
    	n.logger.Error(nil, "Current Node is being deleted", "node", klog.KObj(node))
    }
    
    // OnNodeSynced is a handler for Node syncs.
    func (n *NodePodCIDRHandler) OnNodeSynced() {}
    
    // NodeEligibleHandler handles the life cycle of the Node's eligibility, as
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  4. platforms/jvm/plugins-java/src/integTest/groovy/org/gradle/java/compile/daemon/DaemonJavaCompilerIntegrationTest.groovy

                        }
                    }
                }
            """
    
            expect:
            succeeds "compileJava"
        }
    
        def "handles -sourcepath being specified"() {
            goodCode()
            buildFile << """
                tasks.withType(JavaCompile) {
                    options.sourcepath = project.layout.files()
                }
            """
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri May 31 20:20:39 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  5. security/pkg/nodeagent/test/mock/caserver.go

    	}
    	cert := pem.EncodeToMemory(block)
    
    	return cert, nil
    }
    
    // Check handles health check requests.
    func (s *CAServer) Check(ctx context.Context, in *ghc.HealthCheckRequest) (*ghc.HealthCheckResponse, error) {
    	return &ghc.HealthCheckResponse{
    		Status: ghc.HealthCheckResponse_SERVING,
    	}, nil
    }
    
    // Watch handles health check streams.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  6. doc/next/6-stdlib/2-unique.md

    `Make[T]` function, which produces a reference to a canonical copy of
    the value in the form of a `Handle[T]`.
    Two `Handle[T]` are equal if and only if the values used to produce the
    handles are equal, allowing programs to deduplicate values and reduce
    their memory footprint.
    Comparing two `Handle[T]` values is efficient, reducing down to a simple
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 20 18:34:13 UTC 2024
    - 566 bytes
    - Viewed (0)
  7. pilot/pkg/bootstrap/webhook.go

    	}
    	return len(p), nil
    }
    
    // initSSecureWebhookServer handles initialization for the HTTPS webhook server.
    // If https address is off the injection handlers will be registered on the main http endpoint, with
    // TLS handled by a proxy/gateway in front of Istiod.
    func (s *Server) initSecureWebhookServer(args *PilotArgs) {
    	// create the https server for hosting the k8s injectionWebhook handlers.
    	if args.ServerOptions.HTTPSAddr == "" {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jun 11 17:37:53 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  8. platforms/jvm/jvm-services/src/test/groovy/org/gradle/jvm/toolchain/internal/WindowsInstallationSupplierTest.groovy

        }
    
        def "handles absent adoptopenjdk keys"() {
            given:
            registry.getSubkeys(WindowsRegistry.Key.HKEY_LOCAL_MACHINE, _) >> { throw new MissingRegistryEntryException() }
            def supplier = createSupplier()
    
            when:
            def locations = supplier.get()
    
            then:
            locations.isEmpty()
        }
    
        def "gracefully handles unavailable native integration"() {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed May 08 22:14:10 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  9. pkg/kubeapiserver/admission/initializer_test.go

    )
    
    type doNothingAdmission struct{}
    
    func (doNothingAdmission) Admit(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) error {
    	return nil
    }
    func (doNothingAdmission) Handles(o admission.Operation) bool { return false }
    func (doNothingAdmission) Validate() error                    { return nil }
    
    type WantsCloudConfigAdmissionPlugin struct {
    	doNothingAdmission
    	cloudConfig []byte
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:28:42 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  10. platforms/enterprise/enterprise/src/integTest/groovy/org/gradle/internal/enterprise/test/TestTaskPropertiesServiceIntegrationTest.groovy

                                .addConverter(new groovy.json.JsonGenerator.Converter() {
                                    @Override
                                    boolean handles(Class<?> type) {
                                        ${Stream.name}.isAssignableFrom(type)
                                    }
                                    @Override
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 27 10:21:26 UTC 2024
    - 7.9K bytes
    - Viewed (0)
Back to top