Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 449 for logf (0.02 sec)

  1. cni/test/install_cni.go

    	t.Helper()
    	t.Logf("Pre-populating working dirs")
    	for i, f := range cniDirOrderedFiles {
    		destFilenm := fmt.Sprintf("0%d-%s", i, f)
    		t.Logf("Copying %v into temp config dir %v/%s", f, tempCNIConfDir, destFilenm)
    		cp(wd+cniConfSubDir+f, tempCNIConfDir+"/"+destFilenm, t)
    	}
    	for _, f := range ls(wd+k8sSvcAcctSubDir, t) {
    		t.Logf("Copying %v into temp k8s serviceaccount dir %v", f, tempK8sSvcAcctDir)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 18:38:14 UTC 2024
    - 11.3K 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

    	// 1: Echo
    	errFatal(local.RegisterSingleHandler(handlerTest, func(payload []byte) ([]byte, *RemoteErr) {
    		t.Log("1: server payload: ", len(payload), "bytes.")
    		return append([]byte{}, payload...), nil
    	}))
    	// 2: Return as error
    	errFatal(local.RegisterSingleHandler(handlerTest2, func(payload []byte) ([]byte, *RemoteErr) {
    		t.Log("2: server payload: ", len(payload), "bytes.")
    		err := RemoteErr(payload)
    		return nil, &err
    	}))
    
    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/local-locker_test.go

    								Quorum:    &quorum,
    							})
    							if !ok || err != nil {
    								t.Fatal("failed:", err, ok)
    							}
    						}
    					}
    					start := time.Now()
    					l.expireOldLocks(time.Hour)
    					t.Logf("Scan Took: %v. Left: %d/%d", time.Since(start).Round(time.Millisecond), len(l.lockUID), len(l.lockMap))
    					if len(l.lockMap) != locks {
    						t.Fatalf("objects deleted, want %d != got %d", locks, len(l.lockMap))
    					}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 11.9K 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. internal/grid/grid_test.go

    		errFatal(resp.Err)
    		t.Logf("got resp: %+v", string(resp.Msg))
    		if string(resp.Msg) != testPayload+strconv.Itoa(n) {
    			t.Errorf("want %q, got %q", testPayload+strconv.Itoa(n), string(resp.Msg))
    		}
    		if n == 10 {
    			close(stream.Requests)
    			continue
    		}
    		n++
    		t.Log("sending new client request")
    		stream.Requests <- []byte(strconv.Itoa(n))
    	}
    	t.Log("EOF. 10 Roundtrips:", time.Since(start))
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  7. internal/dsync/dsync_test.go

    	// We expect at least 3 x 2 x testDrwMutexAcquireTimeout to have passed
    	elapsed := time.Since(started)
    	if elapsed < expect {
    		t.Errorf("expected at least %v time have passed, however %v passed", expect, elapsed)
    	}
    	t.Logf("expected at least %v time have passed, %v passed", expect, elapsed)
    }
    
    // Test two locks for different resources, both succeed
    func TestTwoSimultaneousLocksForDifferentResources(t *testing.T) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 14:35:19 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  8. cni/test/install_k8s_test.go

    			resultFileName:     "user-defined.conf",
    			expectedOutputFile: testDataDir + "/expected/YYY-istio-cni.conf",
    		},
    	}
    	for _, tc := range cases {
    		t.Run(tc.name, func(t *testing.T) {
    			t.Logf("%s: Test preconf %s, expected %s", tc.name, tc.preConfFile, tc.expectedOutputFile)
    			install.RunInstallCNITest(t, tc.chainedCNIPlugin, tc.preConfFile, tc.resultFileName, tc.delayedConfFile, tc.expectedOutputFile,
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 30 23:59:49 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  9. cni/pkg/install/cniconfig_test.go

    					if err != nil {
    						t.Fatal(err)
    					}
    					err = os.WriteFile(filepath.Join(tempDir, c.delayedConfName), data, 0o644)
    					if err != nil {
    						t.Fatal(err)
    					}
    					t.Logf("delayed write to %v", filepath.Join(tempDir, c.delayedConfName))
    				} else if len(c.expectedConfName) > 0 {
    					t.Fatalf("timed out waiting for expected %s", expectedFilepath)
    				} else {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 18:38:14 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  10. src/archive/zip/reader_test.go

    	if err != nil {
    		t.Errorf("%v: OpenRaw ReadAll error=%v", f.Name, err)
    		return
    	}
    	end := uint64(start) + f.CompressedSize64
    	want := raw[start:end]
    	if !bytes.Equal(got, want) {
    		t.Logf("got %q", got)
    		t.Logf("want %q", want)
    		t.Errorf("%v: OpenRaw returned unexpected bytes", f.Name)
    		return
    	}
    
    	r, err := f.Open()
    	if err != nil {
    		t.Errorf("%v", err)
    		return
    	}
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Jul 25 00:25:45 UTC 2024
    - 55.6K bytes
    - Viewed (0)
Back to top