Search Options

Results per page
Sort
Preferred Languages
Advance

Results 291 - 300 of 1,179 for funcs (0.06 sec)

  1. src/bufio/scan_test.go

    type endlessZeros struct{}
    
    func (endlessZeros) Read(p []byte) (int, error) {
    	return 0, nil
    }
    
    func TestBadReader(t *testing.T) {
    	scanner := NewScanner(endlessZeros{})
    	for scanner.Scan() {
    		t.Fatal("read should fail")
    	}
    	err := scanner.Err()
    	if err != io.ErrNoProgress {
    		t.Errorf("unexpected error: %v", err)
    	}
    }
    
    func TestScanWordsExcessiveWhiteSpace(t *testing.T) {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Sep 22 16:22:42 UTC 2023
    - 14.3K bytes
    - Viewed (0)
  2. internal/grid/benchmark_test.go

    	"time"
    
    	"github.com/minio/minio/internal/logger/target/testlogger"
    )
    
    func BenchmarkRequests(b *testing.B) {
    	for n := 2; n <= 32; n *= 2 {
    		b.Run("servers="+strconv.Itoa(n), func(b *testing.B) {
    			benchmarkGridRequests(b, n)
    		})
    	}
    }
    
    func benchmarkGridRequests(b *testing.B, n int) {
    	defer testlogger.T.SetErrorTB(b)()
    	errFatal := func(err error) {
    		b.Helper()
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  3. cmd/batch-rotate_gen.go

    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z BatchJobKeyRotateEncryption) Msgsize() (s int) {
    	s = 1 + 5 + msgp.StringPrefixSize + len(string(z.Type)) + 4 + msgp.StringPrefixSize + len(z.Key) + 8 + msgp.StringPrefixSize + len(z.Context)
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *BatchJobKeyRotateFlags) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 02 10:51:33 UTC 2023
    - 27.1K bytes
    - Viewed (0)
  4. clause/on_conflict.go

    	Columns      []Column
    	Where        Where
    	TargetWhere  Where
    	OnConstraint string
    	DoNothing    bool
    	DoUpdates    Set
    	UpdateAll    bool
    }
    
    func (OnConflict) Name() string {
    	return "ON CONFLICT"
    }
    
    // Build build onConflict clause
    func (onConflict OnConflict) Build(builder Builder) {
    	if onConflict.OnConstraint != "" {
    		builder.WriteString("ON CONSTRAINT ")
    		builder.WriteString(onConflict.OnConstraint)
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Oct 07 05:46:20 UTC 2022
    - 1.3K bytes
    - Viewed (0)
  5. misc/linkcheck/linkcheck.go

    	}
    	if crawled[url] {
    		return
    	}
    	crawled[url] = true
    
    	wg.Add(1)
    	go func() {
    		urlq <- url
    	}()
    }
    
    func addProblem(url, errmsg string) {
    	msg := fmt.Sprintf("Error on %s: %s (from %s)", url, errmsg, linkSources[url])
    	if *verbose {
    		log.Print(msg)
    	}
    	problems = append(problems, msg)
    }
    
    func crawlLoop() {
    	for url := range urlq {
    		if err := doCrawl(url); err != nil {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 06 15:53:04 UTC 2021
    - 3.9K bytes
    - Viewed (0)
  6. src/archive/tar/writer.go

    	default:
    		return n, nil
    	}
    }
    
    func (fw *regFileWriter) ReadFrom(r io.Reader) (int64, error) {
    	return io.Copy(struct{ io.Writer }{fw}, r)
    }
    
    // logicalRemaining implements fileState.logicalRemaining.
    func (fw regFileWriter) logicalRemaining() int64 {
    	return fw.nb
    }
    
    // physicalRemaining implements fileState.physicalRemaining.
    func (fw regFileWriter) physicalRemaining() int64 {
    	return fw.nb
    }
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 02 14:22:59 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  7. src/bufio/bufio.go

    // size, it returns the underlying [Reader].
    func NewReaderSize(rd io.Reader, size int) *Reader {
    	// Is it already a Reader?
    	b, ok := rd.(*Reader)
    	if ok && len(b.buf) >= size {
    		return b
    	}
    	r := new(Reader)
    	r.reset(make([]byte, max(size, minReadBufferSize)), rd)
    	return r
    }
    
    // NewReader returns a new [Reader] whose buffer has the default size.
    func NewReader(rd io.Reader) *Reader {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 12 14:39:08 UTC 2023
    - 21.8K bytes
    - Viewed (0)
  8. cmd/erasure-decode_test.go

    }
    
    func BenchmarkErasureDecode_4_64KB(b *testing.B) {
    	const size = 64 * 1024
    	b.Run(" 00|00 ", func(b *testing.B) { benchmarkErasureDecode(2, 2, 0, 0, size, b) })
    	b.Run(" 00|X0 ", func(b *testing.B) { benchmarkErasureDecode(2, 2, 0, 1, size, b) })
    	b.Run(" X0|00 ", func(b *testing.B) { benchmarkErasureDecode(2, 2, 1, 0, size, b) })
    	b.Run(" X0|X0 ", func(b *testing.B) { benchmarkErasureDecode(2, 2, 1, 1, size, b) })
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  9. cmd/prepare-storage.go

    	"github.com/dustin/go-humanize"
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/logger"
    )
    
    var printEndpointError = func() func(Endpoint, error, bool) {
    	var mutex sync.Mutex
    	printOnce := make(map[Endpoint]map[string]int)
    
    	return func(endpoint Endpoint, err error, once bool) {
    		reqInfo := (&logger.ReqInfo{}).AppendTags("endpoint", endpoint.String())
    		ctx := logger.SetReqInfo(GlobalContext, reqInfo)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  10. internal/jwt/parser.go

    // If nil an empty string will be returned.
    func (c *MapClaims) GetAccessKey() string {
    	if c == nil {
    		return ""
    	}
    	return c.AccessKey
    }
    
    // NewStandardClaims - initializes standard claims
    func NewStandardClaims() *StandardClaims {
    	return &StandardClaims{}
    }
    
    // SetIssuer sets issuer for these claims
    func (c *StandardClaims) SetIssuer(issuer string) {
    	c.Issuer = issuer
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 14.1K bytes
    - Viewed (0)
Back to top