Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 93 for Sentry (0.21 sec)

  1. cmd/xl-storage-format-v2_test.go

    	serialized, err := xl.AppendTo(nil)
    	failOnErr(err)
    	// Roundtrip data
    	var xl2 xlMetaV2
    	failOnErr(xl2.Load(serialized))
    
    	// We should have one data entry
    	list, err := xl2.data.list()
    	failOnErr(err)
    	if len(list) != 2 {
    		t.Fatalf("want 1 entry, got %d", len(list))
    	}
    
    	if !bytes.Equal(xl2.data.find("756100c6-b393-4981-928a-d49bbc164741"), data) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Mar 08 17:50:48 GMT 2024
    - 36.4K bytes
    - Viewed (0)
  2. cmd/metacache-walk.go

    				entries[i] = ""
    				continue
    			}
    			if hasSuffixByte(entry, SlashSeparatorChar) {
    				if strings.HasSuffix(entry, globalDirSuffixWithSlash) {
    					// Add without extension so it is sorted correctly.
    					entry = strings.TrimSuffix(entry, globalDirSuffixWithSlash) + slashSeparator
    					dirObjects[entry] = struct{}{}
    					entries[i] = entry
    					continue
    				}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  3. cmd/metacache-set.go

    			}
    			if !strings.HasPrefix(entry.name, o.Prefix) {
    				continue
    			}
    			if !o.Recursive && !entry.isInDir(o.Prefix, o.Separator) {
    				continue
    			}
    			if !o.InclDeleted && entry.isObject() && entry.isLatestDeletemarker() && !entry.isObjectDir() {
    				continue
    			}
    			if o.Lifecycle != nil || o.Replication.Config != nil {
    				if skipped := triggerExpiryAndRepl(ctx, *o, entry); skipped == true {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 19:52:52 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  4. cmd/admin-handlers.go

    	entry := &madmin.LockEntry{
    		Timestamp:  l.Timestamp,
    		Elapsed:    now.Sub(l.Timestamp),
    		Resource:   resource,
    		ServerList: []string{server},
    		Source:     l.Source,
    		Owner:      l.Owner,
    		ID:         l.UID,
    		Quorum:     l.Quorum,
    	}
    	if l.Writer {
    		entry.Type = "WRITE"
    	} else {
    		entry.Type = "READ"
    	}
    	return entry
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 97.3K bytes
    - Viewed (2)
  5. cmd/admin-handlers_test.go

    	}{
    		{
    			peerLocks: peerLocks,
    			expected:  exp,
    		},
    	}
    
    	// printEntries := func(entries madmin.LockEntries) {
    	// 	for i, entry := range entries {
    	// 		fmt.Printf("%d: %s %s %s %s %v %d\n", i, entry.Resource, entry.ID, entry.Owner, entry.Type, entry.ServerList, entry.Elapsed)
    	// 	}
    	// }
    
    	check := func(exp, got madmin.LockEntries) (int, bool) {
    		if len(exp) != len(got) {
    			return 0, false
    		}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 13.8K bytes
    - Viewed (0)
  6. cmd/data-usage-cache.go

    	}
    
    	// Caches are read+written without locks,
    	retries := 0
    	for retries < 5 {
    		retry, err := load(name, time.Minute)
    		if err != nil {
    			return toObjectErr(err, dataUsageBucket, name)
    		}
    		if !retry {
    			break
    		}
    		retry, err = load(name+".bkp", 30*time.Second)
    		if err == nil && !retry {
    			// Only return when we have valid data from the backup
    			break
    		}
    		retries++
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.4K bytes
    - Viewed (1)
  7. cmd/erasure.go

    					cache.Info.LastUpdate = time.Now()
    					scannerLogOnceIf(ctx, cache.save(ctx, er, dataUsageCacheName), "nsscanner-channel-closed")
    					updates <- cache.clone()
    					return
    				}
    				cache.replace(v.Name, v.Parent, v.Entry)
    				cache.Info.LastUpdate = time.Now()
    			}
    		}
    	}()
    
    	// Restrict parallelism for disk usage scanner
    	// upto GOMAXPROCS if GOMAXPROCS is < len(disks)
    	maxProcs := runtime.GOMAXPROCS(0)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 16K bytes
    - Viewed (1)
  8. cmd/batch-handlers.go

    				Key:       entry.Name,
    				Size:      entry.Size,
    				ModTime:   entry.ModTime,
    				VersionID: entry.VersionID,
    				Content:   gr,
    				Headers:   make(http.Header),
    				Close: func() {
    					gr.Close()
    				},
    			}
    
    			opts, err := batchReplicationOpts(ctx, "", gr.ObjInfo)
    			if err != nil {
    				batchLogIf(ctx, err)
    				continue
    			}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 08 14:11:38 GMT 2024
    - 55.2K bytes
    - Viewed (0)
  9. cmd/metacache.go

    	// but may cause additional latency to some calls.
    	metacacheSharePrefix = false
    )
    
    //go:generate msgp -file $GOFILE -unexported
    
    // metacache contains a tracked cache entry.
    type metacache struct {
    	// do not re-arrange the struct this struct has been ordered to use less
    	// space - if you do so please run https://github.com/orijtech/structslop
    	// and verify if your changes are optimal.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5K bytes
    - Viewed (0)
  10. cmd/bucket-metadata-sys.go

    				wait := sleeper.Timer(ctx)
    
    				meta, err := loadBucketMetadata(ctx, sys.objAPI, buckets[i].Name)
    				if err != nil {
    					internalLogIf(ctx, err, logger.WarningKind)
    					wait() // wait to proceed to next entry.
    					continue
    				}
    
    				sys.Lock()
    				sys.metadataMap[buckets[i].Name] = meta
    				sys.Unlock()
    
    				// Initialize the failed buckets
    				if _, ok := failedBuckets[buckets[i].Name]; ok {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 19.8K bytes
    - Viewed (0)
Back to top