- Sort Score
- Result 10 results
- Languages All
Results 201 - 210 of 509 for meisten (0.16 sec)
-
pilot/pkg/model/test/mockopenidserver.go
if ms.timeout != 0 { handler = withDelay(router, ms.timeout) } server := &http.Server{ Addr: ":" + strconv.Itoa(ms.Port), Handler: handler, } ln, err := net.Listen("tcp", ":0") if err != nil { log.Errorf("Server failed to listen %v", err) return err } scheme := "http" if ms.TLSCertFile != "" && ms.TLSKeyFile != "" { scheme = "https" } port := ln.Addr().(*net.TCPAddr).Port
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 09:47:21 UTC 2024 - 9.4K bytes - Viewed (0) -
pkg/adsc/delta_test.go
} tests = append(tests, tc) } for _, tt := range tests { t.Run(tt.desc, func(t *testing.T) { deltaHandler = tt.deltaHandler l, err := net.Listen("tcp", ":0") if err != nil { t.Errorf("Unable to listen with tcp err %v", err) return } tt.inClient.cfg.Address = l.Addr().String() xds := grpc.NewServer()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 09:32:41 UTC 2024 - 13.9K bytes - Viewed (0) -
docs/de/docs/how-to/custom-docs-ui-assets.md
### Eine *Pfadoperation* erstellen, um statische Dateien zu testen Um nun testen zu können, ob alles funktioniert, erstellen Sie eine *Pfadoperation*: ```Python hl_lines="39-41" {!../../../docs_src/custom_docs_ui/tutorial002.py!} ``` ### Benutzeroberfläche, mit statischen Dateien, testen
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu May 23 22:59:02 UTC 2024 - 9.2K bytes - Viewed (0) -
platforms/jvm/testing-jvm/src/integTest/groovy/org/gradle/testing/junit/AbstractJUnitTestListenerIntegrationTest.groovy
import static org.gradle.util.Matchers.matchesRegexp abstract class AbstractJUnitTestListenerIntegrationTest extends AbstractTestingMultiVersionIntegrationTest { abstract String getAssertionError() def "can listen for test results"() { given: file('src/main/java/AppException.java') << """ public class AppException extends Exception { } """.stripIndent()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 18 20:52:40 UTC 2023 - 5.2K bytes - Viewed (0) -
pkg/test/fakes/gce_metadata_server/main.go
r.HandleFunc(attrPath, handleAttrs(attrs)).Methods("GET") srv := &http.Server{Addr: addr, Handler: r} go func() { if err := srv.ListenAndServe(); err != http.ErrServerClosed { log.Fatalf("listen: %v\n", err) } }() return srv
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Dec 04 22:47:52 UTC 2023 - 3.8K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/jvm/JDWPUtil.groovy
connectionArgs.get("port").setValue(port as String) connectionArgs.get("hostname").setValue(host) this.vm = connection.attach(connectionArgs) } vm } def listen(boolean acceptAsync = true) { def vmm = bootstrapClass.virtualMachineManager() connection = vmm.listeningConnectors().find { it.name() == "com.sun.jdi.SocketListen" }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.7K bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/grpcgen_test.go
ds := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{ ListenerBuilder: func() (net.Listener, error) { return net.Listen("tcp", "127.0.0.1:0") }, }) sd := ds.MemRegistry lis, err := net.Listen("tcp", ":0") if err != nil { t.Fatalf("net.Listen failed: %v", err) } _, ports, _ := net.SplitHostPort(lis.Addr().String()) port, _ := strconv.Atoi(ports) // Echo service
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 09:04:02 UTC 2024 - 16.9K bytes - Viewed (0) -
internal/deadlineconn/deadlineconn_test.go
"bufio" "io" "net" "sync" "testing" "time" ) // Test deadlineconn handles read timeout properly by reading two messages beyond deadline. func TestBuffConnReadTimeout(t *testing.T) { l, err := net.Listen("tcp", "localhost:0") if err != nil { t.Fatalf("unable to create listener. %v", err) } defer l.Close() serverAddr := l.Addr().String() tcpListener, ok := l.(*net.TCPListener) if !ok {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Nov 05 18:09:21 UTC 2022 - 3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/testserver/test_server.go
"google.golang.org/grpc" ) // getAvailablePort returns a TCP port that is available for binding. func getAvailablePorts(count int) ([]int, error) { ports := []int{} for i := 0; i < count; i++ { l, err := net.Listen("tcp", ":0") if err != nil { return nil, fmt.Errorf("could not bind to a port: %v", err) } // It is possible but unlikely that someone else will bind this port before we get a chance to use it. defer l.Close()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 06 11:40:40 UTC 2023 - 3.6K bytes - Viewed (0) -
pkg/test/echo/server/endpoint/udp.go
} func (s *udpInstance) Start(onReady OnReadyFunc) error { var listener net.PacketConn var port int var err error if s.Port.TLS { return fmt.Errorf("TLS not supported for UDP") } // Listen on the given port and update the port if it changed from what was passed in. listener, port, err = listenUDPAddress(s.ListenerIP, s.Port.Port) // Store the actual listening port back to the argument. s.Port.Port = port
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 16:20:31 UTC 2023 - 3.4K bytes - Viewed (0)