Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for slate (0.13 sec)

  1. cmd/erasure-server-pool.go

    		serverPools[i] = poolAvailableSpace{
    			Index:      i,
    			Available:  available,
    			MaxUsedPct: maxUsedPct,
    		}
    	}
    	return serverPools
    }
    
    // PoolObjInfo represents the state of current object version per pool
    type PoolObjInfo struct {
    	Index   int
    	ObjInfo ObjectInfo
    	Err     error
    }
    
    type poolErrs struct {
    	Index int
    	Err   error
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  2. cmd/api-errors.go

    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrInvalidObjectState: {
    		Code:           "InvalidObjectState",
    		Description:    "The operation is not valid for the current state of the object.",
    		HTTPStatusCode: http.StatusForbidden,
    	},
    	ErrAuthorizationHeaderMalformed: {
    		Code:           "AuthorizationHeaderMalformed",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 91.4K bytes
    - Viewed (7)
  3. cmd/erasure-object.go

    		return objInfo, ObjectNotFound{
    			Bucket: bucket,
    			Object: object,
    		}
    	}
    
    	if opts.DeletePrefix {
    		if opts.Expiration.Expire {
    			// Expire all versions expiration must still verify the state() on disk
    			// via a getObjectInfo() call as follows, any read quorum issues we
    			// must not proceed further for safety reasons. attempt a MRF heal
    			// while we see such quorum errors.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  4. cmd/test-utils_test.go

    }
    
    func resetGlobalEndpoints() {
    	globalEndpoints = EndpointServerPools{}
    }
    
    func resetGlobalIsErasure() {
    	globalIsErasure = false
    }
    
    // reset global heal state
    func resetGlobalHealState() {
    	// Init global heal state
    	if globalAllHealState == nil {
    		globalAllHealState = newHealState(GlobalContext, false)
    	} else {
    		globalAllHealState.Lock()
    		for _, v := range globalAllHealState.healSeqMap {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  5. cmd/peer-rest-server.go

    }
    
    func (s *peerRESTServer) BackgroundHealStatusHandler(_ *grid.MSS) (*grid.JSON[madmin.BgHealState], *grid.RemoteErr) {
    	state, ok := getLocalBackgroundHealStatus(context.Background(), newObjectLayerFn())
    	if !ok {
    		return nil, grid.NewRemoteErr(errServerNotInitialized)
    	}
    	return madminBgHealState.NewJSONWith(&state), nil
    }
    
    // ReloadSiteReplicationConfigHandler - reloads site replication configuration from the disks
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
  6. cmd/batch-handlers.go

    					success = false
    				} else {
    					stopFn(oi, nil)
    				}
    				ri.trackCurrentBucketObject(r.Target.Bucket, oi, success)
    				globalBatchJobsMetrics.save(job.ID, ri)
    				// persist in-memory state to disk after every 10secs.
    				batchLogIf(ctx, ri.updateAfter(ctx, api, 10*time.Second, job))
    
    				if wait := globalBatchConfig.ReplicationWait(); wait > 0 {
    					time.Sleep(wait)
    				}
    			}()
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 55.2K bytes
    - Viewed (0)
Back to top