Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 44 of 44 for WithTimeout (0.05 sec)

  1. cmd/peer-rest-server.go

    		}
    		srvCfg, err := getValidConfig(objAPI)
    		if err != nil {
    			return np, grid.NewRemoteErr(err)
    		}
    		subSys := vars.Get(peerRESTSubSys)
    		// Apply dynamic values.
    		ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
    		defer cancel()
    		if subSys == "" {
    			err = applyDynamicConfig(ctx, objAPI, srvCfg)
    		} else {
    			err = applyDynamicConfigForSubSys(ctx, objAPI, srvCfg, subSys)
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 53.4K bytes
    - Viewed (0)
  2. cmd/iam.go

    	policyDBSTSUsersPrefix := strings.HasPrefix(event.keyPath, iamConfigPolicyDBSTSUsersPrefix)
    	policyDBGroupsPrefix := strings.HasPrefix(event.keyPath, iamConfigPolicyDBGroupsPrefix)
    
    	ctx, cancel := context.WithTimeout(ctx, defaultContextTimeout)
    	defer cancel()
    
    	switch {
    	case usersPrefix:
    		accessKey := path.Dir(strings.TrimPrefix(event.keyPath, iamConfigUsersPrefix))
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 75.3K bytes
    - Viewed (0)
  3. cmd/iam-store.go

    		toMerge = append(toMerge, p.Policy)
    	}
    	store.runlock()
    
    	if len(missingPolicies) > 0 {
    		m := make(map[string]PolicyDoc)
    		for _, policy := range missingPolicies {
    			ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
    			_ = store.loadPolicyDoc(ctx, policy, m)
    			cancel()
    		}
    
    		cache := store.lock()
    		maps.Copy(cache.iamPolicyDocsMap, m)
    		store.unlock()
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 86.7K bytes
    - Viewed (0)
  4. cmd/site-replication.go

    				results.NodeResults = append(results.NodeResults, result)
    				resultsMu.Unlock()
    			}()
    			continue
    		}
    		wg.Add(1)
    		go func() {
    			defer wg.Done()
    			ctx, cancel := context.WithTimeout(ctx, duration+10*time.Second)
    			defer cancel()
    			result := perfNetRequest(
    				ctx,
    				info.DeploymentID,
    				adminPathPrefix+adminAPIVersionPrefix+adminAPISiteReplicationNetPerf,
    				nil,
    			)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 184.7K bytes
    - Viewed (1)
Back to top