Search Options

Results per page
Sort
Preferred Languages
Advance

Results 701 - 710 of 922 for err (0.4 sec)

  1. internal/crypto/header_test.go

    	var zeroKey [32]byte
    	for i, test := range ssecParseTests {
    		key, err := SSEC.ParseHTTP(test.Header)
    		if err != test.ExpectedErr {
    			t.Errorf("Test %d: want error '%v' but got '%v'", i, test.ExpectedErr, err)
    		}
    
    		if err != nil && key != zeroKey {
    			t.Errorf("Test %d: parsing failed and client key is not zero key", i)
    		}
    		if err == nil && key == zeroKey {
    			t.Errorf("Test %d: parsed client key is zero key", i)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Jul 13 14:52:15 UTC 2022
    - 21.4K bytes
    - Viewed (0)
  2. internal/s3select/jstream/scanner_test.go

    		}
    	})
    }
    
    func benchmarkBufioReader(b []byte) {
    	br := bufio.NewReader(bytes.NewReader(b))
    loop:
    	for {
    		_, err := br.ReadByte()
    		switch err {
    		case nil:
    			continue loop
    		case io.EOF:
    			break loop
    		default:
    			panic(err)
    		}
    	}
    }
    
    func BenchmarkScanner(b *testing.B) {
    	b.Run("small", func(b *testing.B) {
    		for b.Loop() {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.1K bytes
    - Viewed (0)
  3. internal/event/target/kafka_scram_client_contrib.go

    // SASLprep fails, the method returns an error.
    func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error) {
    	x.Client, err = x.NewClient(userName, password, authzID)
    	if err != nil {
    		return err
    	}
    	x.ClientConversation = x.NewConversation()
    	return nil
    }
    
    // Step takes a string provided from a server (or just an empty string for the
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 3.2K bytes
    - Viewed (0)
  4. src/cmd/asm/internal/asm/expr_test.go

    func TestBadExpr(t *testing.T) {
    	for i, test := range badExprTests {
    		err := runBadTest(i, test, t)
    		if err == nil {
    			if test.error != "" {
    				t.Errorf("#%d: %q: expected error %q; got none", i, test.input, test.error)
    			}
    			continue
    		}
    		if !strings.Contains(err.Error(), test.error) {
    			t.Errorf("#%d: expected error %q; got %q", i, test.error, err)
    			continue
    		}
    	}
    }
    
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Tue Aug 29 07:48:38 UTC 2023
    - 3.2K bytes
    - Viewed (0)
  5. scan.go

    				}
    				db.scanIntoStruct(rows, reflectValue, values, fields, joinFields)
    			}
    		default:
    			db.AddError(rows.Scan(dest))
    		}
    	}
    
    	if err := rows.Err(); err != nil && err != db.Error {
    		db.AddError(err)
    	}
    
    	if db.RowsAffected == 0 && db.Statement.RaiseErrorOnNotFound && db.Error == nil {
    		db.AddError(ErrRecordNotFound)
    	}
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Sun May 25 07:40:40 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  6. internal/grid/msg.go

    func (m *message) parse(b []byte) (*subHandlerID, []byte, error) {
    	var sub *subHandlerID
    	if m.Payload == nil {
    		m.Payload = GetByteBuffer()[:0]
    	}
    	h, err := m.UnmarshalMsg(b)
    	if err != nil {
    		return nil, nil, fmt.Errorf("read write: %v", err)
    	}
    	if len(m.Payload) == 0 && m.Flags&FlagPayloadIsZero == 0 {
    		PutByteBuffer(m.Payload)
    		m.Payload = nil
    	}
    	if m.Flags&FlagCRCxxh3 != 0 {
    		const hashLen = 4
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Jul 25 21:07:21 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  7. internal/amztime/iso8601_time.go

    }
    
    // ISO8601Parse parses ISO8601 date string
    func ISO8601Parse(iso8601 string) (t time.Time, err error) {
    	for _, layout := range []string{
    		iso8601TimeFormat,
    		iso8601TimeFormatLong,
    		time.RFC3339,
    	} {
    		t, err = time.Parse(layout, iso8601)
    		if err == nil {
    			return t, nil
    		}
    	}
    
    	return t, err
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Jan 16 23:38:33 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  8. callbacks/delete.go

    		checkMissingWhereConditions(db)
    
    		if !db.DryRun && db.Error == nil {
    			ok, mode := hasReturning(db, supportReturning)
    			if !ok {
    				result, err := db.Statement.ConnPool.ExecContext(db.Statement.Context, db.Statement.SQL.String(), db.Statement.Vars...)
    
    				if db.AddError(err) == nil {
    					db.RowsAffected, _ = result.RowsAffected()
    
    					if db.Statement.Result != nil {
    						db.Statement.Result.Result = result
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Sun May 25 07:40:40 UTC 2025
    - 5.8K bytes
    - Viewed (0)
  9. internal/etag/reader.go

    func (r *Reader) Read(p []byte) (int, error) {
    	n, err := r.src.Read(p)
    	r.readN += int64(n)
    	r.md5.Write(p[:n])
    
    	if err == io.EOF && len(r.checksum) != 0 {
    		if etag := r.ETag(); !Equal(etag, r.checksum) {
    			return n, VerifyError{
    				Expected: r.checksum,
    				Computed: etag,
    			}
    		}
    	}
    	return n, err
    }
    
    // ETag returns the ETag of all the content read
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  10. internal/bucket/replication/error.go

    // parsing.
    type Error struct {
    	err error
    }
    
    // Errorf - formats according to a format specifier and returns
    // the string as a value that satisfies error of type tagging.Error
    func Errorf(format string, a ...any) error {
    	return Error{err: fmt.Errorf(format, a...)}
    }
    
    // Unwrap the internal error.
    func (e Error) Unwrap() error { return e.err }
    
    // Error 'error' compatible method.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 1.3K bytes
    - Viewed (0)
Back to top