Search Options

Results per page
Sort
Preferred Languages
Advance

Results 241 - 250 of 790 for rfunc (0.02 sec)

  1. internal/stmt_store/stmt_store.go

    	lru *lru.LRU[string, *Stmt]
    }
    
    func (s *lruStore) Keys() []string {
    	return s.lru.Keys()
    }
    
    func (s *lruStore) Get(key string) (*Stmt, bool) {
    	stmt, ok := s.lru.Get(key)
    	if ok && stmt != nil {
    		<-stmt.prepared
    	}
    	return stmt, ok
    }
    
    func (s *lruStore) Set(key string, value *Stmt) {
    	s.lru.Add(key, value)
    }
    
    func (s *lruStore) Delete(key string) {
    	s.lru.Remove(key)
    }
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Sun Apr 27 06:05:16 UTC 2025
    - 6K bytes
    - Viewed (0)
  2. cmd/perf-tests.go

    	DownloadTimes madmin.TimeDurations
    	DownloadTTFB  madmin.TimeDurations
    	Error         string
    }
    
    func newRandomReader(size int) io.Reader {
    	return io.LimitReader(randreader.New(), int64(size))
    }
    
    type firstByteRecorder struct {
    	t *time.Time
    	r io.Reader
    }
    
    func (f *firstByteRecorder) Read(p []byte) (n int, err error) {
    	if f.t != nil || len(p) == 0 {
    		return f.r.Read(p)
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  3. cmd/jwt_test.go

    		b.Fatal(err)
    	}
    
    	b.ResetTimer()
    	b.ReportAllocs()
    	b.RunParallel(func(pb *testing.PB) {
    		for pb.Next() {
    			err = xjwt.ParseWithClaims(token, xjwt.NewMapClaims(), func(*xjwt.MapClaims) ([]byte, error) {
    				return []byte(creds.SecretKey), nil
    			})
    			if err != nil {
    				b.Fatal(err)
    			}
    		}
    	})
    }
    
    func BenchmarkAuthenticateNode(b *testing.B) {
    	ctx, cancel := context.WithCancel(b.Context())
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.4K bytes
    - Viewed (0)
  4. cmd/mrf.go

    // the current heal status in one available disk
    func (m *mrfState) shutdown() {
    	atomic.StoreInt32(&m.closing, 1)
    	m.wg.Wait()
    	close(m.opCh)
    	atomic.StoreInt32(&m.closed, 1)
    
    	if len(m.opCh) > 0 {
    		healingLogEvent(context.Background(), "Saving MRF healing data (%d entries)", len(m.opCh))
    	}
    
    	newReader := func() io.ReadCloser {
    		r, w := io.Pipe()
    		go func() {
    			// Initialize MRF meta header.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  5. cmd/object-lambda-handlers_test.go

    		},
    	}
    
    	for _, tc := range testCases {
    		t.Run(tc.name, func(t *testing.T) {
    			runObjectLambdaTest(t, tc.statusCode, tc.body, tc.contentType, tc.expectStatus)
    		})
    	}
    }
    
    func runObjectLambdaTest(t *testing.T, lambdaStatus int, lambdaBody, contentType string, expectStatus int) {
    	ExecObjectLayerAPITest(ExecObjectLayerAPITestArgs{
    		t: t,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jul 18 21:56:31 UTC 2025
    - 5.2K bytes
    - Viewed (0)
  6. cmd/config-dir.go

    type ConfigDir struct {
    	path string
    }
    
    func getDefaultConfigDir() string {
    	homeDir, err := homedir.Dir()
    	if err != nil {
    		return ""
    	}
    
    	return filepath.Join(homeDir, defaultMinioConfigDir)
    }
    
    func getDefaultCertsDir() string {
    	return filepath.Join(getDefaultConfigDir(), certsDir)
    }
    
    func getDefaultCertsCADir() string {
    	return filepath.Join(getDefaultCertsDir(), certsCADir)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 3K bytes
    - Viewed (0)
  7. cmd/xl-storage-format-v2_gen.go

    func (z ErasureAlgo) Msgsize() (s int) {
    	s = msgp.Uint8Size
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *VersionType) DecodeMsg(dc *msgp.Reader) (err error) {
    	{
    		var zb0001 uint8
    		zb0001, err = dc.ReadUint8()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = VersionType(zb0001)
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Dec 15 22:50:12 UTC 2024
    - 56K bytes
    - Viewed (0)
  8. cmd/user-provider-utils.go

    func populateProviderInfoFromClaims(claims map[string]any, provider string, resp *madmin.InfoAccessKeyResp) {
    	resp.UserProvider = provider
    	switch provider {
    	case madmin.LDAPProvider:
    		resp.LDAPSpecificInfo = getLDAPInfoFromClaims(claims)
    	case madmin.OpenIDProvider:
    		resp.OpenIDSpecificInfo = getOpenIDInfoFromClaims(claims)
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.1K bytes
    - Viewed (0)
  9. cmd/erasure-multipart.go

    }
    
    func (er erasureObjects) getMultipartSHADir(bucket, object string) string {
    	return getSHA256Hash([]byte(pathJoin(bucket, object)))
    }
    
    // checkUploadIDExists - verify if a given uploadID exists and is valid.
    func (er erasureObjects) checkUploadIDExists(ctx context.Context, bucket, object, uploadID string, write bool) (fi FileInfo, metArr []FileInfo, err error) {
    	defer func() {
    		if errors.Is(err, errFileNotFound) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  10. cmd/admin-handlers-config-kv.go

    }
    
    type badConfigErr struct {
    	Err error
    }
    
    // Error - return the error message
    func (bce badConfigErr) Error() string {
    	return bce.Err.Error()
    }
    
    // Unwrap the error to its underlying error.
    func (bce badConfigErr) Unwrap() error {
    	return bce.Err
    }
    
    type setConfigResult struct {
    	Cfg                     config.Config
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.7K bytes
    - Viewed (1)
Back to top