Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 32 for shale (0.15 sec)

  1. cmd/common-main.go

    	gob.Register(madmin.TimeInfo{})
    	gob.Register(madmin.XFSErrorConfigs{})
    	gob.Register(map[string]string{})
    	gob.Register(map[string]interface{}{})
    
    	// All minio-go and madmin-go API operations shall be performed only once,
    	// another way to look at this is we are turning off retries.
    	minio.MaxRetry = 1
    	madmin.MaxRetry = 1
    
    	currentReleaseTime, _ = GetCurrentReleaseTime()
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat May 04 00:17:57 GMT 2024
    - 35.8K bytes
    - Viewed (2)
  2. src/cmd/asm/internal/asm/parse.go

    			} else {
    				a.Scale = int16(scale)
    			}
    		}
    		p.get(')')
    	} else if scale != 0 {
    		if p.arch.Family == sys.ARM64 {
    			p.errorf("arm64 doesn't support scaled register format")
    		}
    		// First (R) was missing, all we have is (R*scale).
    		a.Reg = 0
    		a.Index = r1
    		a.Scale = int16(scale)
    	}
    }
    
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Wed Feb 21 14:34:57 GMT 2024
    - 36.9K bytes
    - Viewed (0)
  3. cmd/globals.go

    	// GlobalStaleUploadsExpiry - Expiry duration after which the uploads in multipart,
    	// tmp directory are deemed stale.
    	GlobalStaleUploadsExpiry = time.Hour * 24 // 24 hrs.
    
    	// GlobalStaleUploadsCleanupInterval - Cleanup interval when the stale uploads cleanup is initiated.
    	GlobalStaleUploadsCleanupInterval = time.Hour * 6 // 6 hrs.
    
    	// Refresh interval to update in-memory iam config cache.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 16.5K bytes
    - Viewed (0)
  4. cmd/bucket-targets.go

    				sys.hMutex.Unlock()
    			}
    			hcTimer.Reset(defaultHealthCheckDuration)
    		case <-ctx.Done():
    			return
    		}
    	}
    }
    
    // periodically rebuild the healthCheck map from list of targets to clear
    // out stale endpoints
    func (sys *BucketTargetSys) reloadHealthCheckers(ctx context.Context) {
    	m := make(map[string]epHealth)
    	tgts := sys.ListTargets(ctx, "", "")
    	sys.hMutex.Lock()
    	for _, t := range tgts {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  5. internal/s3select/sql/value.go

    const (
    	opPlus     = "+"
    	opMinus    = "-"
    	opDivide   = "/"
    	opMultiply = "*"
    	opModulo   = "%"
    )
    
    // For arithmetic operations, if both values are numeric then the
    // operation shall succeed. If the types are unknown automatic type
    // conversion to a number is attempted.
    func (v *Value) arithOp(op string, a *Value) error {
    	err := inferTypeForArithOp(v)
    	if err != nil {
    		return err
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 25 20:31:19 GMT 2022
    - 20.2K bytes
    - Viewed (0)
  6. cmd/xl-storage-disk-id-check.go

    	done = noopDoneFunc
    	if contextCanceled(ctx) {
    		return ctx, done, ctx.Err()
    	}
    
    	if p.health.status.Load() != diskHealthOK {
    		return ctx, done, errFaultyDisk
    	}
    
    	// Verify if the disk is not stale
    	// - missing format.json (unformatted drive)
    	// - format.json is valid but invalid 'uuid'
    	if err = p.checkDiskStale(); err != nil {
    		return ctx, done, err
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  7. cmd/erasure-healing.go

    	// the disksWithAllParts() returns the actual disks that can be
    	// used here for reconstruction. This is done to ensure that
    	// we do not skip drives that have inconsistent metadata to be
    	// skipped from purging when they are stale.
    	availableDisks, dataErrs, _ := disksWithAllParts(ctx, onlineDisks, partsMetadata,
    		errs, latestMeta, bucket, object, scanMode)
    
    	var erasure Erasure
    	if !latestMeta.Deleted && !latestMeta.IsRemote() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  8. schema/field.go

    			field.Size = -1
    		}
    	}
    
    	if p, ok := field.TagSettings["PRECISION"]; ok {
    		field.Precision, _ = strconv.Atoi(p)
    	}
    
    	if s, ok := field.TagSettings["SCALE"]; ok {
    		field.Scale, _ = strconv.Atoi(s)
    	}
    
    	// default value is function or null or blank (primary keys)
    	field.DefaultValue = strings.TrimSpace(field.DefaultValue)
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Mon Apr 15 03:20:20 GMT 2024
    - 32K bytes
    - Viewed (1)
  9. cmd/http-stats.go

    	hstats.totalS3Requests.Inc(api)
    	code := w.StatusCode
    
    	switch {
    	case code == 0:
    	case code == 499:
    		// 499 is a good error, shall be counted as canceled.
    		hstats.totalS3Canceled.Inc(api)
    	case code >= http.StatusBadRequest:
    		if code >= http.StatusInternalServerError {
    			hstats.totalS35xxErrors.Inc(api)
    		} else {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 11.4K bytes
    - Viewed (0)
  10. cmd/bucket-metadata-sys.go

    	sys.Lock()
    	for _, bucket := range buckets {
    		delete(sys.metadataMap, bucket)
    		globalBucketMonitor.DeleteBucket(bucket)
    	}
    	sys.Unlock()
    }
    
    // RemoveStaleBuckets removes all stale buckets in memory that are not on disk.
    func (sys *BucketMetadataSys) RemoveStaleBuckets(diskBuckets set.StringSet) {
    	sys.Lock()
    	defer sys.Unlock()
    
    	for bucket := range sys.metadataMap {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 19.8K bytes
    - Viewed (0)
Back to top