Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 122 for decode (0.1 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. internal/bucket/lifecycle/noncurrentversion.go

    	}
    	type noncurrentVersionExpirationWrapper NoncurrentVersionExpiration
    	return e.EncodeElement(noncurrentVersionExpirationWrapper(n), start)
    }
    
    // UnmarshalXML decodes NoncurrentVersionExpiration
    func (n *NoncurrentVersionExpiration) UnmarshalXML(d *xml.Decoder, startElement xml.StartElement) error {
    	// To handle xml with MaxNoncurrentVersions from older MinIO releases.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Dec 14 17:41:44 UTC 2021
    - 5.3K bytes
    - Viewed (0)
  6. internal/s3select/json/args.go

    	unmarshaled bool
    }
    
    // IsEmpty - returns whether reader args is empty or not.
    func (args *ReaderArgs) IsEmpty() bool {
    	return !args.unmarshaled
    }
    
    // UnmarshalXML - decodes XML data.
    func (args *ReaderArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    	// Make subtype to avoid recursive UnmarshalXML().
    	type subReaderArgs ReaderArgs
    	parsedArgs := subReaderArgs{}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.7K bytes
    - Viewed (0)
  7. internal/s3select/csv/args.go

    }
    
    // IsEmpty - returns whether reader args is empty or not.
    func (args *ReaderArgs) IsEmpty() bool {
    	return !args.unmarshaled
    }
    
    // UnmarshalXML - decodes XML data.
    func (args *ReaderArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) {
    	args.FileHeaderInfo = none
    	args.RecordDelimiter = defaultRecordDelimiter
    	args.FieldDelimiter = defaultFieldDelimiter
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 5.4K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. internal/bucket/lifecycle/tag.go

    	errDuplicatedXMLTag = Errorf("duplicated XML Tag")
    	errUnknownXMLTag    = Errorf("unknown XML Tag")
    )
    
    // UnmarshalXML - decodes XML data.
    func (tag *Tag) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) {
    	var keyAlreadyParsed, valueAlreadyParsed bool
    	for {
    		// Read tokens from the XML document in a stream.
    		t, err := d.Token()
    		if err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 2.4K bytes
    - Viewed (0)
Back to top