Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 241 - 250 of 285 for workers (0.08 seconds)

  1. android/guava-tests/test/com/google/common/collect/LinkedHashMultimapTest.java

        assertThat(multimap.entries())
            .containsExactly(mapEntry("b", 2), mapEntry("a", 3), mapEntry("c", 4))
            .inOrder();
        // note that the keys and entries are in different orders
      }
    
      private void assertOrderingReadOnly(Multimap<String, Integer> multimap) {
        assertThat(multimap.get("foo")).containsExactly(5, 3).inOrder();
        assertThat(multimap.get("bar")).containsExactly(4, 1).inOrder();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 16.5K bytes
    - Click Count (0)
  2. cmd/erasure.go

    	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.
    	// some may be local and some remote.
    	getEndpoints func() []Endpoint
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 16.1K bytes
    - Click Count (0)
  3. internal/bucket/lifecycle/lifecycle.go

    				break
    			}
    
    			if !rule.Expiration.IsDaysNull() {
    				// Specifying the Days tag will automatically perform ExpiredObjectDeleteMarker cleanup
    				// once delete markers are old enough to satisfy the age criteria.
    				// https://docs.aws.amazon.com/AmazonS3/latest/userguide/lifecycle-configuration-examples.html
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Apr 03 06:45:06 GMT 2025
    - 18.2K bytes
    - Click Count (0)
  4. cmd/object-api-options.go

    		} else {
    			return opts, err
    		}
    	}
    
    	opts.DeletePrefix = deletePrefix
    	opts.Versioned = globalBucketVersioningSys.PrefixEnabled(bucket, object)
    	// Objects matching prefixes should not leave delete markers,
    	// dramatically reduces namespace pollution while keeping the
    	// benefits of replication, make sure to apply version suspension
    	// only at bucket level instead.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 14.3K bytes
    - Click Count (0)
  5. cmd/admin-handlers.go

    	vars := mux.Vars(r)
    
    	var args dsync.LockArgs
    	var lockers []dsync.NetLocker
    	for path := range strings.SplitSeq(vars["paths"], ",") {
    		if path == "" {
    			continue
    		}
    		args.Resources = append(args.Resources, path)
    	}
    
    	for _, lks := range z.serverPools[0].erasureLockers {
    		lockers = append(lockers, lks...)
    	}
    
    	for _, locker := range lockers {
    		locker.ForceUnlock(ctx, args)
    	}
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/collect/ImmutableTable.java

       * ordering of all views in the returned table. Note that some views of the original table and the
       * copied table may have different iteration orders. For more control over the ordering, create a
       * {@link Builder} and call {@link Builder#orderRowsBy}, {@link Builder#orderColumnsBy}, and
       * {@link Builder#putAll}
       *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Sep 22 21:07:18 GMT 2025
    - 17.4K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Cache.kt

       * cache size. The application needs to be aware of calling this function during the
       * initialization phase and preferably in a background worker thread.
       *
       * Note that if the application chooses to not call this method to initialize the cache. By
       * default, OkHttp will perform lazy initialization upon the first usage of the cache.
       */
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Mar 20 09:13:37 GMT 2026
    - 26.9K bytes
    - Click Count (0)
  8. src/test/java/jcifs/netbios/NameTest.java

            // First byte should be length of "test" (4) after processing
            assertEquals(4, dst[0]);
    
            // After processing, dots should be replaced with length markers
            // The scope processing happens backwards
            assertEquals(name.scope.length() + 2, length);
        }
    
        @Test
        void readScopeWireFormat_withMultipleLabels_shouldParseCorrectly() {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 19.4K bytes
    - Click Count (0)
  9. cmd/object-api-interface.go

    	ListObjectVersions(ctx context.Context, bucket, prefix, marker, versionMarker, delimiter string, maxKeys int) (result ListObjectVersionsInfo, err error)
    	// Walk lists all objects including versions, delete markers.
    	Walk(ctx context.Context, bucket, prefix string, results chan<- itemOrErr[ObjectInfo], opts WalkOptions) error
    
    	// Object operations.
    
    	// GetObjectNInfo returns a GetObjectReader that satisfies the
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 17.5K bytes
    - Click Count (0)
  10. LICENSE

      The GNU Affero General Public License is a free, copyleft license for
    software and other kinds of works, specifically designed to ensure
    cooperation with the community in the case of network server software.
    
      The licenses for most software and other practical works are designed
    to take away your freedom to share and change the works.  By contrast,
    our General Public Licenses are intended to guarantee your freedom to
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Apr 23 18:58:53 GMT 2021
    - 33.7K bytes
    - Click Count (0)
Back to Top