Search Options

Results per page
Sort
Preferred Languages
Advance

Results 361 - 370 of 702 for secunds (0.06 sec)

  1. guava/src/com/google/common/util/concurrent/AtomicLongMap.java

       * {@code key} (or zero, if there is none) is passed as the first argument to {@code
       * accumulatorFunction}, and {@code x} is passed as the second argument.
       *
       * @since 21.0
       */
      @CanIgnoreReturnValue
      public long accumulateAndGet(K key, long x, LongBinaryOperator accumulatorFunction) {
        checkNotNull(accumulatorFunction);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  2. istioctl/pkg/waypoint/waypoint.go

    	waypointName    = constants.DefaultNamespaceWaypoint
    	enrollNamespace bool
    	overwrite       bool
    )
    
    const waitTimeout = 90 * time.Second
    
    func Cmd(ctx cli.Context) *cobra.Command {
    	makeGateway := func(forApply bool) (*gateway.Gateway, error) {
    		ns := ctx.NamespaceOrDefault(ctx.Namespace())
    		if ctx.Namespace() == "" && !forApply {
    			ns = ""
    		}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  3. cmd/bucket-replication.go

    			<-ctx.Done()
    			return
    		}
    		duration := time.Duration(r.Float64() * float64(time.Minute))
    		if duration < time.Second {
    			// Make sure to sleep at least a second to avoid high CPU ticks.
    			duration = time.Second
    		}
    		time.Sleep(duration)
    	}
    }
    
    // Loads bucket replication resync statuses into memory.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  4. compat/maven-model-builder/src/main/java/org/apache/maven/model/validation/DefaultModelValidator.java

         *
         * @param first the first version.
         * @param second the second version.
         * @return negative if the first version is newer than the second version, zero if they are the same or positive if
         * the second version is the newer.
         */
        private static int compareModelVersions(String first, String second) {
            // we use a dedicated comparator because we control our model version scheme.
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 77.1K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/pod_cache_test.go

    	netns2 := p.UpsertPodCacheWithNetns(string(pod.UID), wl2)
    	if netns2 != ns {
    		t.Fatalf("Expected the original Netns for the same uid, got %p and %p", netns2, ns)
    	}
    	if !ns2.closed.Load() {
    		t.Fatal("Expected the second Netns to be closed")
    	}
    }
    
    func TestDoubleTake(t *testing.T) {
    	p := newPodNetnsCache(openNsTestOverride)
    
    	pod := &corev1.Pod{ObjectMeta: metav1.ObjectMeta{UID: "testUID"}}
    	ns := newFakeNs(inc())
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Aug 14 19:36:19 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  6. guava/src/com/google/common/collect/JdkBackedImmutableMap.java

        Map<K, V> delegateMap = Maps.newHashMapWithExpectedSize(n);
        // If duplicates are allowed, this map will track the last value for each duplicated key.
        // A second pass will retain only the first entry for that key, but with this last value. The
        // value will then be replaced by null, signaling that later entries with the same key should
        // be deleted.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Nov 30 21:54:06 UTC 2023
    - 4.8K bytes
    - Viewed (0)
  7. internal/jwt/parser_test.go

    			},
    		},
    		false,
    		-1,
    	},
    	{
    		"Standard Claims",
    		"",
    		defaultKeyFunc,
    		&StandardClaims{
    			StandardClaims: jwt.StandardClaims{
    				ExpiresAt: time.Now().Add(time.Second * 10).Unix(),
    			},
    		},
    		true,
    		0,
    	},
    }
    
    func mapClaimsToken(claims *MapClaims) string {
    	claims.SetAccessKey("test")
    	j := jwt.NewWithClaims(jwt.SigningMethodHS512, claims)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Nov 05 19:20:08 UTC 2021
    - 6K bytes
    - Viewed (0)
  8. cmd/admin-handlers-users-race_test.go

    				runAllIAMConcurrencyTests(testCase, &check{t, testCase.serverType})
    			},
    		)
    	}
    }
    
    func (s *TestSuiteIAM) TestDeleteUserRace(c *check) {
    	ctx, cancel := context.WithTimeout(context.Background(), 90*time.Second)
    	defer cancel()
    
    	bucket := getRandomBucketName()
    	err := s.client.MakeBucket(ctx, bucket, minio.MakeBucketOptions{})
    	if err != nil {
    		c.Fatalf("bucket creat error: %v", err)
    	}
    
    	// Create a policy policy
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 09:06:25 UTC 2024
    - 4K bytes
    - Viewed (0)
  9. cmd/metacache-server-pool.go

    		var c *metacache
    		if rpc == nil {
    			resp := localMetacacheMgr.getBucket(ctx, o.Bucket).findCache(*o)
    			c = &resp
    		} else {
    			rctx, cancel := context.WithTimeout(ctx, 5*time.Second)
    			c, err = rpc.GetMetacacheListing(rctx, *o)
    			cancel()
    		}
    		if err != nil {
    			if errors.Is(err, context.Canceled) {
    				// Context is canceled, return at once.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  10. internal/grid/connection.go

    	readBufferSize     = 32 << 10 // 32 KiB is the most optimal on Linux
    	writeBufferSize    = 32 << 10 // 32 KiB is the most optimal on Linux
    	defaultDialTimeout = 2 * time.Second
    	connPingInterval   = 10 * time.Second
    	connWriteTimeout   = 3 * time.Second
    )
    
    type connectionParams struct {
    	ctx           context.Context
    	id            uuid.UUID
    	local, remote string
    	handlers      *handlers
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
Back to top