Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for wantIdle (0.24 sec)

  1. src/net/http/transport_test.go

    		t.Fatal("second put failed")
    	}
    	wantIdle("after put", 2)
    	tr.CloseIdleConnections()
    	if !tr.IsIdleForTesting() {
    		t.Error("should be idle after CloseIdleConnections")
    	}
    	wantIdle("after close idle", 0)
    	if tr.PutIdleTestConn("http", "example.com") {
    		t.Fatal("put didn't fail")
    	}
    	wantIdle("after second put", 0)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 21:59:21 UTC 2024
    - 192.6K bytes
    - Viewed (0)
  2. src/runtime/symtabinl_test.go

    			// this robust.
    			continue
    		}
    		for ; uf.valid(); uf = u.next(uf) {
    			file, line := u.fileLine(uf)
    			const wantFile = "symtabinl_test.go"
    			if !stringslite.HasSuffix(file, wantFile) {
    				t.Errorf("tiuTest+%#x: want file ...%s, got %s", pc-pc1, wantFile, file)
    			}
    
    			sf := u.srcFunc(uf)
    
    			name := sf.name()
    			const namePrefix = "runtime."
    			if stringslite.HasPrefix(name, namePrefix) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 15:41:45 UTC 2024
    - 3K bytes
    - Viewed (0)
  3. cmd/erasure-common.go

    		}, index)
    	}
    
    	dataArray := make([]ReadMultipleResp, 0, len(req.Files))
    	// Merge results. They should come in order from each.
    	for _, wantFile := range req.Files {
    		quorum := 0
    		toAdd := ReadMultipleResp{
    			Bucket: req.Bucket,
    			Prefix: req.Prefix,
    			File:   wantFile,
    		}
    		for i := range resps {
    			if disks[i] == nil {
    				continue
    			}
    			select {
    			case <-ctx.Done():
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  4. src/cmd/vet/vet_test.go

    	}
    }
    
    // TestTags verifies that the -tags argument controls which files to check.
    func TestTags(t *testing.T) {
    	t.Parallel()
    	for tag, wantFile := range map[string]int{
    		"testtag":     1, // file1
    		"x testtag y": 1,
    		"othertag":    2,
    	} {
    		tag, wantFile := tag, wantFile
    		t.Run(tag, func(t *testing.T) {
    			t.Parallel()
    			t.Logf("-tags=%s", tag)
    			cmd := vetCmd(t, "-tags="+tag, "tagtest")
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 03 01:02:40 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  5. pilot/pkg/security/authz/builder/builder_test.go

    	for i, got := range gots {
    		gotYaml, err := protomarshal.ToYAML(got)
    		if err != nil {
    			t.Fatalf("failed to convert to YAML: %v", err)
    		}
    
    		wantFile := basePath + baseDir + wants[i]
    		util.RefreshGoldenFile(t, []byte(gotYaml), wantFile)
    		want := yamlConfig(t, wantFile, forTCP)
    		wantYaml, err := protomarshal.ToYAML(want)
    		if err != nil {
    			t.Fatalf("failed to convert to YAML: %v", err)
    		}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  6. src/log/slog/logger_test.go

    		t.Helper()
    		const wantFunc = "log/slog.TestCallDepth"
    		const wantFile = "logger_test.go"
    		wantLine := startLine + count*2
    		got := h.r.source()
    		gotFile := filepath.Base(got.File)
    		if got.Function != wantFunc || gotFile != wantFile || got.Line != wantLine {
    			t.Errorf("got (%s, %s, %d), want (%s, %s, %d)",
    				got.Function, gotFile, got.Line, wantFunc, wantFile, wantLine)
    		}
    	}
    
    	defer SetDefault(Default()) // restore
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Nov 10 21:25:30 UTC 2023
    - 19.5K bytes
    - Viewed (0)
  7. internal/grid/grid_test.go

    			},
    			OutCapacity: 1,
    			InCapacity:  1,
    		}))
    	}
    	register(local)
    	register(remote)
    	// Double remote DL
    	local.debugMsg(debugAddToDeadline, wantDL)
    	defer local.debugMsg(debugAddToDeadline, time.Duration(0))
    	remote.debugMsg(debugAddToDeadline, wantDL)
    	defer remote.debugMsg(debugAddToDeadline, time.Duration(0))
    
    	testHandler := func(t *testing.T, handler HandlerID) {
    		remoteConn := local.Connection(remoteHost)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 36.4K bytes
    - Viewed (0)
Back to top