Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 391 for ctx_ (0.05 sec)

  1. cmd/erasure-healing-common_test.go

    			_, err = obj.PutObject(ctx, bucket, object, mustGetPutObjReader(t, bytes.NewReader(data), int64(len(data)), "", ""), ObjectOptions{})
    			if err != nil {
    				t.Fatalf("Failed to putObject %v", err)
    			}
    
    			partsMetadata, errs := readAllFileInfo(ctx, erasureDisks, "", bucket, object, "", false, true)
    			fi, err := getLatestFileInfo(ctx, partsMetadata, z.serverPools[0].sets[0].defaultParityCount, errs)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 15:19:10 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  2. cmd/healthcheck-handler.go

    }
    
    // ClusterCheckHandler returns if the server is ready for requests.
    func ClusterCheckHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "ClusterCheckHandler")
    
    	objLayer := checkHealth(w)
    	if objLayer == nil {
    		return
    	}
    
    	ctx, cancel := context.WithTimeout(ctx, globalAPIConfig.getClusterDeadline())
    	defer cancel()
    
    	opts := HealthOptions{
    		Maintenance:    r.Form.Get("maintenance") == "true",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 26 07:44:34 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  3. cmd/site-replication-utils.go

    	peerResyncMap map[string]resyncState
    }
    
    func newSiteResyncMetrics(ctx context.Context) *siteResyncMetrics {
    	s := siteResyncMetrics{
    		resyncStatus:  make(map[string]SiteResyncStatus),
    		peerResyncMap: make(map[string]resyncState),
    	}
    	go s.save(ctx)
    	go s.init(ctx)
    	return &s
    }
    
    // init site resync metrics
    func (sm *siteResyncMetrics) init(ctx context.Context) {
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  4. cmd/background-heal-ops.go

    	waitForLowIO(maxIO, maxWait, currentHTTPIO)
    }
    
    func initBackgroundHealing(ctx context.Context, objAPI ObjectLayer) {
    	bgSeq := newBgHealSequence()
    	// Run the background healer
    	for i := 0; i < globalBackgroundHealRoutine.workers; i++ {
    		go globalBackgroundHealRoutine.AddWorker(ctx, objAPI, bgSeq)
    	}
    
    	globalBackgroundHealState.LaunchNewHealSequence(bgSeq, objAPI)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  5. internal/logger/logonce.go

    // on how it is used.
    func LogOnceIf(ctx context.Context, subsystem string, err error, id string, errKind ...interface{}) {
    	if logIgnoreError(err) {
    		return
    	}
    	logOnce.logOnceIf(ctx, subsystem, err, id, errKind...)
    }
    
    // LogOnceConsoleIf - similar to LogOnceIf but exclusively only logs to console target.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  6. internal/bucket/bandwidth/reader.go

    // bucket.
    func NewMonitoredReader(ctx context.Context, m *Monitor, r io.Reader, opts *MonitorReaderOptions) *MonitoredReader {
    	reader := MonitoredReader{
    		r:        r,
    		throttle: m.throttle(opts.BucketOptions),
    		m:        m,
    		opts:     opts,
    		ctx:      ctx,
    	}
    	reader.m.init(opts.BucketOptions)
    	return &reader
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 14:57:31 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  7. internal/dsync/dsync_test.go

    	var wg sync.WaitGroup
    	wg.Add(1)
    
    	ctx, cl := context.WithCancel(context.Background())
    	cancel := func() {
    		cl()
    		wg.Done()
    	}
    
    	if !dm.GetLock(ctx, cancel, id, source, Options{Timeout: 5 * time.Minute}) {
    		t.Fatal("GetLock() should be successful")
    	}
    
    	// Wait until context is canceled
    	wg.Wait()
    	if ctx.Err() == nil {
    		t.Fatal("Unexpected error", ctx.Err())
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 14:35:19 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  8. cmd/veeam-sos-api.go

    // isVeeamClient - returns true if the request is from Veeam client.
    func isVeeamClient(ctx context.Context) bool {
    	ri := logger.GetReqInfo(ctx)
    	return ri != nil && strings.Contains(ri.UserAgent, veeamAgentSubstr)
    }
    
    func veeamSOSAPIHeadObject(ctx context.Context, bucket, object string, opts ObjectOptions) (ObjectInfo, error) {
    	gr, err := veeamSOSAPIGetObject(ctx, bucket, object, nil, opts)
    	if gr != nil {
    		gr.Close()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  9. cmd/fmt-gen.go

         {{.Prompt}} {{.HelpName}} http://node{1...32}.example.com/mnt/export{1...32}
    
    `,
    }
    
    func fmtGenMain(ctxt *cli.Context) {
    	deploymentID := ctxt.String("deployment-id")
    	err := buildServerCtxt(ctxt, &globalServerCtxt)
    	if err != nil {
    		log.Fatalln(err)
    	}
    	handleCommonArgs(globalServerCtxt)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  10. cmd/erasure-healing.go

    	healingMetricObject
    	healingMetricCheckAbandonedParts
    )
    
    func (er erasureObjects) listAndHeal(ctx context.Context, bucket, prefix string, scanMode madmin.HealScanMode, healEntry func(string, metaCacheEntry, madmin.HealScanMode) error) error {
    	ctx, cancel := context.WithCancel(ctx)
    	defer cancel()
    
    	disks, _ := er.getOnlineDisksWithHealing(false)
    	if len(disks) == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
Back to top