- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 142 for doesn (0.14 sec)
-
cmd/erasure-object.go
// into memory, any mutation on xl.meta subsequently is // inconsequential to the overall read operation. // - xl.meta metadata is still verified for quorum under lock() // however writing the response doesn't need to serialize // concurrent writers unlockOnDefer = true nsUnlocker = func() { lock.RUnlock(lkctx) } } fi, metaArr, onlineDisks, err := er.getObjectFileInfo(ctx, bucket, object, opts, true)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/common-main.go
if isFile(pathJoin("/run/secrets/", sp)) { sp = pathJoin("/run/secrets/", sp) } credBuf, err := os.ReadFile(sp) if err != nil { if os.IsNotExist(err) { // ignore if file doesn't exist. return "", nil } return "", err } return string(bytes.TrimSpace(credBuf)), nil } func loadEnvVarsFromFiles() { if env.IsSet(config.EnvAccessKeyFile) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 04 00:17:57 GMT 2024 - 35.8K bytes - Viewed (2) -
cmd/admin-handlers.go
if anonParam != anonymizeStrict { return addr } newAddr, found := hostAnonymizer[addr] if found { return newAddr } // If we reach here, it means that the given addr doesn't contain any of the hosts. // Return it as is. Can happen for drive paths in non-distributed mode return addr } // anonymizedAddr - Updated the addr of the node info with anonymized one
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 29 17:39:04 GMT 2024 - 97.8K bytes - Viewed (2) -
cmd/object-handlers_test.go
} r.Close() if !bytes.Equal(testCase.data, buffer.Bytes()) { t.Errorf("Test %d: %s: Data Mismatch: Data fetched back from the uploaded object doesn't match the original one.", i+1, instanceType) } } } } // Wrapper for calling PutObject API handler tests for both Erasure multiple disks and FS single drive setup.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 160K bytes - Viewed (0) -
cmd/bucket-replication.go
Host: globalLocalNodeName, EventName: event.ObjectReplicationNotTracked, }) return } // Lock the object name before starting replication operation. // Use separate lock that doesn't collide with regular objects. lk := objectAPI.NewNSLock(bucket, "/[replicate]/"+dobj.ObjectName) lkctx, err := lk.GetLock(ctx, globalOperationTimeout) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirCallResolver.kt
* case, the resulting [KtCall] would contain no type arguments at all, which can cause problems later. If too few type arguments are * provided, an empty map is returned defensively so that [toTypeArgumentsMapping] doesn't conjure any error types. If you want to map * too few type arguments meaningfully, please provide filler types explicitly. */ private fun toTypeArgumentsMapping( typeArguments: List<FirTypeProjection>,
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Thu Apr 25 18:05:58 GMT 2024 - 70.8K bytes - Viewed (1) -
android/guava/src/com/google/common/collect/Multisets.java
* elementSet()}, do not support {@code remove()}. However, all other multiset methods supported * by {@code unfiltered} are supported by the returned multiset. When given an element that * doesn't satisfy the predicate, the multiset's {@code add()} and {@code addAll()} methods throw * an {@link IllegalArgumentException}. When methods such as {@code removeAll()} and {@code
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 41.7K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
CurrentSize: pi.Free, TotalSize: pi.Total, } return nil } func (p poolMeta) IsSuspended(idx int) bool { if idx >= len(p.Pools) { // We don't really know if the pool is suspended or not, since it doesn't exist. return false } return p.Pools[idx].Decommission != nil } func (p *poolMeta) validate(pools []*erasureSets) (bool, error) { type poolInfo struct { position int completed bool
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
cmd/batch-handlers.go
batchLogIf(ctx, err) continue } _, nodeIdx := parseRequestToken(req.ID) if nodeIdx > -1 && GetProxyEndpointLocalIndex(globalProxyEndpoints) != nodeIdx { // This job doesn't belong on this node. continue } if err := j.queueJob(req); err != nil { batchLogIf(ctx, err) continue } } } // AddWorker adds a replication worker to the pool
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 55.2K bytes - Viewed (0) -
api/maven-api-model/src/main/mdo/maven.mdo
The frequency for downloading updates - can be {@code always}, {@code daily} (default), {@code interval:XXX} (in minutes) or {@code never} (only if it doesn't exist locally). </description> <type>String</type> </field> <field> <name>checksumPolicy</name> <version>4.0.0+</version> <description>
XML - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Tue Apr 23 13:29:46 GMT 2024 - 115.1K bytes - Viewed (0)