- Sort Score
- Result 10 results
- Languages All
Results 11 - 17 of 17 for readConfig (0.04 sec)
-
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() {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 37.7K bytes - Viewed (0) -
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 42.2K bytes - Viewed (1) -
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 184.8K bytes - Viewed (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 }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 118.2K bytes - Viewed (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);Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 19.7K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb1/net/NetShareEnumTest.java
@Mock private Configuration mockConfig; private NetShareEnum netShareEnum; 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: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 15.8K bytes - Viewed (0) -
src/test/java/jcifs/context/BaseContextTest.java
// Given BaseConfiguration realConfig = new BaseConfiguration(true); // When BaseContext realContext = new BaseContext(realConfig); // Then assertNotNull(realContext, "Context should work with real configuration"); assertSame(realConfig, realContext.getConfig(), "Should use provided real configuration");Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 15.1K bytes - Viewed (0)