- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 137 for leading (0.25 sec)
-
cmd/erasure-object_test.go
if err != nil { t.Fatalf("Expected GetObject reading data to succeed, but failed with %v", err) } gr.Close() const expectedHash = "fffb6377948ebea75ad2b8058e849ef5" foundHash := fmt.Sprintf("%x", h.Sum(nil)) if foundHash != expectedHash { t.Fatalf("Expected data to have md5sum = `%s`, found `%s`", expectedHash, foundHash) } } // Test reading an object with some outdated data in some disks
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 36.8K bytes - Viewed (0) -
internal/grid/manager.go
} } defer conn.Close() if debugPrint { fmt.Printf("grid: Upgraded request: %v\n", req.URL) } msg, _, err := wsutil.ReadClientData(conn) if err != nil { writeErr(fmt.Errorf("reading connect: %w", err)) w.WriteHeader(http.StatusForbidden) return } if debugPrint { fmt.Printf("%s handler: Got message, length %v\n", m.local, len(msg)) } var message message
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0) -
internal/mountinfo/mountinfo_linux_test.go
` var err error dir := t.TempDir() mountsPath := filepath.Join(dir, "mounts") if err = os.WriteFile(mountsPath, []byte(successCase), 0o666); err != nil { t.Fatal(err) } // Verifies if reading each line worked properly. { var mounts mountInfos mounts, err = readProcMounts(mountsPath) if err != nil { t.Fatal(err) } if len(mounts) != 3 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.3K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
netns := fixture.podNsMap.Take(string(pod.UID)) assert.Equal(t, nil, netns) // run gc to clean up ns: //revive:disable-next-line:call-to-gc Just a test that we are cleaning up the netns runtime.GC() assertNSClosed(t, closed) } func TestServerDeletePod(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() setupLogging()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
src/bytes/reader.go
// io.ByteScanner, and io.RuneScanner interfaces by reading from // a byte slice. // Unlike a [Buffer], a Reader is read-only and supports seeking. // The zero value for Reader operates like a Reader of an empty slice. type Reader struct { s []byte i int64 // current reading index prevRune int // index of previous rune; or < 0 }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 17:10:31 GMT 2023 - 3.9K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
} // Target - Kafka target. type Target struct { status int32 totalMessages int64 failedMessages int64 wg sync.WaitGroup // Channel of log entries. // Reading logCh must hold read lock on logChMu (to avoid read race) // Sending a value on logCh must hold read lock on logChMu (to avoid closing) logCh chan interface{} logChMu sync.RWMutex // store to persist and replay the logs to the target
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1) -
cni/pkg/nodeagent/ztunnelserver.go
fd := int(wl.Netns.Fd()) log.Infof("Sending local pod %s ztunnel", uid) resp, err = conn.sendMsgAndWaitForAck(&zdsapi.WorkloadRequest{ Payload: &zdsapi.WorkloadRequest_Add{ Add: &zdsapi.AddWorkload{ Uid: uid, WorkloadInfo: wl.Workload, }, }, }, &fd) } else { log.Infof("netns not available for local pod %s. sending keep to ztunnel", uid)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
internal/s3select/json/reader_test.go
} r := NewReader(f, &ReaderArgs{}) var record sql.Record for { record, err = r.Read(record) if err != nil { break } } r.Close() if err != io.EOF { t.Fatalf("Reading failed with %s, %s", err, file.Name()) } }) t.Run(file.Name()+"-close", func(t *testing.T) { f, err := os.Open(filepath.Join("testdata", file.Name())) if err != nil { t.Fatal(err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 2.5K bytes - Viewed (0) -
cmd/auth-handler_test.go
if s3Error != testCase.s3Error { if _, err := io.ReadAll(testCase.req.Body); toAPIErrorCode(ctx, err) != testCase.s3Error { t.Fatalf("Test %d: Unexpected S3 error: want %d - got %d (got after reading request %s)", i, testCase.s3Error, s3Error, toAPIError(ctx, err).Code) } } } } func TestCheckAdminRequestAuthType(t *testing.T) { ctx, cancel := context.WithCancel(context.Background())
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 15.4K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/secret_test.go
configDump, err := io.ReadAll(configDumpFile) if err != nil { t.Errorf("error reading test data file: %v", err) } outFile, err := os.Open("testdata/secret/output") if err != nil { t.Errorf("error opening test data output file: %v", err) } defer outFile.Close() expectedOut, err := io.ReadAll(outFile) if err != nil { t.Errorf("error reading test data output file: %v", err) } gotOut := &bytes.Buffer{}
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jun 06 15:14:48 GMT 2023 - 1.5K bytes - Viewed (0)