- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 458 for Parallel (0.11 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/grpc_service_unix_test.go
// Since the Dial to kms-plugin is non-blocking we expect the construction of gRPC service to succeed even when // kms-plugin is not yet up - dialing happens in the background. func TestKMSPluginLateStart(t *testing.T) { t.Parallel() callTimeout := 3 * time.Second s := newEndpoint() ctx := testContext(t) service, err := NewGRPCService(ctx, s.endpoint, callTimeout) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 29 05:36:41 UTC 2023 - 10K bytes - Viewed (0) -
src/hash/maphash/smhasher_test.go
// currently disabled in -race mode. var fixedSeed = MakeSeed() // Sanity checks. // hash should not depend on values outside key. // hash should not depend on alignment. func TestSmhasherSanity(t *testing.T) { t.Parallel() r := rand.New(rand.NewSource(1234)) const REP = 10 const KEYMAX = 128 const PAD = 16 const OFFMAX = 16 for k := 0; k < REP; k++ { for n := 0; n < KEYMAX; n++ { for i := 0; i < OFFMAX; i++ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 16:41:38 UTC 2024 - 11K bytes - Viewed (0) -
src/cmd/link/internal/ld/ld_test.go
testenv.MustHaveGoBuild(t) // When external linking, symbols may be defined externally, so we allow // undefined symbols and let external linker resolve. Skip the test. testenv.MustInternalLink(t, false) t.Parallel() out, err := testenv.Command(t, testenv.GoToolPath(t), "build", "./testdata/issue10978").CombinedOutput() if err == nil { t.Fatal("expected build to fail") } wantErrors := map[string]int{
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 13 05:45:53 UTC 2023 - 10.3K bytes - Viewed (0) -
src/os/os_unix_test.go
t.Fatalf("Error reading from file: %v", err) } } } func TestNewFileBlock(t *testing.T) { t.Parallel() newFileTest(t, true) } func TestNewFileNonBlock(t *testing.T) { t.Parallel() newFileTest(t, false) } func TestNewFileInvalid(t *testing.T) { t.Parallel() const negOne = ^uintptr(0) if f := NewFile(negOne, "invalid"); f != nil { t.Errorf("NewFile(-1) got %v want nil", f)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:32:43 UTC 2023 - 11.5K bytes - Viewed (0) -
src/os/pipe_test.go
func TestCloseWithBlockingReadByNewFile(t *testing.T) { t.Parallel() var p [2]syscallDescriptor err := syscall.Pipe(p[:]) if err != nil { t.Fatal(err) } // os.NewFile returns a blocking mode file. testCloseWithBlockingRead(t, os.NewFile(uintptr(p[0]), "reader"), os.NewFile(uintptr(p[1]), "writer")) } func TestCloseWithBlockingReadByFd(t *testing.T) { t.Parallel() r, w, err := os.Pipe() if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 05 23:35:29 UTC 2023 - 12.4K bytes - Viewed (0) -
internal/grid/benchmark_test.go
} const payloadSize = 512 rng := rand.New(rand.NewSource(time.Now().UnixNano())) payload := make([]byte, payloadSize) _, err = rng.Read(payload) errFatal(err) // Wait for all to connect // Parallel writes per server. b.Run("bytes", func(b *testing.B) { for par := 1; par <= 32; par *= 2 { b.Run("par="+strconv.Itoa(par*runtime.GOMAXPROCS(0)), func(b *testing.B) { defer timeout(60 * time.Second)()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.7K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/isolated/IsolatedProjectsToolingApiParallelConfigurationIntegrationTest.groovy
@Rule BlockingHttpServer server = new BlockingHttpServer() def setup() { server.start() } def "projects are configured and models created in parallel when project scoped model is queried concurrently"() { withSomeToolingModelBuilderPluginInBuildSrc(""" ${server.callFromBuildUsingExpression("'model-' + project.name")} """)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 10.6K bytes - Viewed (0) -
src/os/removeall_test.go
package os_test import ( "bytes" "fmt" "internal/testenv" . "os" "path/filepath" "runtime" "strconv" "strings" "testing" ) func TestRemoveAll(t *testing.T) { t.Parallel() tmpDir := t.TempDir() if err := RemoveAll(""); err != nil { t.Errorf("RemoveAll(\"\"): %v; want nil", err) } file := filepath.Join(tmpDir, "file") path := filepath.Join(tmpDir, "_TestRemoveAll_")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:21:29 UTC 2024 - 12.3K bytes - Viewed (0) -
platforms/core-execution/execution-e2e-tests/src/integTest/groovy/org/gradle/integtests/StaleOutputHistoryLossIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Mar 04 10:15:40 UTC 2024 - 19.2K bytes - Viewed (0) -
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/transform/ArtifactTransformParallelIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Nov 22 09:41:31 UTC 2023 - 16.9K bytes - Viewed (0)