Search Options

Results per page
Sort
Preferred Languages
Advance

Results 331 - 340 of 355 for Uint64N (0.04 sec)

  1. cmd/object-handlers.go

    	}
    
    	actualSize, err := objInfo.GetActualSize()
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	objectRSC := s3select.NewObjectReadSeekCloser(
    		func(offset int64) (io.ReadCloser, error) {
    			rs := &HTTPRangeSpec{
    				IsSuffixLength: false,
    				Start:          offset,
    				End:            -1,
    			}
    			opts.NoLock = true
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 120.6K bytes
    - Viewed (0)
  2. association.go

    			}
    		}
    	}
    
    	return association.Error
    }
    
    func (association *Association) Clear() error {
    	return association.Replace()
    }
    
    func (association *Association) Count() (count int64) {
    	if association.Error == nil {
    		association.Error = association.buildCondition().Count(&count).Error
    	}
    	return
    }
    
    type assignBack struct {
    	Source reflect.Value
    	Index  int
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Wed Jun 12 10:49:45 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  3. docs/debugging/xl-meta/main.go

    		}
    		if len(files) > 1 || strings.HasSuffix(files[0], ".zip") {
    			ndjson = true
    		}
    
    		toPrint := make([]string, 0, 16)
    		for _, file := range files {
    			var r io.Reader
    			var sz int64
    			switch file {
    			case "-":
    				r = os.Stdin
    			default:
    				f, err := os.Open(file)
    				if err != nil {
    					return err
    				}
    				if st, err := f.Stat(); err == nil {
    					sz = st.Size()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 40.3K bytes
    - Viewed (0)
  4. cmd/common-main.go

    			fmt.Scanln()
    			os.Exit(1)
    		}
    	}
    
    	logger.Init(GOPATH, GOROOT)
    	logger.RegisterError(config.FmtError)
    
    	t, _ := minioVersionToReleaseTime(Version)
    	if !t.IsZero() {
    		globalVersionUnix = uint64(t.Unix())
    	}
    
    	globalIsCICD = env.Get("MINIO_CI_CD", "") != "" || env.Get("CI", "") != ""
    
    	console.SetColor("Debug", fcolor.New())
    
    	gob.Register(StorageErr(""))
    	gob.Register(madmin.TimeInfo{})
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 32.5K bytes
    - Viewed (3)
  5. cmd/bucket-replication-handlers.go

    				ReplicationValidityCheck: true, // set this to validate the replication config
    			},
    		}
    		obj := path.Join(minioReservedBucket, globalLocalNodeNameHex, "deleteme")
    		ui, err := c.PutObject(ctx, clnt.Bucket, obj, reader, int64(len(buf)), "", "", putOpts)
    		if err != nil && !isReplicationPermissionCheck(ErrorRespToObjectError(err, bucket, obj)) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  6. src/cmd/cgo/doc.go

    # C references to Go
    
    Go functions can be exported for use by C code in the following way:
    
    	//export MyFunction
    	func MyFunction(arg1, arg2 int, arg3 string) int64 {...}
    
    	//export MyFunction2
    	func MyFunction2(arg1, arg2 int, arg3 string) (int64, *C.char) {...}
    
    They will be available in the C code as:
    
    	extern GoInt64 MyFunction(int arg1, int arg2, GoString arg3);
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Wed Dec 11 23:57:34 UTC 2024
    - 44K bytes
    - Viewed (0)
  7. cmd/storage-datatypes_gen.go

    				return
    			}
    			if z.APICalls == nil {
    				z.APICalls = make(map[string]uint64, zb0003)
    			} else if len(z.APICalls) > 0 {
    				for key := range z.APICalls {
    					delete(z.APICalls, key)
    				}
    			}
    			for zb0003 > 0 {
    				zb0003--
    				var za0003 string
    				var za0004 uint64
    				za0003, err = dc.ReadString()
    				if err != nil {
    					err = msgp.WrapError(err, "APICalls")
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 152K bytes
    - Viewed (0)
  8. cmd/notification.go

    	if len(sys.peerClients) == 0 {
    		return nil
    	}
    	peerClients := sys.allPeerClients
    	if len(peerClients) == 0 {
    		return nil
    	}
    	idx := xxhash.Sum64String(s) % uint64(len(peerClients))
    	return peerClients[idx]
    }
    
    // GetPeerOnlineCount gets the count of online and offline nodes.
    func (sys *NotificationSys) GetPeerOnlineCount() (nodesOnline, nodesOffline int) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.9K bytes
    - Viewed (0)
  9. cmd/peer-rest-server.go

    	connectTime := time.Now()
    	ctx := newContext(r, w, "DevNull")
    	for {
    		n, err := io.CopyN(xioutil.Discard, r.Body, 128*humanize.KiByte)
    		atomic.AddUint64(&globalNetPerfRX.RX, uint64(n))
    		if err != nil && err != io.EOF {
    			// If there is a disconnection before globalNetPerfMinDuration (we give a margin of error of 1 sec)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 53.4K bytes
    - Viewed (0)
  10. cmd/iam-store.go

    		if err2 != nil {
    			// Just return the first error.
    			return err
    		}
    		d.Policy = doc.Policy
    		return nil
    	}
    	*d = doc
    	return nil
    }
    
    // key options
    type options struct {
    	ttl int64 // expiry in seconds
    }
    
    type iamWatchEvent struct {
    	isCreated bool // !isCreated implies a delete event.
    	keyPath   string
    }
    
    // iamCache contains in-memory cache of IAM data.
    type iamCache struct {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 86.7K bytes
    - Viewed (0)
Back to top