Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 71 for decode (0.1 sec)

  1. cmd/encryption-v1.go

    		mac := hmac.New(sha256.New, key)
    		mac.Write([]byte(baseKey))
    		return sio.DecryptBuffer(nil, input, sio.Config{Key: mac.Sum(nil), CipherSuites: fips.DARECiphers()})
    	}
    }
    
    // decryptChecksums will attempt to decode checksums and return it/them if set.
    // if part > 0, and we have the checksum for the part that will be returned.
    func (o *ObjectInfo) decryptPartsChecksums(h http.Header) {
    	data := o.Checksum
    	if len(data) == 0 {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 06:56:12 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  2. cmd/storage-rest-server.go

    	if err != nil {
    		s.writeErrorResponse(w, err)
    		return
    	}
    
    	versions := make([]FileInfoVersions, totalVersions)
    	decoder := msgpNewReader(r.Body)
    	defer readMsgpReaderPoolPut(decoder)
    	for i := 0; i < totalVersions; i++ {
    		dst := &versions[i]
    		if err := dst.DecodeMsg(decoder); err != nil {
    			s.writeErrorResponse(w, err)
    			return
    		}
    	}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 44.8K bytes
    - Viewed (0)
  3. cmd/xl-storage-format-v2.go

    		return 0
    	}
    	var sameDataDirCount int
    	var decoded xlMetaDataDirDecoder
    	for _, version := range x.versions {
    		if version.header.Type != ObjectType || version.header.VersionID == versionID || !version.header.UsesDataDir() {
    			continue
    		}
    		_, err := decoded.UnmarshalMsg(version.meta)
    		if err != nil || decoded.ObjectV2 == nil || decoded.ObjectV2.DataDir != dataDir {
    			continue
    		}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 29 19:14:09 UTC 2024
    - 63.6K bytes
    - Viewed (0)
  4. cmd/bucket-lifecycle.go

    func (sp *SelectParameters) IsEmpty() bool {
    	return sp == nil
    }
    
    var selectParamsXMLName = "SelectParameters"
    
    // UnmarshalXML - decodes XML data.
    func (sp *SelectParameters) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    	// Essentially the same as S3Select barring the xml name.
    	if start.Name.Local == selectParamsXMLName {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  5. cmd/peer-rest-server.go

    	for {
    		select {
    		case <-ctx.Done():
    			grid.PutByteBuffer(buf.Bytes())
    			return nil
    		case ev := <-ch:
    			buf.Reset()
    			tmpEvt.Records[0] = ev
    			if err := enc.Encode(tmpEvt); err != nil {
    				peersLogOnceIf(ctx, err, "event: Encode failed")
    				continue
    			}
    			out <- grid.NewBytesWithCopyOf(buf.Bytes())
    		}
    	}
    }
    
    // TraceHandler sends http trace messages back to peer rest client
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 52.1K bytes
    - Viewed (0)
  6. cmd/bucket-handlers.go

    		v.Add("key", objInfo.Name)
    		v.Add("etag", "\""+objInfo.ETag+"\"")
    		redirectURL.RawQuery = v.Encode()
    		writeRedirectSeeOther(w, redirectURL.String())
    		return
    	}
    
    	// Add checksum header.
    	if checksum != nil && checksum.Valid() {
    		hash.AddChecksumHeader(w, checksum.AsMap())
    	}
    
    	// Decide what http response to send depending on success_action_status parameter
    	switch successStatus {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 14 13:28:35 UTC 2024
    - 61.2K bytes
    - Viewed (0)
  7. cmd/erasure-object.go

    				checksumInfo.Algorithm, checksumInfo.Hash, erasure.ShardSize())
    
    			// Prefer local disks
    			prefer[index] = disk.Hostname() == ""
    		}
    
    		written, err := erasure.Decode(ctx, writer, readers, partOffset, partLength, partSize, prefer)
    		// Note: we should not be defer'ing the following closeBitrotReaders() call as
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 78.6K bytes
    - Viewed (0)
  8. internal/bucket/lifecycle/expiration.go

    	if !b.set {
    		return nil
    	}
    	return e.EncodeElement(b.val, startElement)
    }
    
    // UnmarshalXML decodes delete marker boolean from the XML form.
    func (b *Boolean) UnmarshalXML(d *xml.Decoder, startElement xml.StartElement) error {
    	var exp bool
    	err := d.DecodeElement(&exp, &startElement)
    	if err != nil {
    		return err
    	}
    	b.val = exp
    	b.set = true
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed Feb 21 20:28:34 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  9. cmd/erasure-encode.go

    	return fmt.Errorf("%w (offline-disks=%d/%d)", writeErr, countErrs(p.errs, errDiskNotFound), len(p.writers))
    }
    
    // Encode reads from the reader, erasure-encodes the data and writes to the writers.
    func (e *Erasure) Encode(ctx context.Context, src io.Reader, writers []io.Writer, buf []byte, quorum int) (total int64, err error) {
    	writer := &multiWriter{
    		writers:     writers,
    		writeQuorum: quorum,
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  10. internal/bucket/lifecycle/lifecycle_test.go

    				set:                     true,
    			},
    		},
    	}
    	for i, tc := range testCases {
    		var got NoncurrentVersionExpiration
    		dec := xml.NewDecoder(strings.NewReader(tc.xml))
    		if err := dec.Decode(&got); err != nil || got != tc.expected {
    			if err != nil {
    				t.Fatalf("%d: Failed to unmarshal xml %v", i+1, err)
    			}
    			t.Fatalf("%d: Expected %v but got %v", i+1, tc.expected, got)
    		}
    	}
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 23 01:12:48 UTC 2024
    - 55.1K bytes
    - Viewed (0)
Back to top