Search Options

Results per page
Sort
Preferred Languages
Advance

Results 351 - 360 of 1,473 for ERROR (0.03 sec)

  1. cmd/common-main_test.go

    			tmpfile, err := os.CreateTemp("", "testfile")
    			if err != nil {
    				t.Error(err)
    			}
    			tmpfile.WriteString(testCase.content)
    			tmpfile.Sync()
    			tmpfile.Close()
    
    			value, err := readFromSecret(tmpfile.Name())
    			if err != nil && !testCase.expectedErr {
    				t.Error(err)
    			}
    			if err == nil && testCase.expectedErr {
    				t.Error(errors.New("expected error, found success"))
    			}
    			if value != testCase.expectedValue {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.7K bytes
    - Viewed (0)
  2. internal/event/target/amqp.go

    }
    
    func (target *AMQPTarget) channel() (*amqp091.Channel, chan amqp091.Confirmation, error) {
    	var err error
    	var conn *amqp091.Connection
    	var ch *amqp091.Channel
    
    	isAMQPClosedErr := func(err error) bool {
    		if err == amqp091.ErrClosed {
    			return true
    		}
    
    		if nerr, ok := err.(*net.OpError); ok {
    			return (nerr.Err.Error() == "use of closed network connection")
    		}
    
    		return false
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  3. api/go1.22.txt

    pkg archive/tar, method (*Writer) AddFS(fs.FS) error #58000
    pkg archive/zip, method (*Writer) AddFS(fs.FS) error #54898
    pkg cmp, func Or[$0 comparable](...$0) $0 #60204
    pkg crypto/x509, func OIDFromInts([]uint64) (OID, error) #60665
    pkg crypto/x509, method (*CertPool) AddCertWithConstraint(*Certificate, func([]*Certificate) error) #57178
    pkg crypto/x509, method (OID) Equal(OID) bool #60665
    pkg crypto/x509, method (OID) EqualASN1OID(asn1.ObjectIdentifier) bool #60665
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Wed Jan 24 20:54:27 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  4. internal/s3select/message.go

    	207, 151, 211, 146, // message crc.
    }
    
    // newErrorMessage - creates new Request Level Error Message. S3 sends this message if the request failed for any reason.
    // It contains the error code and error message for the failure. If S3 sends a RequestLevelError message,
    // it doesn't send an End message.
    //
    // Header specification:
    // Request-level error messages contain three headers, as follows:
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 30 15:26:43 UTC 2022
    - 15.2K bytes
    - Viewed (0)
  5. cmd/metacache_gen.go

    				return
    			}
    		case "id":
    			z.id, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "id")
    				return
    			}
    		case "err":
    			z.error, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "error")
    				return
    			}
    		case "root":
    			z.root, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "root")
    				return
    			}
    		case "fnf":
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Nov 08 18:26:08 UTC 2021
    - 10K bytes
    - Viewed (0)
  6. cmd/erasure-healing-common.go

    // - disks which have all parts specified in the latest xl.meta.
    //
    //   - slice of errors about the state of data files on disk - can have
    //     a not-found error or a hash-mismatch error.
    func disksWithAllParts(ctx context.Context, onlineDisks []StorageAPI, partsMetadata []FileInfo,
    	errs []error, latestMeta FileInfo, filterByETag bool, bucket, object string,
    	scanMode madmin.HealScanMode,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 01 15:19:10 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  7. internal/lock/lock_nix.go

    // flags and shouldn't be considered as replacement
    // for os.OpenFile().
    func LockedOpenFile(path string, flag int, perm os.FileMode) (*LockedFile, error) {
    	return lockedOpenFile(path, flag, perm, 0)
    }
    
    // Open - Call os.OpenFile
    func Open(path string, flag int, perm os.FileMode) (*os.File, error) {
    	return os.OpenFile(path, flag, perm)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 19 01:35:22 UTC 2021
    - 2.8K bytes
    - Viewed (0)
  8. internal/http/response-recorder.go

    // returns an error if the underlying ResponseWriter does not implement io.ReaderFrom
    func (lrw *ResponseRecorder) ReadFrom(r io.Reader) (int64, error) {
    	if lrw.ReaderFrom != nil {
    		n, err := lrw.ReaderFrom.ReadFrom(r)
    		lrw.bytesWritten += int(n)
    		return n, err
    	}
    	return 0, ErrNotImplemented
    }
    
    func (lrw *ResponseRecorder) Write(p []byte) (int, error) {
    	if !lrw.headersLogged {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  9. cmd/httprange_test.go

    	}
    	for i, urs := range unparsableRangeSpecs {
    		rs, err := parseRequestRangeSpec(urs)
    		if err == nil {
    			t.Errorf("Case %d: Did not get an expected error - got %v", i, rs)
    		}
    		if isErrInvalidRange(err) {
    			t.Errorf("Case %d: Got invalid range error instead of a parse error", i)
    		}
    		if rs != nil {
    			t.Errorf("Case %d: Got non-nil rs though err != nil: %v", i, rs)
    		}
    	}
    
    	invalidRangeSpecs := []string{
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun May 05 16:56:21 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  10. cmd/data-usage-cache_gen.go

    func (z *dataUsageHash) DecodeMsg(dc *msgp.Reader) (err error) {
    	{
    		var zb0001 string
    		zb0001, err = dc.ReadString()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = dataUsageHash(zb0001)
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z dataUsageHash) EncodeMsg(en *msgp.Writer) (err error) {
    	err = en.WriteString(string(z))
    	if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 75K bytes
    - Viewed (0)
Back to top