Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for readConfig (0.16 sec)

  1. cmd/config.go

    				RestoreID:  strings.TrimSuffix(path.Base(obj.Name), kvPrefix),
    				CreateTime: obj.ModTime, // ModTime is createTime for config history entries.
    			}
    			if withData {
    				data, err := readConfig(ctx, objAPI, obj.Name)
    				if err != nil {
    					// ignore history file if not readable.
    					continue
    				}
    
    				data, err = decryptData(data, obj.Name)
    				if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.9K bytes
    - Viewed (0)
  2. cmd/config-migrate.go

    	}
    	if osIsPermission(err) {
    		logger.Info("Older config found but is not readable %s, proceeding to read config from other places", err)
    	}
    	if osIsNotExist(err) || osIsPermission(err) || len(data) == 0 {
    		data, err = readConfig(GlobalContext, objAPI, configFile)
    		if err != nil {
    			// when config.json is not found, then we freshly initialize.
    			if errors.Is(err, errConfigNotFound) {
    				return newServerCfg()
    			}
    			return nil, err
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.4K bytes
    - Viewed (0)
  3. cmd/tier.go

    func loadTierConfig(ctx context.Context, objAPI ObjectLayer) (*TierConfigMgr, error) {
    	if objAPI == nil {
    		return nil, errServerNotInitialized
    	}
    
    	data, err := readConfig(ctx, objAPI, tierConfigPath)
    	if err != nil {
    		return nil, err
    	}
    
    	if len(data) <= 4 {
    		return nil, errors.New("tierConfigInit: no data")
    	}
    
    	// Read header
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  4. cmd/data-scanner.go

    }
    
    func readBackgroundHealInfo(ctx context.Context, objAPI ObjectLayer) backgroundHealInfo {
    	if globalIsErasureSD {
    		return backgroundHealInfo{}
    	}
    
    	// Get last healing information
    	buf, err := readConfig(ctx, objAPI, backgroundHealInfoPath)
    	if err != nil {
    		if !errors.Is(err, errConfigNotFound) {
    			internalLogOnceIf(ctx, err, backgroundHealInfoPath)
    		}
    		return backgroundHealInfo{}
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.5K bytes
    - Viewed (0)
  5. cmd/bucket-metadata.go

    		return BucketMetadata{}, errInvalidArgument
    	}
    	b := newBucketMetadata(name)
    	configFile := path.Join(bucketMetaPrefix, name, bucketMetadataFile)
    	data, err := readConfig(ctx, api, configFile)
    	if err != nil {
    		return b, err
    	}
    	if len(data) <= 4 {
    		return b, fmt.Errorf("loadBucketMetadata: no data")
    	}
    	// Read header
    	switch binary.LittleEndian.Uint16(data[0:2]) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri May 16 14:27:42 UTC 2025
    - 18.1K bytes
    - Viewed (0)
  6. cmd/batch-handlers.go

    	case batchExpireName:
    		version = batchExpireVersionV1
    		format = batchExpireFormat
    	default:
    		return errors.New("no supported batch job request specified")
    	}
    
    	data, err := readConfig(ctx, api, path)
    	if err != nil {
    		if errors.Is(err, errConfigNotFound) || isErrObjectNotFound(err) {
    			return errNoSuchJob
    		}
    		return err
    	}
    	if len(data) == 0 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.5K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool-decom.go

    	if !update {
    		update = len(specifiedPools) != len(rememberedPools)
    	}
    
    	return update, nil
    }
    
    func (p *poolMeta) load(ctx context.Context, pool *erasureSets, pools []*erasureSets) error {
    	data, err := readConfig(ctx, pool, poolMetaName)
    	if err != nil {
    		if errors.Is(err, errConfigNotFound) || isErrObjectNotFound(err) {
    			return nil
    		}
    		return err
    	}
    	if len(data) == 0 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 42.1K bytes
    - Viewed (1)
  8. cmd/site-replication.go

    	if c.enabled {
    		logger.Info("Cluster replication initialized")
    	}
    	return nil
    }
    
    func (c *SiteReplicationSys) loadFromDisk(ctx context.Context, objAPI ObjectLayer) error {
    	buf, err := readConfig(ctx, objAPI, getSRStateFilePath())
    	if err != nil {
    		if errors.Is(err, errConfigNotFound) {
    			c.Lock()
    			defer c.Unlock()
    			c.state = srState{}
    			c.enabled = false
    		}
    		return err
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 184.7K bytes
    - Viewed (0)
  9. cmd/bucket-replication.go

    	brs = newBucketResyncStatus(bucket)
    	resyncDirPath := path.Join(bucketMetaPrefix, bucket, replicationDir)
    	data, err := readConfig(GlobalContext, objAPI, pathJoin(resyncDirPath, resyncFileName))
    	if err != nil && err != errConfigNotFound {
    		return brs, err
    	}
    	if len(data) == 0 {
    		// Seems to be empty.
    		return brs, nil
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  10. src/test/java/jcifs/internal/smb1/net/NetServerEnum2Test.java

        @Mock
        private Configuration mockConfig;
    
        private NetServerEnum2 netServerEnum2;
        private Configuration realConfig;
    
        @BeforeEach
        void setUp() throws Exception {
            MockitoAnnotations.openMocks(this);
            // Use real configuration for most tests
            realConfig = new BaseConfiguration(false);
            // Mock configuration setup
            when(mockConfig.getTransactionBufferSize()).thenReturn(65535);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 19.7K bytes
    - Viewed (0)
Back to top