Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 31 for caps (0.14 sec)

  1. cmd/tier.go

    func (config *TierConfigMgr) Add(ctx context.Context, tier madmin.TierConfig, ignoreInUse bool) error {
    	config.Lock()
    	defer config.Unlock()
    
    	// check if tier name is in all caps
    	tierName := tier.Name
    	if tierName != strings.ToUpper(tierName) {
    		return errTierNameNotUppercase
    	}
    
    	// check if tier name already in use
    	if _, exists := config.isTierNameInUse(tierName); exists {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  2. internal/grid/types.go

    			PutByteBuffer(*b)
    		}
    		*b = nil
    		return bytes, nil
    	}
    	val, bytes, err := msgp.ReadBytesZC(bytes)
    	if err != nil {
    		return bytes, err
    	}
    	if cap(*b) >= len(val) {
    		*b = (*b)[:len(val)]
    		copy(*b, val)
    	} else {
    		if cap(*b) == 0 && len(val) <= maxBufferSize {
    			*b = GetByteBufferCap(len(val))
    		} else {
    			PutByteBuffer(*b)
    			*b = make([]byte, 0, len(val))
    		}
    		in := *b
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 01 23:42:09 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  3. helm/minio/README.md

    Then install the chart, specifying that you want to use the TLS secret:
    
    ```bash
    helm install --set tls.enabled=true,tls.certSecret=tls-ssl-minio minio/minio
    ```
    
    ### Installing certificates from third party CAs
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 24 07:27:57 GMT 2024
    - 10.9K bytes
    - Viewed (0)
  4. internal/rest/client.go

    func exponentialBackoffWait(r *rand.Rand, unit, cap time.Duration) func(uint) time.Duration {
    	if unit > time.Hour {
    		// Protect against integer overflow
    		panic("unit cannot exceed one hour")
    	}
    	return func(attempt uint) time.Duration {
    		if attempt > 16 {
    			// Protect against integer overflow
    			attempt = 16
    		}
    		// sleep = random_between(unit, min(cap, base * 2 ** attempt))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 14.4K bytes
    - Viewed (0)
  5. internal/grid/muxclient.go

    	}
    	m.respWait = responses // Route directly to output.
    	m.respMu.Unlock()
    
    	// Try to grab an initial block.
    	m.singleResp = false
    	m.RecvSeq = m.SendSeq // Sync
    	if cap(requests) > 0 {
    		m.outBlock = make(chan struct{}, cap(requests))
    	}
    	msg := message{
    		Op:         OpConnectMux,
    		Handler:    h,
    		Payload:    payload,
    		DeadlineMS: uint32(m.deadline.Milliseconds()),
    	}
    	msg.setZeroPayloadFlag()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.2K bytes
    - Viewed (0)
  6. cmd/handler-utils.go

    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/minio/internal/mcontext"
    	xnet "github.com/minio/pkg/v2/net"
    	"golang.org/x/exp/maps"
    	"golang.org/x/exp/slices"
    )
    
    const (
    	copyDirective    = "COPY"
    	replaceDirective = "REPLACE"
    	accessDirective  = "ACCESS"
    )
    
    // Parses location constraint from the incoming reader.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.5K bytes
    - Viewed (3)
  7. cmd/common-main.go

    	if err != nil {
    		return nil, nil, false, err
    	}
    	for _, file := range files {
    		// Ignore all
    		// - regular files
    		// - "CAs" directory
    		// - any directory which starts with ".."
    		if file.Mode().IsRegular() || file.Name() == "CAs" || strings.HasPrefix(file.Name(), "..") {
    			continue
    		}
    		if file.Mode()&os.ModeSymlink == os.ModeSymlink {
    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)
  8. cmd/storage-datatypes.go

    }
    
    // Recycle will reuse the memory allocated for the FileInfo data.
    func (r *RenameDataInlineHandlerParams) Recycle() {
    	if r == nil {
    		return
    	}
    	if cap(r.FI.Data) >= xioutil.SmallBlock {
    		grid.PutByteBuffer(r.FI.Data)
    		r.FI.Data = nil
    	}
    }
    
    // RenameFileHandlerParams are parameters for RenameFileHandler.
    type RenameFileHandlerParams struct {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 15.3K bytes
    - Viewed (0)
  9. cmd/streaming-signature-v4.go

    	if err == io.EOF {
    		err = io.ErrUnexpectedEOF
    	}
    	if err != nil {
    		cr.err = err
    		return n, cr.err
    	}
    	if b != '\n' {
    		cr.err = errMalformedEncoding
    		return n, cr.err
    	}
    
    	if cap(cr.buffer) < size {
    		cr.buffer = make([]byte, size)
    	} else {
    		cr.buffer = cr.buffer[:size]
    	}
    
    	// Now, we read the payload and compute its SHA-256 hash.
    	_, err = io.ReadFull(cr.reader, cr.buffer)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 18.2K bytes
    - Viewed (0)
  10. internal/grid/grid_test.go

    			close(nowBlocking)
    			// Block until test is done.
    			<-stopBlocking
    			return nil
    		})
    	}()
    
    	<-nowBlocking
    	// Wait for the receiver channel to fill.
    	for len(st.responses) != cap(st.responses) {
    		time.Sleep(time.Millisecond)
    	}
    	cancel()
    	<-serverCanceled
    	local.debugMsg(debugIsOutgoingClosed, st.muxID, func(closed bool) {
    		if !closed {
    			t.Error("expected outgoing closed")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 30 15:03:35 GMT 2024
    - 30.1K bytes
    - Viewed (0)
Back to top