Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for getTicks (0.32 sec)

  1. 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)
  2. subprojects/core/src/testFixtures/groovy/org/gradle/util/internal/MultithreadedTestRule.java

         */
        public ClockTick clockTick(int tick) {
            lock.lock();
            try {
                return getTick(tick);
            } finally {
                lock.unlock();
            }
        }
    
        private ClockTickImpl getTick(int tick) {
            ClockTickImpl clockTick = ticks.get(tick);
            if (clockTick == null) {
                clockTick = new ClockTickImpl(tick);
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Oct 05 19:36:14 UTC 2023
    - 23.3K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. platforms/jvm/language-groovy/src/main/java/org/gradle/api/tasks/javadoc/Groovydoc.java

    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Aug 28 11:40:18 UTC 2023
    - 14.1K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top