Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for vlogf (0.06 sec)

  1. internal/logger/target/testlogger/testlogger.go

    	tb := t.current.Load()
    	var logf func(format string, args ...any)
    	if tb != nil {
    		tbb := *tb
    		tbb.Helper()
    		switch t.action.Load() {
    		case errorMessage:
    			logf = tbb.Errorf
    		case fatalMessage:
    			logf = tbb.Fatalf
    		default:
    			logf = tbb.Logf
    		}
    	} else {
    		switch t.action.Load() {
    		case errorMessage:
    			logf = func(format string, args ...any) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4K bytes
    - Viewed (0)
  2. internal/s3select/jstream/decoder_test.go

    		mockData  = byte('[')
    	)
    
    	r := newMockReader(failAfter, mockData)
    	decoder := NewDecoder(r, -1)
    
    	for mv := range decoder.Stream() {
    		t.Logf("depth=%d offset=%d len=%d (%v)", mv.Depth, mv.Offset, mv.Length, mv.Value)
    	}
    
    	err := decoder.Err()
    	t.Logf("got error: %s", err)
    	if err == nil {
    		t.Fatalf("missing expected decoder error")
    	}
    
    	derr, ok := err.(DecoderError)
    	if !ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  3. internal/grid/connection_test.go

    		t.Helper()
    		if err != nil {
    			t.Fatal(err)
    		}
    	}
    	wrapServer := func(handler http.Handler) http.Handler {
    		return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    			t.Logf("Got a %s request for: %v", r.Method, r.URL)
    			handler.ServeHTTP(w, r)
    		})
    	}
    	connReady := make(chan struct{})
    	// We fake a local and remote server.
    	localHost := hosts[0]
    	remoteHost := hosts[1]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 08 21:44:00 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  4. cmd/metacache_test.go

    	for i, tt := range metaCacheTestset {
    		t.Run(tt.id, func(t *testing.T) {
    			var want bool
    			if i >= len(wantResults) {
    				t.Logf("no expected result for test #%d", i)
    			} else {
    				want = wantResults[i]
    			}
    
    			got := tt.finished()
    			if got != want {
    				t.Errorf("#%d: want %v, got %v", i, want, got)
    			}
    		})
    	}
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 08 18:06:45 UTC 2021
    - 6.8K bytes
    - Viewed (0)
  5. internal/s3select/jstream/scanner_test.go

    		c := scanner.next()
    		if scanner.readerErr != nil {
    			t.Fatal(scanner.readerErr)
    		}
    		if c != data[i] {
    			t.Fatalf("expected %s, got %s", string(data[i]), string(c))
    		}
    		t.Logf("pos=%d remaining=%d (%s)", i, r.Len(), string(c))
    		i++
    	}
    }
    
    type mockReader struct {
    	pos       int
    	mockData  byte
    	failAfter int
    }
    
    func newMockReader(failAfter int, data byte) *mockReader {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  6. cmd/xl-storage-free-version_test.go

    		t.Helper()
    		if err != nil {
    			t.Fatal(err)
    		}
    	}
    
    	// Add a version with tiered content, one with local content
    	xl := xlMetaV2{}
    	counter := 1
    	report := func() {
    		t.Helper()
    		// t.Logf("versions (%d): len = %d", counter, len(xl.versions))
    		counter++
    	}
    	fi := FileInfo{
    		Volume:           "volume",
    		Name:             "object-name",
    		VersionID:        "00000000-0000-0000-0000-000000000001",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Mar 02 05:11:03 UTC 2024
    - 7.8K bytes
    - Viewed (0)
Back to top