Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 40 for corruptor (0.07 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/CacheCorruptionTest.kt

      }
    
      private fun corruptMetadata(corruptor: (String) -> String) {
        val metadataFile =
          fileSystem.allPaths.find {
            it.name.endsWith(".0")
          }
    
        if (metadataFile != null) {
          val contents =
            fileSystem.read(metadataFile) {
              readUtf8()
            }
    
          fileSystem.write(metadataFile) {
            writeUtf8(corruptor(contents))
          }
        }
      }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 6K bytes
    - Viewed (0)
  2. docs/erasure/README.md

    MinIO protects data against hardware failures and silent data corruption using erasure code and checksums. With the highest level of redundancy, you may lose up to half (N/2) of the total drives and still be able to recover the data.
    
    ## What is Erasure Code?
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  3. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.6K bytes
    - Viewed (0)
  4. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
  5. android/guava-testlib/src/com/google/common/collect/testing/google/MultimapPutIterableTester.java

        Collection<V> values = multimap().get(k3());
        if (values.size() == 0) {
          expectUnchanged();
          // Be extra thorough in case internal state was corrupted by the expected null.
          assertEquals(new ArrayList<>(), new ArrayList<>(values));
          assertEquals(size, multimap().size());
        } else {
          assertEquals(newArrayList(v3()), new ArrayList<>(values));
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 7.4K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Cache.kt

            // Choice here is between failing with a correct RuntimeException
            // or mostly silently with an IOException
            url = urlLine.toHttpUrlOrNull() ?: throw IOException("Cache corruption for $urlLine").also {
              Platform.get().log("cache corruption", WARN, it)
            }
            requestMethod = source.readUtf8LineStrict()
            val varyHeadersBuilder = Headers.Builder()
            val varyRequestHeaderLineCount = readInt(source)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 16 09:39:51 UTC 2025
    - 26.9K bytes
    - Viewed (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/ServerTruncatesRequestTest.kt

        expectedEvents += "ConnectionReleased"
        expectedEvents += "CallEnd"
        assertThat(listener.recordedEventTypes()).isEqualTo(expectedEvents)
    
        // Confirm that the connection pool was not corrupted by making another call.
        makeSimpleCall()
      }
    
      /**
       * If the server returns a full response, it doesn't really matter if the HTTP/2 stream is reset.
       * Attempts to write the request body fails fast.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  8. src/main/java/jcifs/pac/ASN1Util.java

                    }
                    throw new IOException("corrupted stream - high tag number < 31 found");
                }
    
                tagNo = b & 0x7f;
    
                // X.690-0207 8.1.2.4.2
                // "c) bits 7 to 1 of the first subsequent octet shall not all be zero."
                if (0 == tagNo) {
                    throw new IOException("corrupted stream - invalid high tag number found");
                }
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  9. cmd/erasure-healing_test.go

    		t.Fatalf("FileInfo not equal after healing: %v != %v", fi, nfi)
    	}
    
    	// Test 4: checks if HealObject returns an error when xl.meta is not found
    	// in more than read quorum number of disks, to create a corrupted situation.
    	for i := 0; i <= nfi.Erasure.DataBlocks; i++ {
    		erasureDisks[i].Delete(t.Context(), bucket, pathJoin(object, xlStorageFormatFile), DeleteOptions{
    			Recursive: false,
    			Immediate: false,
    		})
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 48.5K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/DiskLruCache.kt

            return
          } catch (journalIsCorrupt: IOException) {
            Platform.get().log(
              "DiskLruCache $directory is corrupt: ${journalIsCorrupt.message}, removing",
              WARN,
              journalIsCorrupt,
            )
          }
    
          // The cache is corrupted, attempt to delete the contents of the directory. This can throw and
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 34.7K bytes
    - Viewed (0)
Back to top