Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 391 for ctx_ (0.05 sec)

  1. cmd/sftp-server_test.go

    	}
    }
    
    func (s *TestSuiteIAM) SFTPInvalidServiceAccountPassword(c *check) {
    	ctx, cancel := context.WithTimeout(context.Background(), testDefaultTimeout)
    	defer cancel()
    
    	accessKey, secretKey := mustGenerateCredentials(c)
    	err := s.adm.SetUser(ctx, accessKey, secretKey, madmin.AccountEnabled)
    	if err != nil {
    		c.Fatalf("Unable to set user: %v", err)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 09:06:25 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  2. internal/lsync/lrwmutex_test.go

    )
    
    func testSimpleWriteLock(t *testing.T, duration time.Duration) (locked bool) {
    	ctx := context.Background()
    	lrwm := NewLRWMutex()
    
    	if !lrwm.GetRLock(ctx, "", "object1", time.Second) {
    		panic("Failed to acquire read lock")
    	}
    	// fmt.Println("1st read lock acquired, waiting...")
    
    	if !lrwm.GetRLock(ctx, "", "object1", time.Second) {
    		panic("Failed to acquire read lock")
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 05 04:57:35 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  3. internal/grid/benchmark_test.go

    			// Send 10x response.
    			Handle: func(ctx context.Context, payload []byte, _ <-chan []byte, out chan<- []byte) *RemoteErr {
    				for i := 0; i < responses; i++ {
    					toSend := GetByteBuffer()[:0]
    					toSend = append(toSend, byte(i))
    					toSend = append(toSend, payload...)
    					select {
    					case <-ctx.Done():
    						return nil
    					case out <- toSend:
    					}
    				}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  4. internal/logger/config.go

    }
    
    // LookupConfigForSubSys - lookup logger config, override with ENVs if set, for the given sub-system
    func LookupConfigForSubSys(ctx context.Context, scfg config.Config, subSys string) (cfg Config, err error) {
    	switch subSys {
    	case config.LoggerWebhookSubSys:
    		cfg = lookupLegacyConfigForSubSys(ctx, config.LoggerWebhookSubSys)
    		if cfg, err = lookupLoggerWebhookConfig(scfg, cfg); err != nil {
    			return cfg, err
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 20 16:02:50 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  5. cmd/bucket-replication-handlers.go

    		return
    	}
    
    	// Check if bucket exists.
    	if _, err := objectAPI.GetBucketInfo(ctx, bucket, BucketOptions{}); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	if _, _, err := globalBucketMetadataSys.GetReplicationConfig(ctx, bucket); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  6. cmd/post-policy-fan-out.go

    			if opts.Kind != nil {
    				encrd, objectEncryptionKey, err := newEncryptReader(ctx, hr, opts.Kind, opts.KeyID, opts.Key, bucket, req.Key, userDefined, opts.KmsCtx)
    				if err != nil {
    					errs[idx] = err
    					return
    				}
    
    				// do not try to verify encrypted content/
    				hr, err = hash.NewReader(ctx, encrd, -1, "", "", -1)
    				if err != nil {
    					errs[idx] = err
    					return
    				}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  7. cmd/metrics-v3-cache.go

    		nodesUpDown:         newNodesUpDownCache(),
    	}
    }
    
    type nodesOnline struct {
    	Online, Offline int
    }
    
    func newNodesUpDownCache() *cachevalue.Cache[nodesOnline] {
    	loadNodesUpDown := func(ctx context.Context) (v nodesOnline, err error) {
    		v.Online, v.Offline = globalNotificationSys.GetPeerOnlineCount()
    		return
    	}
    	return cachevalue.NewFromFunc(1*time.Minute,
    		cachevalue.Opts{ReturnLastGood: true},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  8. cmd/object-multipart-handlers.go

    			}
    		}
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    	defer gr.Close()
    	srcInfo := gr.ObjInfo
    
    	actualPartSize, err := srcInfo.GetActualSize()
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	if err := enforceBucketQuotaHard(ctx, dstBucket, actualPartSize); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  9. cmd/object-handlers.go

    			rcfg, err := globalBucketObjectLockSys.Get(bucket)
    			if err != nil {
    				writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    				return
    			}
    			replcfg, err := getReplicationConfig(ctx, bucket)
    			if err != nil {
    				writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    				return
    			}
    			event := evalActionFromLifecycle(ctx, *lc, rcfg, replcfg, objInfo)
    			if event.Action.Delete() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 05 05:16:15 UTC 2024
    - 117.4K bytes
    - Viewed (0)
  10. cmd/metrics-v3-cluster-usage.go

    )
    
    // loadClusterUsageObjectMetrics - reads cluster usage metrics.
    //
    // This is a `MetricsLoaderFn`.
    func loadClusterUsageObjectMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
    	dataUsageInfo, err := c.dataUsageInfo.Get()
    	if err != nil {
    		metricsLogIf(ctx, err)
    		return nil
    	}
    
    	// data usage has not captured any data yet.
    	if dataUsageInfo.LastUpdate.IsZero() {
    		return nil
    	}
    
    	var (
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jul 14 18:11:42 UTC 2024
    - 6.5K bytes
    - Viewed (0)
Back to top