- Sort Score
- Num 10 results
- Language All
Results 251 - 260 of 2,201 for Errorf (0.04 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
internal/s3select/simdj/reader_amd64_test.go
} err = rec.WriteCSV(&gotB, opts) if err != nil { t.Error(err) } err = want.WriteCSV(&wantB, opts) if err != nil { t.Error(err) } if !bytes.Equal(gotB.Bytes(), wantB.Bytes()) { t.Errorf("CSV output mismatch.\nwant: %s(%x)\ngot: %s(%x)", wantB.String(), wantB.Bytes(), gotB.String(), gotB.Bytes()) } gotB.Reset() wantB.Reset()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 3.9K bytes - Click Count (0) -
internal/grid/connection_test.go
cReverse.Local = hosts[y] cReverse.Remote = hosts[x] if c.shouldConnect() == cReverse.shouldConnect() { t.Errorf("shouldConnect(%q, %q) != shouldConnect(%q, %q)", hosts[x], hosts[y], hosts[y], hosts[x]) } if c.shouldConnect() { should++ } } if should < 10 { t.Errorf("host %q only connects to %d hosts", hosts[x], should) } t.Logf("host %q should connect to %d hosts", hosts[x], should) }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 5.9K bytes - Click Count (0) -
internal/pubsub/pubsub.go
func (ps *PubSub[T, M]) Subscribe(mask M, subCh chan T, doneCh <-chan struct{}, filter func(entry T) bool) error { totalSubs := atomic.AddInt32(&ps.numSubscribers, 1) if ps.maxSubscribers > 0 && totalSubs > ps.maxSubscribers { atomic.AddInt32(&ps.numSubscribers, -1) return fmt.Errorf("the limit of `%d` subscribers is reached", ps.maxSubscribers) } ps.Lock() defer ps.Unlock()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 06 16:57:30 GMT 2024 - 5.2K bytes - Click Count (0) -
internal/rest/client.go
online closed ) // NetworkError - error type in case of errors related to http/transport // for ex. connection refused, connection reset, dns resolution failure etc. // All errors returned by storage-rest-server (ex errFileNotFound, errDiskNotFound) are not considered to be network errors. type NetworkError struct { Err error } func (n *NetworkError) Error() string { return n.Err.Error() }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 14.7K bytes - Click Count (0) -
cmd/erasure-heal_test.go
closeBitrotReaders(readers) closeBitrotWriters(staleWriters) if err != nil && !test.shouldFail { t.Errorf("Test %d: should pass but it failed with: %v", i, err) } if err == nil && test.shouldFail { t.Errorf("Test %d: should fail but it passed", i) } if err == nil { // Verify that checksums of staleDisks // match expected values
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 7.9K bytes - Click Count (0) -
tests/update_belongs_to_test.go
user := *GetUser("update-belongs-to", Config{}) if err := DB.Create(&user).Error; err != nil { t.Fatalf("errors happened when create: %v", err) } user.Company = Company{Name: "company-belongs-to-association"} user.Manager = &User{Name: "manager-belongs-to-association"} if err := DB.Save(&user).Error; err != nil { t.Fatalf("errors happened when update: %v", err) } var user2 UserCreated: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Thu Jul 14 06:55:54 GMT 2022 - 1.6K bytes - Click Count (0) -
internal/s3select/sql/parser_test.go
t.Fatal(err) } if len(tokens) != 7 { t.Errorf("Expected 7 got %d", len(tokens)) } // for i, t := range tokens { // fmt.Printf("%d: %#v\n", i, t) // } } func TestParseSelectStatement(t *testing.T) { exp, err := ParseSelectStatement("select _3,_1,_2 as 'mytest' from S3object") if err != nil { t.Fatalf("parse alias sql error: %v", err) }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.2K bytes - Click Count (0) -
internal/bucket/bandwidth/monitor_test.go
} m.bucketsMeasurement[BucketOptions{Name: "bucket", ReplicationARN: "arn"}].updateExponentialMovingAverage(tt.fields.endTime) got := m.GetReport(SelectBuckets()) if !reflect.DeepEqual(got, tt.want) { t.Errorf("GetReport() = %v, want %v", got, tt.want) } m.bucketsMeasurement[BucketOptions{Name: "bucket", ReplicationARN: "arn"}].incrementBytes(tt.fields.update2)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 4.3K bytes - Click Count (0) -
schema/index_test.go
if len(expected) != len(actual) { t.Errorf("expected %d indices, but got %d", len(expected), len(actual)) return } for i, ei := range expected { t.Run(ei.Name, func(t *testing.T) { ai := actual[i] tests.AssertObjEqual(t, ai, ei, "Name", "Class", "Type", "Where", "Comment", "Option") if len(ei.Fields) != len(ai.Fields) {
Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Fri Dec 06 02:27:44 GMT 2024 - 7.9K bytes - Click Count (0) -
internal/grid/muxclient.go
return } select { case m.outBlock <- struct{}{}: default: gridLogIf(m.ctx, errors.New("output unblocked overflow")) } } func (m *muxClient) pong(msg pongMsg) { if msg.NotFound || msg.Err != nil { err := errors.New("remote terminated call") if msg.Err != nil { err = fmt.Errorf("remove pong failed: %v", &msg.Err) } m.addResponse(Response{Err: err}) return }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 15.9K bytes - Click Count (0)