Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 128 for Decrement (0.2 sec)

  1. 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)
  2. pkg/xds/monitoring.go

    	totalXDSRejects.With(typeTag.Value(model.GetMetricType(xdsType))).Increment()
    	switch xdsType {
    	case model.ListenerType:
    		ldsReject.With(nodeTag.Value(node), errTag.Value(errCode)).Increment()
    	case model.ClusterType:
    		cdsReject.With(nodeTag.Value(node), errTag.Value(errCode)).Increment()
    	case model.EndpointType:
    		edsReject.With(nodeTag.Value(node), errTag.Value(errCode)).Increment()
    	case model.RouteType:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 00:26:45 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  3. guava-testlib/src/com/google/common/testing/FakeTicker.java

        checkArgument(autoIncrementStep >= 0, "May not auto-increment by a negative amount");
        this.autoIncrementStepNanos = timeUnit.toNanos(autoIncrementStep);
        return this;
      }
    
      /**
       * Sets the increment applied to the ticker whenever it is queried.
       *
       * <p>The default behavior is to auto increment by zero. i.e: The ticker is left unchanged when
       * queried.
       *
       * @since 28.0
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Feb 06 14:40:46 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  4. pkg/webhooks/monitoring.go

    func reportWebhookPatchAttempts(webhookConfigName string) {
    	metricWebhookPatchAttempts.
    		With(webhookConfigNameTag.Value(webhookConfigName)).
    		Increment()
    }
    
    func reportWebhookPatchRetry(webhookConfigName string) {
    	metricWebhookPatchRetries.
    		With(webhookConfigNameTag.Value(webhookConfigName)).
    		Increment()
    }
    
    func reportWebhookPatchFailure(webhookConfigName string, reason string) {
    	metricWebhookPatchFailures.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jul 17 20:25:52 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  5. pkg/webhooks/validation/controller/monitoring.go

    	metricWebhookConfigurationUpdateError.With(reasonLabel.Value(string(reason))).Increment()
    }
    
    func reportValidationConfigLoadError(reason string) {
    	metricWebhookConfigurationLoadError.With(reasonLabel.Value(reason)).Increment()
    }
    
    func reportValidationConfigUpdate() {
    	metricWebhookConfigurationUpdates.Increment()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jul 17 20:25:52 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  6. pilot/pkg/xds/monitoring.go

    		// TODO use a single metric with a type tag
    		switch xdsType {
    		case v3.ListenerType:
    			ldsSendErrPushes.Increment()
    		case v3.ClusterType:
    			cdsSendErrPushes.Increment()
    		case v3.EndpointType:
    			edsSendErrPushes.Increment()
    		case v3.RouteType:
    			rdsSendErrPushes.Increment()
    		}
    		return true
    	}
    	return false
    }
    
    func recordPushTime(xdsType string, duration time.Duration) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 00:26:45 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/strategy_test.go

    		old           *unstructured.Unstructured
    		obj           *unstructured.Unstructured
    		statusEnabled bool
    		expected      *unstructured.Unstructured
    	}{
    		{
    			name:          "/status is enabled, spec changes increment generation",
    			statusEnabled: true,
    			old: &unstructured.Unstructured{
    				Object: map[string]interface{}{
    					"metadata": generation1(),
    					"spec":     "old",
    					"status":   "old",
    				},
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  8. android/guava-testlib/src/com/google/common/testing/FakeTicker.java

        checkArgument(autoIncrementStep >= 0, "May not auto-increment by a negative amount");
        this.autoIncrementStepNanos = timeUnit.toNanos(autoIncrementStep);
        return this;
      }
    
      /**
       * Sets the increment applied to the ticker whenever it is queried.
       *
       * <p>The default behavior is to auto increment by zero. i.e: The ticker is left unchanged when
       * queried.
       *
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Mar 13 18:17:09 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  9. platforms/ide/tooling-api-builders/src/main/java/org/gradle/tooling/internal/provider/runner/ProjectConfigurationTracker.java

            void increment(PluginApplication pluginApplication, long duration) {
                InternalPluginIdentifier plugin = pluginApplication.getPlugin();
                pluginApplicationResults
                    .computeIfAbsent(plugin, key -> new PluginApplicationResult(plugin, pluginApplication.getApplicationId()))
                    .increment(duration);
            }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Sep 26 14:49:20 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  10. pkg/webhooks/validation/server/monitoring.go

    		With(ResourceTag.Value(request.Resource.Resource)).
    		With(ReasonTag.Value(reason)).
    		Increment()
    }
    
    func reportValidationPass(request *kube.AdmissionRequest) {
    	metricValidationPassed.
    		With(GroupTag.Value(request.Resource.Group)).
    		With(VersionTag.Value(request.Resource.Version)).
    		With(ResourceTag.Value(request.Resource.Resource)).
    		Increment()
    }
    
    func reportValidationHTTPError(status int) {
    	metricValidationHTTPError.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Aug 09 16:50:34 UTC 2023
    - 2.6K bytes
    - Viewed (0)
Back to top