- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 11 for readConfig (0.16 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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 {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.9K bytes - Click Count (0) -
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 }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.4K bytes - Click Count (0) -
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{} }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 45.5K bytes - Click Count (0) -
internal/config/config.go
return nil, err } ids[tgt] = true } if err := scanner.Err(); err != nil { return nil, err } return ids, err } // ReadConfig - read content from input and write into c. // Returns whether all parameters were dynamic. func (c Config) ReadConfig(r io.Reader) (dynOnly bool, err error) { var n int scanner := bufio.NewScanner(r) dynOnly = true for scanner.Scan() {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 37.7K bytes - Click Count (0) -
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]) {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 18.2K bytes - Click Count (0) -
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 {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 63.5K bytes - Click Count (1) -
cmd/admin-handlers-config-kv.go
result.Cfg, err = readServerConfig(ctx, objectAPI, nil) if err != nil { return result, err } result.Dynamic, err = result.Cfg.ReadConfig(bytes.NewReader(kvBytes)) if err != nil { return result, err } result.SubSys, _, _, err = config.GetSubSys(string(kvBytes)) if err != nil { return result, err }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 15.8K bytes - Click Count (1) -
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 {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 42.2K bytes - Click Count (1) -
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 }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 118.2K bytes - Click Count (0) -
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);Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 19.7K bytes - Click Count (0)