Search Options

Results per page
Sort
Preferred Languages
Advance

Results 201 - 210 of 663 for Fprintf (0.04 sec)

  1. internal/dsync/drwmutex_test.go

    			if n != 10000 {
    				panic(fmt.Sprintf("wlock(%d)\n", n))
    			}
    			for range 100 {
    			}
    			atomic.AddInt32(activity, -10000)
    			rwm.Unlock(context.Background())
    		}
    	}
    	cdone <- true
    }
    
    // Borrowed from rwmutex_test.go
    func hammerRWMutex(t *testing.T, gomaxprocs, numReaders, numIterations int) {
    	t.Run(fmt.Sprintf("%d-%d-%d", gomaxprocs, numReaders, numIterations), func(t *testing.T) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  2. internal/bucket/object/lock/lock.go

    func (config Config) String() string {
    	parts := []string{
    		fmt.Sprintf("Enabled: %v", config.Enabled()),
    	}
    	if config.Rule != nil {
    		if config.Rule.DefaultRetention.Mode != "" {
    			parts = append(parts, fmt.Sprintf("Mode: %s", config.Rule.DefaultRetention.Mode))
    		}
    		if config.Rule.DefaultRetention.Days != nil {
    			parts = append(parts, fmt.Sprintf("Days: %d", *config.Rule.DefaultRetention.Days))
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 17.9K bytes
    - Viewed (0)
  3. cmd/os-readdir_test.go

    	if runtime.GOOS == globalWindowsOSName {
    		t.Skip("symlinks not available on windows")
    		return nil
    	}
    	dir := t.TempDir()
    	entries := []string{}
    	for i := range 10 {
    		name1 := fmt.Sprintf("file-%d", i)
    		name2 := fmt.Sprintf("file-%d", i+10)
    		if err := os.WriteFile(filepath.Join(dir, name1), []byte{}, os.ModePerm); err != nil {
    			// For cleanup, its required to add these entries into test results.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  4. clause/update_test.go

    		},
    		{
    			[]clause.Interface{clause.Update{Table: clause.Table{Name: "products"}, Modifier: "LOW_PRIORITY"}},
    			"UPDATE LOW_PRIORITY `products`", nil,
    		},
    	}
    
    	for idx, result := range results {
    		t.Run(fmt.Sprintf("case #%v", idx), func(t *testing.T) {
    			checkBuildClauses(t, result.Clauses, result.Result, result.Vars)
    		})
    	}
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Tue Jun 02 01:18:01 UTC 2020
    - 722 bytes
    - Viewed (0)
  5. internal/store/queuestore_test.go

    	for i := range 5 {
    		items = append(items, TestItem{
    			Name:     fmt.Sprintf("test-item-%d", i),
    			Property: "property",
    		})
    	}
    	if _, err := store.PutMultiple(items); err != nil {
    		t.Fatalf("failed to put multiple; %v", err)
    	}
    
    	for i := 5; i < 10; i++ {
    		item := TestItem{
    			Name:     fmt.Sprintf("test-item-%d", i),
    			Property: "property",
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 10.2K bytes
    - Viewed (0)
  6. statement_test.go

    )
    
    func TestWhereCloneCorruption(t *testing.T) {
    	for whereCount := 1; whereCount <= 8; whereCount++ {
    		t.Run(fmt.Sprintf("w=%d", whereCount), func(t *testing.T) {
    			s := new(Statement)
    			for w := 0; w < whereCount; w++ {
    				s = s.clone()
    				s.AddClause(clause.Where{
    					Exprs: s.BuildCondition(fmt.Sprintf("where%d", w)),
    				})
    			}
    
    			s1 := s.clone()
    			s1.AddClause(clause.Where{
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Sat Dec 23 13:19:41 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  7. logger/sql_test.go

    			NumericRegexp: nil,
    			Vars:          []interface{}{"jinzhu", 1, 999.99, true, []byte("12345"), tt, &tt, nil, "w@g.\"com", myrole, pwd, js, es},
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Thu Mar 21 08:00:02 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  8. cmd/update-notifier_test.go

    	plainMsg := "You are running an older version of MinIO released"
    
    	for i, testCase := range testCases {
    		output := prepareUpdateMessage(testCase.dlURL, testCase.older)
    		line1 := fmt.Sprintf("%s %s", plainMsg, color.YellowBold(testCase.expectedSubStr))
    		line2 := fmt.Sprintf("Update: %s", color.CyanBold(testCase.dlURL))
    		// Uncomment below to see message appearance:
    		// fmt.Println(output)
    		switch {
    		case testCase.dlURL == "" && output != "":
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Jul 31 15:36:19 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  9. internal/grid/trace.go

    		m := MSS(typed)
    		trace.Path += m.ToQuery()
    	case *URLValues:
    		trace.Path += typed.Values().Encode()
    	case *NoPayload, *Bytes:
    		trace.Path = fmt.Sprintf("%s?payload=%T", trace.Path, typed)
    	case string:
    		trace.Path = fmt.Sprintf("%s?%s", trace.Path, typed)
    	default:
    	}
    	trace.HTTP.ReqInfo.Path = trace.Path
    
    	t.Publisher.Publish(trace)
    	return resp, err
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  10. tests/benchmark_test.go

    	for i := 0; i < 10_000; i++ {
    		user := *GetUser(fmt.Sprintf("scan-%d", i), Config{})
    		DB.Create(&user)
    	}
    
    	var u []User
    	b.ResetTimer()
    	for x := 0; x < b.N; x++ {
    		DB.Raw("select * from users").Scan(&u)
    	}
    }
    
    func BenchmarkScanSlicePointer(b *testing.B) {
    	DB.Exec("delete from users")
    	for i := 0; i < 10_000; i++ {
    		user := *GetUser(fmt.Sprintf("scan-%d", i), Config{})
    		DB.Create(&user)
    	}
    
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Wed Jun 01 03:50:57 UTC 2022
    - 1.5K bytes
    - Viewed (0)
Back to top