Search Options

Results per page
Sort
Preferred Languages
Advance

Results 641 - 650 of 859 for err (0.02 sec)

  1. internal/crypto/key.go

    	if random == nil {
    		random = rand.Reader
    	}
    	if len(extKey) != 32 { // safety check
    		logger.CriticalIf(context.Background(), errors.New("crypto: invalid key length"))
    	}
    	var nonce [32]byte
    	if _, err := io.ReadFull(random, nonce[:]); err != nil {
    		logger.CriticalIf(context.Background(), errOutOfEntropy)
    	}
    
    	const Context = "object-encryption-key generation"
    	mac := hmac.New(sha256.New, extKey)
    	mac.Write([]byte(Context))
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Mar 19 20:28:10 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  2. src/cmd/asm/internal/lex/input.go

    	}
    	name, err := strconv.Unquote(in.Stack.Text())
    	if err != nil {
    		in.Error("unquoting include file name: ", err)
    	}
    	in.expectNewline("#include")
    	// Push tokenizer for file onto stack.
    	fd, err := os.Open(name)
    	if err != nil {
    		for _, dir := range in.includes {
    			fd, err = os.Open(filepath.Join(dir, name))
    			if err == nil {
    				break
    			}
    		}
    		if err != nil {
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Fri Sep 06 13:17:27 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  3. internal/disk/stat_openbsd.go

    import (
    	"errors"
    	"fmt"
    	"syscall"
    )
    
    // GetInfo returns total and free bytes available in a directory, e.g. `/`.
    func GetInfo(path string, _ bool) (info Info, err error) {
    	s := syscall.Statfs_t{}
    	err = syscall.Statfs(path, &s)
    	if err != nil {
    		return Info{}, err
    	}
    	reservedBlocks := uint64(s.F_bfree) - uint64(s.F_bavail)
    	info = Info{
    		Total:  uint64(s.F_bsize) * (uint64(s.F_blocks) - reservedBlocks),
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  4. cmd/grid.go

    		TraceTo:   globalTrace,
    		RoutePath: grid.RoutePath,
    	})
    	if err != nil {
    		return err
    	}
    	globalGrid.Store(g)
    	return nil
    }
    
    func initGlobalLockGrid(ctx context.Context, eps EndpointServerPools) error {
    	hosts, local := eps.GridHosts()
    	lookupHost := globalDNSCache.LookupHost
    	g, err := grid.NewManager(ctx, grid.ManagerOptions{
    		// Pass Dialer for websocket grid, make sure we do not
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  5. 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.HashGeneratorFcn.NewClient(userName, password, authzID)
    	if err != nil {
    		return err
    	}
    	x.ClientConversation = x.Client.NewConversation()
    	return nil
    }
    
    // Step takes a string provided from a server (or just an empty string for the
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Nov 09 04:04:01 UTC 2023
    - 3.2K bytes
    - Viewed (1)
  6. cmd/jwt.go

    func metricsRequestAuthenticate(req *http.Request) (*xjwt.MapClaims, []string, bool, error) {
    	token, err := jwtreq.AuthorizationHeaderExtractor.ExtractToken(req)
    	if err != nil {
    		if err == jwtreq.ErrNoTokenInRequest {
    			return nil, nil, false, errNoAuthToken
    		}
    		return nil, nil, false, err
    	}
    	claims := xjwt.NewMapClaims()
    	if err := xjwt.ParseWithClaims(token, claims, func(claims *xjwt.MapClaims) ([]byte, error) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  7. cmd/speedtest.go

    	}
    
    	localPaths := globalEndpoints.LocalDisksPaths()
    	var ignoredPaths []string
    	paths := func() (tmpPaths []string) {
    		for _, lp := range localPaths {
    			if _, err := Lstat(pathJoin(lp, minioMetaBucket, formatConfigFile)); err == nil {
    				tmpPaths = append(tmpPaths, pathJoin(lp, minioMetaTmpBucket))
    			} else {
    				// Use dperf on only formatted drives.
    				ignoredPaths = append(ignoredPaths, lp)
    			}
    		}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon May 06 09:45:10 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  8. src/bytes/buffer.go

    // ReadBytes returns err != nil if and only if the returned data does not end in
    // delim.
    func (b *Buffer) ReadBytes(delim byte) (line []byte, err error) {
    	slice, err := b.readSlice(delim)
    	// return a copy of slice. The buffer's backing array may
    	// be overwritten by later calls.
    	line = append(line, slice...)
    	return line, err
    }
    
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Tue Jul 16 18:17:37 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  9. internal/kms/config_test.go

    )
    
    func TestIsPresent(t *testing.T) {
    	for i, test := range isPresentTests {
    		os.Clearenv()
    		for k, v := range test.Env {
    			os.Setenv(k, v)
    		}
    
    		ok, err := IsPresent()
    		if err != nil && !test.ShouldFail {
    			t.Fatalf("Test %d: %v", i, err)
    		}
    		if err == nil && test.ShouldFail {
    			t.Fatalf("Test %d: should have failed but succeeded", i)
    		}
    
    		if !test.ShouldFail && ok != test.IsPresent {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  10. schema/index_test.go

    type CompIdxLevel2B struct {
    	Data2B string `gorm:"index:,unique,composite:comp_id2,priority:3"`
    }
    
    func TestParseIndex(t *testing.T) {
    	user, err := schema.Parse(&UserIndex{}, &sync.Map{}, schema.NamingStrategy{})
    	if err != nil {
    		t.Fatalf("failed to parse user index, got error %v", err)
    	}
    
    	results := map[string]schema.Index{
    		"idx_user_indices_name": {
    			Name:   "idx_user_indices_name",
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Sun Feb 04 07:49:19 UTC 2024
    - 8K bytes
    - Viewed (0)
Back to top