- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for getTicks (0.32 sec)
-
cmd/erasure-object_test.go
if err != nil { t.Fatal(err) } erasureDisks := xl.getDisks() z.serverPools[0].erasureDisksMu.Lock() xl.getDisks = func() []StorageAPI { for i := range erasureDisks[:6] { erasureDisks[i] = newNaughtyDisk(erasureDisks[i], nil, errFaultyDisk) } return erasureDisks }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 36.8K bytes - Viewed (0) -
subprojects/core/src/testFixtures/groovy/org/gradle/util/internal/MultithreadedTestRule.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 23.3K bytes - Viewed (0) -
cmd/erasure.go
// erasureObjects - Implements ER object layer. type erasureObjects struct { setDriveCount int defaultParityCount int setIndex int poolIndex int // getDisks returns list of storageAPIs. getDisks func() []StorageAPI // getLockers returns list of remote and local lockers. getLockers func() ([]dsync.NetLocker, string) // getEndpoints returns list of endpoint belonging this set.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 16K bytes - Viewed (0) -
cmd/erasure-multipart.go
defer func() { if errors.Is(err, errFileNotFound) { err = errUploadIDNotFound } }() uploadIDPath := er.getUploadIDDir(bucket, object, uploadID) storageDisks := er.getDisks() // Read metadata associated with the object from all disks. partsMetadata, errs := readAllFileInfo(ctx, storageDisks, bucket, minioMetaMultipartBucket, uploadIDPath, "", false, false)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 44.8K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/model/internal/registry/ModelElementNode.java
@Override @Nullable public ModelNodeInternal getLink(String name) { return links == null ? null : links.get(name); } @Override public Iterable<? extends ModelNodeInternal> getLinks() { return links == null ? Collections.<ModelNodeInternal>emptyList() : links.values(); } @Override public int getLinkCount(Predicate<? super MutableModelNode> predicate) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 06 21:54:37 UTC 2024 - 10.9K bytes - Viewed (0) -
platforms/jvm/language-java/src/test/groovy/org/gradle/external/javadoc/StandardJavadocDocletOptionsTest.java
assertNull(options.getWindowTitle()); assertNull(options.getDocTitle()); assertNull(options.getFooter()); assertNull(options.getBottom()); assertEmpty(options.getLinks()); assertEmpty(options.getLinksOffline()); assertFalse(options.isLinkSource()); assertEmpty(options.getGroups()); assertFalse(options.isNoDeprecated());
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Aug 28 11:40:18 UTC 2023 - 15.5K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/model/internal/registry/DefaultModelRegistry.java
} } private void ensureCanRemove(ModelNodeInternal node, List<ModelNodeInternal> nodesToRemove) { if (!(node instanceof ModelReferenceNode)) { for (ModelNodeInternal childNode : node.getLinks()) { ensureCanRemove(childNode, nodesToRemove); } } if (!Iterables.isEmpty(node.getDependents())) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 24 15:40:00 UTC 2024 - 45.7K bytes - Viewed (0) -
platforms/jvm/language-groovy/src/main/java/org/gradle/api/tasks/javadoc/Groovydoc.java
getSource(), destinationDir, isUse(), isNoTimestamp(), isNoVersionStamp(), getWindowTitle(), getDocTitle(), getHeader(), getFooter(), getPathToOverview(), getAccess().get(), getLinks(), getGroovyClasspath(), getClasspath(), getTemporaryDir(), getServices().get(FileSystemOperations.class), getIncludeAuthor().get(), getProcessScripts().get(), getIncludeMainForScripts().get() );
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Aug 28 11:40:18 UTC 2023 - 14.1K bytes - Viewed (0) -
cmd/erasure-healing-common_test.go
if err != nil { t.Fatalf("Failed to make a bucket %v", err) } object := "object" data := bytes.Repeat([]byte("a"), smallFileThreshold*16) z := obj.(*erasureServerPools) erasureDisks, err := z.GetDisks(0, 0) if err != nil { t.Fatal(err) } for i, test := range testCases { test := test t.Run(fmt.Sprintf("case-%d", i), func(t *testing.T) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 23K bytes - Viewed (0) -
cmd/erasure-healing.go
dryRun := opts.DryRun scanMode := opts.ScanMode storageDisks := er.getDisks() storageEndpoints := er.getEndpoints() defer func() { er.auditHealObject(ctx, bucket, object, versionID, result, err) }() if globalTrace.NumSubscribers(madmin.TraceHealing) > 0 {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 33.8K bytes - Viewed (0)