- Sort Score
- Num 10 results
- Language All
Results 241 - 250 of 304 for Never (0.02 seconds)
-
cmd/metacache-walk.go
Recursive bool // ReportNotFound will return errFileNotFound if all disks reports the BaseDir cannot be found. ReportNotFound bool // FilterPrefix will only return results with given prefix within folder. // Should never contain a slash. FilterPrefix string // ForwardTo will forward to the given object path. ForwardTo string // Limit the number of returned objects if > 0. Limit int
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon May 26 07:06:43 GMT 2025 - 12.6K bytes - Click Count (0) -
cmd/endpoint.go
// where there are situations same endpoints with multiple disks // come online indicating either one of them is local and some // of them are not local. This situation can never happen and // its only a possibility in orchestrated deployments with dynamic // DNS. Following code ensures that we treat if one of the endpoint // says its local for a given host - it is true for all endpoints
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 34.5K bytes - Click Count (0) -
src/archive/tar/writer_test.go
t.Errorf("test %d, unexpected WriteHeader error: %v", i, err) } if err := tw.Close(); err != nil { t.Errorf("test %d, unexpected Close error: %v", i, err) } // The prefix field should never appear in the GNU format. var blk block copy(blk[:], b.Bytes()) prefix := string(blk.toUSTAR().prefix()) prefix, _, _ = strings.Cut(prefix, "\x00") // Truncate at the NUL terminator
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Mon Dec 15 16:34:13 GMT 2025 - 40.2K bytes - Click Count (0) -
cmd/s3-zip-handlers.go
func splitZipExtensionPath(input string) (zipPath, object string, err error) { idx := strings.Index(input, archivePattern) if idx < 0 { // Should never happen return "", "", errors.New("unable to parse zip path") } return input[:idx+len(archivePattern)-1], input[idx+len(archivePattern):], nil } // getObjectInArchiveFileHandler - GET Object in the archive file
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 15.8K bytes - Click Count (0) -
internal/event/target/elasticsearch.go
var keyHash string { key := eventData.S3.Bucket.Name + "/" + objectName if target.client.isAtleastV7() { hh, _ := highwayhash.New(magicHighwayHash256Key) // New will never return error since key is 256 bit hh.Write([]byte(key)) hashBytes := hh.Sum(nil) keyHash = base64.URLEncoding.EncodeToString(hashBytes) } else { keyHash = key } }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 15K bytes - Click Count (0) -
internal/ringbuffer/ring_buffer.go
r.mu.Lock() defer r.mu.Unlock() return !r.isFull && r.w == r.r } // CloseWithError closes the writer; reads will return // no bytes and the error err, or EOF if err is nil. // // CloseWithError never overwrites the previous error if it exists // and always returns nil. func (r *RingBuffer) CloseWithError(err error) { if err == nil { err = io.EOF } r.setErr(err, false) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 13.3K bytes - Click Count (0) -
compat/maven-compat/src/main/java/org/apache/maven/project/artifact/MavenMetadataSource.java
relocatedArtifact = rel.relocatedArtifact; if (rel.project == null) { // When this happens we have a Maven 1.x POM, or some invalid POM. // It should have never found its way into Maven 2.x repository, but it did. dependencies = Collections.emptyList(); } else { dependencies = rel.project.getModel().getDependencies();Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Thu Sep 25 12:03:50 GMT 2025 - 30.4K bytes - Click Count (0) -
cmd/batch-expire.go
switch ef.Type { case BatchJobExpireObject: if obj.DeleteMarker { return false } case BatchJobExpireDeleted: if !obj.DeleteMarker { return false } default: // we should never come here, Validate should have caught this. batchLogOnceIf(context.Background(), fmt.Errorf("invalid filter type: %s", ef.Type), ef.Type) return false } if len(ef.Name) > 0 && !wildcard.Match(ef.Name, obj.Name) {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Apr 22 11:16:32 GMT 2025 - 23K bytes - Click Count (0) -
cmd/erasure-metadata.go
// For tiered objects, read quorum is N/2+1 to ensure simple majority on xl.meta. // It is not equal to EcM because the data integrity is entrusted with the warm tier. // However, we never go below EcM, in case of a EcM=EcN setup. parities[index] = max(totalShards-(totalShards/2+1), metadata.Erasure.ParityBlocks) } else { parities[index] = metadata.Erasure.ParityBlocks } } return parities
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 21.3K bytes - Click Count (0) -
cmd/metacache-entries.go
return other, false } // Check if each version matches... for i, eVer := range eVers.versions { oVer := oVers.versions[i] if eVer.header != oVer.header { if eVer.header.hasEC() != oVer.header.hasEC() { // One version has EC and the other doesn't - may have been written later. // Compare without considering EC. a, b := eVer.header, oVer.header a.EcN, a.EcM = 0, 0 b.EcN, b.EcM = 0, 0Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Aug 08 15:29:58 GMT 2024 - 24.1K bytes - Click Count (0)