- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 223 for corrupt (0.16 sec)
-
cmd/bitrot.go
if algo != HighwayHash256S { h := algo.New() if n, err := io.Copy(h, r); err != nil || n != wantSize { // Premature failure in reading the object, file is corrupt. return errFileCorrupt } if !bytes.Equal(h.Sum(nil), want) { return errFileCorrupt } return nil } h := algo.New() hashBuf := make([]byte, h.Size()) left := wantSize
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 7.6K bytes - Viewed (0) -
build-logic/cleanup/src/main/kotlin/gradlebuild/cleanup/services/CachesCleaner.kt
fileSystemOperations.delete { delete(workerDir.dir("wrapper/dists/dist")) } // Remove caches that weren't multi-process safe and may be corrupt fileSystemOperations.removeDodgyCacheFiles(workerDir.dir("caches")) // Remove old daemon log files fileSystemOperations.removeDaemonLogFiles(workerDir.dir("daemon")) }
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Fri Jun 28 08:29:28 UTC 2024 - 4.2K bytes - Viewed (0) -
cmd/erasure-healing-common.go
metaErrs[i] = errDiskNotFound continue } meta := partsMetadata[i] corrupted := false if filterByETag { corrupted = meta.Metadata["etag"] != latestMeta.Metadata["etag"] } else { corrupted = !meta.ModTime.Equal(latestMeta.ModTime) || meta.DataDir != latestMeta.DataDir } if corrupted { metaErrs[i] = errFileCorrupt partsMetadata[i] = FileInfo{} continue }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 12.7K bytes - Viewed (0) -
cmd/erasure-healing.go
notFoundCount++ } else if isErrBucketNotFound(err) { notFoundCount++ } } } return len(errs) == notFoundCount } // ObjectDir is considered dangling/corrupted if any only // if total disks - a combination of corrupted and missing // files is lesser than N/2+1 number of disks. // If no files were found false will be returned. func isObjectDirDangling(errs []error) (ok bool) { var found int
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Oct 02 17:50:41 UTC 2024 - 34.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/idn/IdnaMappingTableTest.kt
assertThat(allowedByCompactTable).isEqualTo(allowedByTable) assertThat(compactTableMappedTo).isEqualTo(tableMappedTo) } } /** Confirm we didn't corrupt any data in code generation. */ @Test fun compareConstructedAndGeneratedCompactTables() { assertThat(IDNA_MAPPING_TABLE.sections).isEqualTo(compactTable.sections)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 8.9K bytes - Viewed (0) -
cmd/erasure-healing-common_test.go
} break } case corruptPart: for index, err := range test.errs { if err != nil { continue } // Corrupt a part from a disk // which has a valid xl.meta, // and check if that disk // appears in outDatedDisks. tamperedIndex = index
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 01 15:19:10 UTC 2024 - 23.1K bytes - Viewed (0) -
cmd/erasure-sets.go
- Any JBOD inconsistent - return failure - Some are corrupt (missing format.json) - return failure - Any unrecognized disks - return failure Some disks are offline and we have quorum. ----------------- - Some unformatted - format all and return success, treat disks offline as corrupted. - Any JBOD inconsistent - return failure - Some are corrupt (missing format.json) - Any unrecognized disks - return failure
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 27 10:41:37 UTC 2024 - 37K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
"TYPE_GOAWAY unexpected error code: $errorCodeInt", ) var debugData = ByteString.EMPTY if (opaqueDataLength > 0) { // Must read debug data in order to not corrupt the connection. debugData = source.readByteString(opaqueDataLength.toLong()) } handler.goAway(lastStreamId, errorCode, debugData) }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 19.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Cache.kt
for (i in 0 until length) { val line = source.readUtf8LineStrict() val bytes = Buffer() val certificateBytes = line.decodeBase64() ?: throw IOException("Corrupt certificate in cache entry") bytes.write(certificateBytes) result.add(certificateFactory.generateCertificate(bytes.inputStream())) } return result
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 26.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
|100 |2 | |CLEAN k1 1 1 """.trimMargin(), ) } createNewCache() assertThat(cache["k1"]).isNull() // The journal is not corrupt when editing after a truncated line. set("k1", "C", "D") cache.close() createNewCache() assertValue("k1", "C", "D") } @ParameterizedTest
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 15 14:55:09 UTC 2024 - 75.8K bytes - Viewed (0)