Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for tiers (0.04 sec)

  1. cmd/xl-storage.go

    			return sizeSummary{}, errSkipFile
    		}
    
    		sizeS := sizeSummary{}
    		for _, tier := range globalTierConfigMgr.ListTiers() {
    			if sizeS.tiers == nil {
    				sizeS.tiers = make(map[string]tierStats)
    			}
    			sizeS.tiers[tier.Name] = tierStats{}
    		}
    		if sizeS.tiers != nil {
    			sizeS.tiers[storageclass.STANDARD] = tierStats{}
    			sizeS.tiers[storageclass.RRS] = tierStats{}
    		}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 85.3K bytes
    - Viewed (2)
  2. internal/bucket/lifecycle/lifecycle_test.go

    	}
    	if evt.StorageClass != "TIER-1" {
    		t.Fatalf("Expected TIER-1 but got %s", evt.StorageClass)
    	}
    
    	evt = lc.eval(obj2, now)
    	if evt.Action != TransitionVersionAction {
    		t.Fatalf("Expected action: %s but got %s", TransitionVersionAction, evt.Action)
    	}
    	if evt.StorageClass != "TIER-2" {
    		t.Fatalf("Expected TIER-2 but got %s", evt.StorageClass)
    	}
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 23 01:12:48 UTC 2024
    - 55.1K bytes
    - Viewed (0)
  3. cmd/object-api-datatypes_gen.go

    			z.VersionID, bts, err = msgp.ReadStringBytes(bts)
    			if err != nil {
    				err = msgp.WrapError(err, "VersionID")
    				return
    			}
    		case "Tier":
    			z.Tier, bts, err = msgp.ReadStringBytes(bts)
    			if err != nil {
    				err = msgp.WrapError(err, "Tier")
    				return
    			}
    		case "FreeVersion":
    			z.FreeVersion, bts, err = msgp.ReadBoolBytes(bts)
    			if err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 70.1K bytes
    - Viewed (0)
  4. cmd/erasure-object.go

    	}
    
    	return tags.ParseObjectTags(oi.UserTags)
    }
    
    // TransitionObject - transition object content to target tier.
    func (er erasureObjects) TransitionObject(ctx context.Context, bucket, object string, opts ObjectOptions) error {
    	tgtClient, err := globalTierConfigMgr.getDriver(ctx, opts.Transition.Tier)
    	if err != nil {
    		return err
    	}
    
    	// Acquire write lock before starting to transition the object.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 78.6K bytes
    - Viewed (0)
  5. src/cmd/compile/internal/ssa/rewrite.go

    				if vchange && debug > 1 {
    					fmt.Printf("rewriting %s  ->  %s\n", v0.LongString(), v.LongString())
    				}
    			}
    		}
    		if !change && !deadChange {
    			break
    		}
    		iters++
    		if (iters > itersLimit || debug >= 2) && change {
    			// We've done a suspiciously large number of rewrites (or we're in debug mode).
    			// As of Sep 2021, 90% of rewrites complete in 4 iterations or fewer
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 19:02:52 UTC 2024
    - 64.2K bytes
    - Viewed (0)
  6. cmd/peer-rest-server.go

    	}
    
    	go func() {
    		err := globalTierConfigMgr.Reload(context.Background(), newObjectLayerFn())
    		if err != nil {
    			peersLogIf(context.Background(), fmt.Errorf("Failed to reload remote tier config %s", err))
    		}
    	}()
    
    	return
    }
    
    // ConsoleLogHandler sends console logs of this node back to peer rest client
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 52.1K bytes
    - Viewed (0)
  7. src/time/time_test.go

    		t.Errorf("readFile(%q) error = %v; want error containing 'is too large'", zero, err)
    	}
    }
    
    // Issue 25686: hard crash on concurrent timer access.
    // Issue 37400: panic with "racy use of timers"
    // This test deliberately invokes a race condition.
    // We are testing that we don't crash with "fatal error: panic holding locks",
    // and that we also don't panic.
    func TestConcurrentTimerReset(t *testing.T) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:13:47 UTC 2024
    - 56.5K bytes
    - Viewed (0)
  8. pkg/controller/history/controller_history_test.go

    		},
    		{
    			name:      "reversed",
    			revisions: []*apps.ControllerRevision{ss1Rev3, ss1Rev2, ss1Rev1},
    			want:      []string{ss1Rev1.Name, ss1Rev2.Name, ss1Rev3.Name},
    		},
    		{
    			name:      "with ties",
    			revisions: []*apps.ControllerRevision{ss1Rev3, ss1Rev3Time2, ss1Rev2, ss1Rev1},
    			want:      []string{ss1Rev1.Name, ss1Rev2.Name, ss1Rev3.Name, ss1Rev3Time2.Name, ss1Rev3Time2Name2.Name},
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 21 13:31:28 UTC 2023
    - 49.1K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    				c.blockedWatchers = append(c.blockedWatchers, watcher)
    			}
    		}
    
    		if len(c.blockedWatchers) > 0 {
    			// dispatchEvent is called very often, so arrange
    			// to reuse timers instead of constantly allocating.
    			startTime := time.Now()
    			timeout := c.dispatchTimeoutBudget.takeAvailable()
    			c.timer.Reset(timeout)
    
    			// Send event to all blocked watchers. As long as timer is running,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
  10. cmd/bucket-handlers.go

    			ReqParams:    extractReqParams(r),
    			RespElements: extractRespElements(w),
    			UserAgent:    r.UserAgent(),
    			Host:         handlers.GetSourceIP(r),
    		})
    	}
    
    	// Clean up transitioned objects from remote tier
    	for _, os := range oss {
    		if os == nil { // skip objects that weren't deleted due to invalid versionID etc.
    			continue
    		}
    		os.Sweep()
    	}
    }
    
    // PutBucketHandler - PUT Bucket
    // ----------
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 14 13:28:35 UTC 2024
    - 61.2K bytes
    - Viewed (0)
Back to top