Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1681 - 1690 of 2,223 for mmap (0.02 sec)

  1. build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild.cache-miss-monitor.gradle.kts

            "CompileAllBuild_BuildCacheNG",
            "CompileAllBuild_NGRemote"
        ) || isBuildCommitDistribution
    
    val Project.isBuildCommitDistribution: Boolean
        get() = providers.gradleProperty("buildCommitDistribution").map { it.toBoolean() }.orElse(false).get()
    
    
    fun Project.isInBuild(vararg buildTypeIds: String) = providers.environmentVariable("BUILD_TYPE_ID").orNull?.let { currentBuildTypeId ->
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Thu Mar 07 05:49:29 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  2. cmd/object_api_suite_test.go

    	}
    	res, err := obj.NewMultipartUpload(context.Background(), "bucket", "key", opts)
    	if err != nil {
    		t.Fatalf("%s: <ERROR> %s", instanceType, err)
    	}
    	uploadID := res.UploadID
    
    	parts := make(map[int]string)
    	metadata := make(map[string]string)
    	for i := 1; i <= 10; i++ {
    		randomPerm := rand.Perm(10)
    		randomString := ""
    		for _, num := range randomPerm {
    			randomString += strconv.Itoa(num)
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 02 15:13:05 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java

        int numberOfModifications = 100;
        MinMaxPriorityQueue<Integer> mmHeap =
            rawtypeToWildcard(MinMaxPriorityQueue.expectedSize(heapSize)).create();
        /*
         * this map would contain the same exact elements as the MinMaxHeap; the
         * value in the map is the number of occurrences of the key.
         */
        SortedMap<Integer, AtomicInteger> replica = Maps.newTreeMap();
        assertTrue("Empty heap should be OK", mmHeap.isIntact());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 35.9K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb/SmbTransportPoolImpl.java

    import java.io.IOException;
    import java.net.InetAddress;
    import java.net.UnknownHostException;
    import java.util.Arrays;
    import java.util.Comparator;
    import java.util.LinkedList;
    import java.util.List;
    import java.util.Map;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ConcurrentLinkedQueue;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import jcifs.Address;
    import jcifs.CIFSContext;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Dec 20 14:09:34 UTC 2020
    - 12.5K bytes
    - Viewed (0)
  5. compat/maven-artifact/src/main/java/org/apache/maven/artifact/DefaultArtifact.java

     * under the License.
     */
    package org.apache.maven.artifact;
    
    import java.io.File;
    import java.util.Collection;
    import java.util.Collections;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.Objects;
    
    import org.apache.maven.artifact.handler.ArtifactHandler;
    import org.apache.maven.artifact.metadata.ArtifactMetadata;
    import org.apache.maven.artifact.repository.ArtifactRepository;
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  6. callbacks/update.go

    			for db.Statement.ReflectValue.Kind() == reflect.Ptr {
    				db.Statement.ReflectValue = db.Statement.ReflectValue.Elem()
    			}
    
    			if dest, ok := db.Statement.Dest.(map[string]interface{}); ok {
    				for _, rel := range db.Statement.Schema.Relationships.BelongsTo {
    					if _, ok := dest[rel.Name]; ok {
    						db.AddError(rel.Field.Set(db.Statement.Context, db.Statement.ReflectValue, dest[rel.Name]))
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Mar 18 05:44:55 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/suggest/entity/ElevateWord.java

        }
    
        public List<String> getRoles() {
            return roles;
        }
    
        public SuggestItem toSuggestItem() {
            final String[][] readingArray =
                    this.getReadings().stream().map(reading -> new String[] { reading }).toArray(count -> new String[count][]);
            return new SuggestItem(new String[] { this.getElevateWord() }, readingArray, fields.toArray(new String[fields.size()]), 1, 0,
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  8. cmd/os-instrumented.go

    	var m madmin.OSMetrics
    	m.CollectedAt = time.Now()
    	m.LifeTimeOps = make(map[string]uint64, osMetricLast)
    	for i := osMetric(0); i < osMetricLast; i++ {
    		if n := atomic.LoadUint64(&o.operations[i]); n > 0 {
    			m.LifeTimeOps[i.String()] = n
    		}
    	}
    	if len(m.LifeTimeOps) == 0 {
    		m.LifeTimeOps = nil
    	}
    
    	m.LastMinute.Operations = make(map[string]madmin.TimedAction, osMetricLast)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 15 01:09:38 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  9. cmd/bucket-lifecycle-handlers.go

    	// Validate the transition storage ARNs
    	if err = validateTransitionTier(bucketLifecycle); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	// Create a map of updated set of rules in request
    	updatedRules := make(map[string]lifecycle.Rule, len(bucketLifecycle.Rules))
    	for _, rule := range bucketLifecycle.Rules {
    		updatedRules[rule.ID] = rule
    	}
    
    	// Get list of rules for the bucket from disk
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 7K bytes
    - Viewed (0)
  10. cmd/warm-backend-gcs.go

    	if gcs.Prefix != "" {
    		destObj = fmt.Sprintf("%s/%s", gcs.Prefix, object)
    	}
    	return destObj
    }
    
    func (gcs *warmBackendGCS) PutWithMeta(ctx context.Context, key string, data io.Reader, length int64, meta map[string]string) (remoteVersionID, error) {
    	object := gcs.client.Bucket(gcs.Bucket).Object(gcs.getDest(key))
    	w := object.NewWriter(ctx)
    	if gcs.StorageClass != "" {
    		w.ObjectAttrs.StorageClass = gcs.StorageClass
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 6.1K bytes
    - Viewed (0)
Back to top