Search Options

Results per page
Sort
Preferred Languages
Advance

Results 201 - 210 of 1,440 for ERROR (0.07 sec)

  1. cmd/storage-datatypes_gen.go

    	if err != nil {
    		err = msgp.WrapError(err, "Metrics")
    		return
    	}
    	z.Error, err = dc.ReadString()
    	if err != nil {
    		err = msgp.WrapError(err, "Error")
    		return
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z *DiskInfo) EncodeMsg(en *msgp.Writer) (err error) {
    	// array header, size 18
    	err = en.Append(0xdc, 0x0, 0x12)
    	if err != nil {
    		return
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 150.2K bytes
    - Viewed (0)
  2. internal/cachevalue/cache.go

    // If the Update function returns an error the value is forwarded as is and not cached.
    func (t *Cache[T]) GetWithCtx(ctx context.Context) (T, error) {
    	v := t.val.Load()
    	ttl := t.ttl
    	vTime := t.lastUpdateMs.Load()
    	tNow := time.Now().UnixMilli()
    	if v != nil && tNow-vTime < ttl.Milliseconds() {
    		return *v, nil
    	}
    
    	// Fetch new value asynchronously, while we do not return an error
    	// if v != nil value or
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 12:50:46 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  3. cmd/site-replication-metrics_gen_test.go

    		t.Log("WARNING: TestEncodeDecodeRStat Msgsize() is inaccurate")
    	}
    
    	vn := RStat{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    }
    
    func BenchmarkEncodeRStat(b *testing.B) {
    	v := RStat{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 30 08:00:59 UTC 2023
    - 12.9K bytes
    - Viewed (0)
  4. internal/grid/msg_gen_test.go

    		t.Log("WARNING: TestEncodeDecodeconnectReq Msgsize() is inaccurate")
    	}
    
    	vn := connectReq{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    }
    
    func BenchmarkEncodeconnectReq(b *testing.B) {
    	v := connectReq{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jul 25 21:07:21 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  5. internal/event/config.go

    func (filter FilterRule) MarshalXML(e *xml.Encoder, start xml.StartElement) error {
    	if filter.isEmpty() {
    		return nil
    	}
    	type filterRuleWrapper FilterRule
    	return e.EncodeElement(filterRuleWrapper(filter), start)
    }
    
    // UnmarshalXML - decodes XML data.
    func (filter *FilterRule) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    	// Make subtype to avoid recursive UnmarshalXML().
    	type filterRule FilterRule
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Nov 16 17:28:29 UTC 2021
    - 8.4K bytes
    - Viewed (0)
  6. cmd/prepare-storage.go

    			printOnce[endpoint] = m
    			if once {
    				m[err.Error()]++
    				peersLogAlwaysIf(ctx, err)
    				return
    			}
    		}
    		// Once is set and we are here means error was already
    		// printed once.
    		if once {
    			return
    		}
    		// once not set, check if same error occurred 3 times in
    		// a row, then make sure we print it to call attention.
    		if m[err.Error()] > 2 {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  7. cmd/storage-rest-common_gen.go

    package cmd
    
    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *nsScannerOptions) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  8. cmd/erasure-healing-common_test.go

    	"path/filepath"
    	"runtime"
    	"testing"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    )
    
    // Returns the latest updated FileInfo files and error in case of failure.
    func getLatestFileInfo(ctx context.Context, partsMetadata []FileInfo, defaultParityCount int, errs []error) (FileInfo, error) {
    	// There should be at least half correct entries, if not return failure
    	expectedRQuorum := len(partsMetadata) / 2
    	if defaultParityCount == 0 {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 01 15:19:10 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  9. internal/event/target/postgresql.go

    }
    
    // send - sends an event to the PostgreSQL.
    func (target *PostgreSQLTarget) send(eventData event.Event) error {
    	if target.args.Format == event.NamespaceFormat {
    		objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
    		if err != nil {
    			return err
    		}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  10. tests/associations_many2many_test.go

    		t.Fatalf("should raise error when create users without languages reference")
    	}
    
    	if err := DB.Create(&user.Languages).Error; err != nil {
    		t.Fatalf("no error should happen when create languages, but got %v", err)
    	}
    
    	if err := DB.Omit("Languages.*").Create(&user).Error; err != nil {
    		t.Fatalf("no error should happen when create user when languages exists, but got %v", err)
    	}
    
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Sat Jun 10 13:05:19 UTC 2023
    - 13.2K bytes
    - Viewed (0)
Back to top