Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 187 for reader_r (0.17 sec)

  1. internal/config/identity/openid/jwt.go

    	"github.com/minio/pkg/v3/policy"
    )
    
    type publicKeys struct {
    	*sync.RWMutex
    
    	// map of kid to public key
    	pkMap map[string]interface{}
    }
    
    func (pk *publicKeys) parseAndAdd(b io.Reader) error {
    	var jwk JWKS
    	err := json.NewDecoder(b).Decode(&jwk)
    	if err != nil {
    		return err
    	}
    
    	for _, key := range jwk.Keys {
    		pkey, err := key.DecodePublicKey()
    		if err != nil {
    			return err
    		}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 02:46:36 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  2. src/bytes/buffer.go

    )
    
    // ErrTooLarge is passed to panic if memory cannot be allocated to store data in a buffer.
    var ErrTooLarge = errors.New("bytes.Buffer: too large")
    var errNegativeRead = errors.New("bytes.Buffer: reader returned negative count from Read")
    
    const maxInt = int(^uint(0) >> 1)
    
    // Bytes returns a slice of length b.Len() holding the unread portion of the buffer.
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Tue Jul 16 18:17:37 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  3. cmd/data-usage-cache.go

    		d.replaceHashed(dataUsageHash(key), &eHash, existing)
    	}
    }
    
    type objectIO interface {
    	GetObjectNInfo(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, h http.Header, opts ObjectOptions) (reader *GetObjectReader, err error)
    	PutObject(ctx context.Context, bucket, object string, data *PutObjReader, opts ObjectOptions) (objInfo ObjectInfo, err error)
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  4. cmd/auth-handler.go

    	}
    
    	// Verify 'Content-Md5' and/or 'X-Amz-Content-Sha256' if present.
    	// The verification happens implicit during reading.
    	reader, err := hash.NewReader(ctx, r.Body, -1, clientETag.String(), hex.EncodeToString(contentSHA256), -1)
    	if err != nil {
    		return toAPIErrorCode(ctx, err)
    	}
    	r.Body = reader
    	return ErrNone
    }
    
    // List of all support S3 auth types.
    var supportedS3AuthTypes = map[authType]struct{}{
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  5. src/archive/tar/strconv.go

    func (f *formatter) formatString(b []byte, s string) {
    	if len(s) > len(b) {
    		f.err = ErrFieldTooLong
    	}
    	copy(b, s)
    	if len(s) < len(b) {
    		b[len(s)] = 0
    	}
    
    	// Some buggy readers treat regular files with a trailing slash
    	// in the V7 path field as a directory even though the full path
    	// recorded elsewhere (e.g., via PAX record) contains no trailing slash.
    	if len(s) > len(b) && b[len(b)-1] == '/' {
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Tue Aug 01 14:28:42 UTC 2023
    - 9K bytes
    - Viewed (0)
  6. src/archive/zip/struct.go

    	Comment string
    
    	// NonUTF8 indicates that Name and Comment are not encoded in UTF-8.
    	//
    	// By specification, the only other encoding permitted should be CP-437,
    	// but historically many ZIP readers interpret Name and Comment as whatever
    	// the system's local character encoding happens to be.
    	//
    	// This flag should only be set if the user intends to encode a non-portable
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Tue May 28 21:41:09 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  7. cmd/test-utils_test.go

    	var priv interface{}
    	var err error
    	priv, err = rsa.GenerateKey(crand.Reader, rsaBits)
    	if err != nil {
    		return nil, nil, fmt.Errorf("failed to generate private key: %w", err)
    	}
    
    	notBefore := time.Now()
    	notAfter := notBefore.Add(validFor)
    
    	serialNumberLimit := new(big.Int).Lsh(big.NewInt(1), 128)
    	serialNumber, err := crand.Int(crand.Reader, serialNumberLimit)
    	if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  8. cmd/erasure-multipart.go

    	if !opts.NoAuditLog {
    		auditObjectErasureSet(ctx, "PutObjectPart", object, &er)
    	}
    
    	data := r.Reader
    	// Validate input data size and it can never be less than zero.
    	if data.Size() < -1 {
    		bugLogIf(ctx, errInvalidArgument, logger.ErrorKind)
    		return pi, toObjectErr(errInvalidArgument)
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  9. cmd/bucket-replication.go

    	}
    	closeReader := func() { obj.Close() }
    	reader, err := fn(obj, h, closeReader)
    	if err != nil {
    		return nil, proxy, err
    	}
    	reader.ObjInfo = oi.Clone()
    	if rs != nil {
    		contentSize, err := parseSizeFromContentRange(h)
    		if err != nil {
    			return nil, proxy, err
    		}
    		reader.ObjInfo.Size = contentSize
    	}
    
    	return reader, proxyResult{Proxy: true}, nil
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  10. src/cmd/asm/internal/lex/input.go

    	"fmt"
    	"os"
    	"path/filepath"
    	"slices"
    	"strconv"
    	"strings"
    	"text/scanner"
    
    	"cmd/asm/internal/flags"
    	"cmd/internal/objabi"
    	"cmd/internal/src"
    )
    
    // Input is the main input: a stack of readers and some macro definitions.
    // It also handles #include processing (by pushing onto the input stack)
    // and parses and instantiates macro definitions.
    type Input struct {
    	Stack
    	includes        []string
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Fri Sep 06 13:17:27 UTC 2024
    - 12.5K bytes
    - Viewed (0)
Back to top