- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for Decrement (1.05 sec)
-
analysis/analysis-api/src/org/jetbrains/kotlin/analysis/api/resolution/KaCompoundAccess.kt
public enum class Kind { PLUS_ASSIGN, MINUS_ASSIGN, TIMES_ASSIGN, DIV_ASSIGN, REM_ASSIGN } } /** * A compound access that read, increment or decrement, and write the computed value back. */ public class IncOrDecOperation( operationPartiallyAppliedSymbol: KaPartiallyAppliedFunctionSymbol<KaFunctionSymbol>, kind: Kind,
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Wed Jun 05 16:16:39 UTC 2024 - 2.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java
abstract void compareAndSetSeenExceptions( AggregateFutureState<?> state, @CheckForNull Set<Throwable> expect, Set<Throwable> update); /** Atomic decrement-and-get of the {@link AggregateFutureState#remaining} field. */ abstract int decrementAndGetRemainingCount(AggregateFutureState<?> state); } private static final class SafeAtomicHelper extends AtomicHelper {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 28 20:40:51 UTC 2024 - 8.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AggregateFutureState.java
abstract void compareAndSetSeenExceptions( AggregateFutureState<?> state, @CheckForNull Set<Throwable> expect, Set<Throwable> update); /** Atomic decrement-and-get of the {@link AggregateFutureState#remaining} field. */ abstract int decrementAndGetRemainingCount(AggregateFutureState<?> state); } private static final class SafeAtomicHelper extends AtomicHelper {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 28 20:40:51 UTC 2024 - 8.4K bytes - Viewed (0) -
src/sync/waitgroup.go
if race.Enabled { if delta < 0 { // Synchronize decrements with Wait. race.ReleaseMerge(unsafe.Pointer(wg)) } race.Disable() defer race.Enable() } state := wg.state.Add(uint64(delta) << 32) v := int32(state >> 32) w := uint32(state) if race.Enabled && delta > 0 && v == int32(delta) { // The first increment must be synchronized with Wait. // Need to model this as a read, because there can be
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 4K bytes - Viewed (0) -
cmd/kube-controller-manager/app/options/persistentvolumebindercontroller.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 02:59:09 UTC 2024 - 4.8K bytes - Viewed (0) -
security/pkg/server/ca/server.go
func (s *Server) CreateCertificate(ctx context.Context, request *pb.IstioCertificateRequest) ( *pb.IstioCertificateResponse, error, ) { s.monitoring.CSR.Increment() caller, err := security.Authenticate(ctx, s.Authenticators) if caller == nil || err != nil { s.monitoring.AuthnError.Increment() return nil, status.Error(codes.Unauthenticated, "request authenticate failure") }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 28 17:35:26 UTC 2024 - 8K bytes - Viewed (0) -
src/cmd/go/internal/telemetrystats/telemetrystats_bootstrap.go
// Copyright 2024 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. //go:build cmd_go_bootstrap package telemetrystats
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:09:11 UTC 2024 - 233 bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/config/types.go
// pod. MinimumTimeoutNFS int32 // podTemplateFilePathNFS is the file path to a pod definition used as a template for // NFS persistent volume recycling PodTemplateFilePathNFS string // incrementTimeoutNFS is the increment of time added per Gi to ActiveDeadlineSeconds // for an NFS scrubber pod. IncrementTimeoutNFS int32 // podTemplateFilePathHostPath is the file path to a pod definition used as a template for
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 02:59:09 UTC 2024 - 3.8K bytes - Viewed (0) -
src/cmd/go/internal/telemetrystats/telemetrystats.go
//go:build !cmd_go_bootstrap package telemetrystats import ( "cmd/go/internal/base" "cmd/go/internal/cfg" "cmd/go/internal/modload" "cmd/internal/telemetry" ) func Increment() { incrementConfig() incrementVersionCounters() } // incrementConfig increments counters for the configuration // the command is running in. func incrementConfig() { if !modload.WillBeEnabled() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:09:11 UTC 2024 - 1.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/DirectExecutorService.java
private void startTask() { synchronized (lock) { if (shutdown) { throw new RejectedExecutionException("Executor already shutdown"); } runningTasks++; } } /** Decrements the running task count. */ private void endTask() { synchronized (lock) { int numRunning = --runningTasks; if (numRunning == 0) { lock.notifyAll(); } } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 15 10:40:05 UTC 2024 - 3.5K bytes - Viewed (0)