Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 291 - 300 of 505 for cdone (0.02 seconds)

  1. cmd/untar.go

    				return err
    			}
    			wg.Add(1)
    			go func(name string, fi fs.FileInfo, b []byte) {
    				rc := disconnectReader{r: bytes.NewReader(b)}
    				defer func() {
    					rc.Close()
    					<-asyncWriters
    					wg.Done()
    					xioutil.ODirectPoolMedium.Put(bufp)
    				}()
    				if err := putObject(&rc, fi, name); err != nil {
    					if o.ignoreErrs {
    						s3LogIf(ctx, err)
    						return
    					}
    					asyncErrMu.Lock()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 6K bytes
    - Click Count (2)
  2. cmd/leak-detect_test.go

    	initialStackSnapShot := NewLeakDetect()
    	return func() {
    		initialStackSnapShot.DetectLeak(t)
    	}
    }
    
    // list of functions to be ignored from the stack trace.
    // Leak detection is done when tests are run, should ignore the tests related functions,
    // and other runtime functions while identifying leaks.
    var ignoredStackFns = []string{
    	"",
    	// Below are the stacks ignored by the upstream leaktest code.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 5.2K bytes
    - Click Count (0)
  3. docs/erasure/README.md

    protect against two drive failure whereas in MinIO erasure code you can lose as many as half of drives and still the data remains safe. Further, MinIO's erasure code is at the object level and can heal one object at a time. For RAID, healing can be done only at the volume level which translates into high downtime. As MinIO encodes each object individually, it can heal objects incrementally. Storage servers once deployed should not require drive replacement or healing for the lifetime of the server....
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  4. internal/bucket/bandwidth/monitor.go

    			}
    		}
    		m.tlock.RUnlock()
    	}
    	return report
    }
    
    func (m *Monitor) trackEWMA() {
    	for {
    		select {
    		case <-m.bucketMovingAvgTicker.C:
    			m.updateMovingAvg()
    		case <-m.ctx.Done():
    			return
    		}
    	}
    }
    
    func (m *Monitor) updateMovingAvg() {
    	m.mlock.Lock()
    	defer m.mlock.Unlock()
    	for _, bucketMeasurement := range m.bucketsMeasurement {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 6K bytes
    - Click Count (0)
  5. internal/s3select/simdj/reader.go

    	}
    	r.onReaderExit = func() {
    		close(r.decoded)
    		readCloser.Close()
    		for range r.input {
    			// Read until EOF trickles through.
    			// Otherwise, we risk the decoder hanging.
    		}
    		r.readerWg.Done()
    	}
    
    	// We cannot reuse as we are sending parsed objects elsewhere.
    	simdjson.ParseNDStream(readCloser, r.input, nil)
    	r.readerWg.Add(1)
    	go r.startReader()
    	return &r
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 30 17:02:22 GMT 2023
    - 4.9K bytes
    - Click Count (0)
  6. api/go1.7.txt

    pkg context, func WithValue(Context, interface{}, interface{}) Context
    pkg context, type CancelFunc func()
    pkg context, type Context interface { Deadline, Done, Err, Value }
    pkg context, type Context interface, Deadline() (time.Time, bool)
    pkg context, type Context interface, Done() <-chan struct
    pkg context, type Context interface, Err() error
    pkg context, type Context interface, Value(interface{}) interface{}
    pkg context, var Canceled error
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Jun 28 15:08:11 GMT 2016
    - 13.6K bytes
    - Click Count (0)
  7. ci/official/utilities/setup_macos.sh

      else
        echo "pyenv is not managed by homebrew. Installing it via github..."
        # On "ventura" VMs, pyenv is not managed by Homebrew. Install the latest
        # pyenv from github.
        rm -rf "$PYENV_ROOT"
        git clone https://github.com/pyenv/pyenv.git "$PYENV_ROOT"
      fi
      echo "Upgraded pyenv version: $(pyenv --version)"
    fi
    
    # Scheduled nightly and release builds upload build artifacts (Pip packages,
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Mon Oct 06 22:42:26 GMT 2025
    - 6.8K bytes
    - Click Count (0)
  8. cmd/bucket-policy.go

    		"versionid":        {vid},
    		"signatureversion": {signatureVersion},
    		"authType":         {authtype},
    	}
    
    	if lc != "" {
    		args["LocationConstraint"] = []string{lc}
    	}
    
    	cloneHeader := r.Header.Clone()
    	if v := cloneHeader.Get("x-amz-signature-age"); v != "" {
    		args["signatureAge"] = []string{v}
    		cloneHeader.Del("x-amz-signature-age")
    	}
    
    	if userTags := cloneHeader.Get(xhttp.AmzObjectTagging); userTags != "" {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 7.9K bytes
    - Click Count (0)
  9. cmd/admin-handlers-idp-openid.go

    		listServiceAccounts = true
    	default:
    		err := errors.New("invalid list type")
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErrWithErr(ErrInvalidRequest, err), r.URL)
    		return
    	}
    
    	s := globalServerConfig.Clone()
    	roleArnMap := make(map[string]string)
    	// Map of configs to a map of users to their access keys
    	cfgToUsersMap := make(map[string]map[string]madmin.OpenIDUserAccessKeys)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sat Sep 06 17:38:46 GMT 2025
    - 7.6K bytes
    - Click Count (0)
  10. cmd/object-api-datatypes.go

    		if err != nil {
    			encLogIf(GlobalContext, err)
    			return nil
    		}
    		data = decrypted
    	}
    	return data
    }
    
    // Clone - Returns a cloned copy of current objectInfo
    func (o *ObjectInfo) Clone() (cinfo ObjectInfo) {
    	cinfo = ObjectInfo{
    		Bucket:                     o.Bucket,
    		Name:                       o.Name,
    		ModTime:                    o.ModTime,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 21.2K bytes
    - Click Count (0)
Back to Top