Search Options

Results per page
Sort
Preferred Languages
Advance

Results 191 - 200 of 230 for decode (0.09 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. internal/bucket/replication/rule.go

    		return errDeleteReplicationMissing
    	}
    	if d.Status != Disabled && d.Status != Enabled {
    		return errInvalidDeleteReplicationStatus
    	}
    	return nil
    }
    
    // UnmarshalXML - decodes XML data.
    func (d *DeleteReplication) UnmarshalXML(dec *xml.Decoder, start xml.StartElement) (err error) {
    	// Make subtype to avoid recursive UnmarshalXML().
    	type deleteReplication DeleteReplication
    	drep := deleteReplication{}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jan 24 23:22:20 UTC 2022
    - 8.3K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  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/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