Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for successors (0.07 sec)

  1. src/main/java/jcifs/util/SimpleCircuitBreaker.java

            if (current == State.HALF_OPEN) {
                int successes = halfOpenSuccesses.incrementAndGet();
                if (successes >= successThreshold) {
                    if (state.compareAndSet(State.HALF_OPEN, State.CLOSED)) {
                        stateChangeTime.set(System.currentTimeMillis());
                        log.info("Circuit breaker {} closed after {} successful attempts", name, successes);
                    }
                }
            }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 11.3K bytes
    - Viewed (0)
  2. src/main/java/jcifs/util/SmbCircuitBreaker.java

            if (currentState == State.HALF_OPEN) {
                int successes = successCount.incrementAndGet();
                log.debug("[{}] Success in HALF_OPEN state ({}/{})", name, successes, successThreshold);
    
                if (successes >= successThreshold) {
                    log.info("[{}] Circuit breaker closing after {} successful attempts", name, successes);
                    transitionTo(State.CLOSED);
                }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 33.4K bytes
    - Viewed (0)
  3. src/test/java/jcifs/util/SmbCircuitBreakerTest.java

            assertEquals(State.HALF_OPEN, circuitBreaker.getState(), "Should be in HALF_OPEN after first success");
    
            // Need successThreshold (2) consecutive successes to close the circuit
            // Second success should close the circuit (threshold is 2)
            result = circuitBreaker.executeWithCircuitBreaker(() -> "success 1");
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 23.2K bytes
    - Viewed (0)
  4. src/test/java/jcifs/util/SimpleCircuitBreakerTest.java

                                breaker.call(() -> {
                                    throw new RuntimeException("Test");
                                });
                            } else {
                                // Some successes
                                breaker.call(() -> "success");
                                successCount.incrementAndGet();
                            }
                        } catch (Exception e) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 10.6K bytes
    - Viewed (0)
  5. cmd/tier_test.go

    		switch metric.Description.Name {
    		case tierRequestsSuccess:
    			succ += metric.Value
    		case tierRequestsFailure:
    			fail += metric.Value
    		}
    	}
    	if int(succ) != expSuccess {
    		t.Fatalf("Expected %d successes but got %f", expSuccess, succ)
    	}
    	if int(fail) != expFailure {
    		t.Fatalf("Expected %d failures but got %f", expFailure, fail)
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 1.5K bytes
    - Viewed (0)
  6. cmd/erasure-metadata_test.go

    			if ok1 != ok2 {
    				t.Errorf("Expected %s, got %s", test.expectedErr, err)
    			}
    			if test.succmodTimes != nil {
    				if !test.expectedSuccModTime.Equal(fi.SuccessorModTime) {
    					t.Errorf("Expected successor mod time to be %v but got %v", test.expectedSuccModTime, fi.SuccessorModTime)
    				}
    				if test.expectedIsLatest != fi.IsLatest {
    					t.Errorf("Expected IsLatest to be %v but got %v", test.expectedIsLatest, fi.IsLatest)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.4K bytes
    - Viewed (0)
  7. cmd/object-api-datatypes.go

    	replicationDecision string // internal representation of replication decision for use by DeleteObject handler
    	// The total count of all versions of this object
    	NumVersions int
    	//  The modtime of the successor object version if any
    	SuccessorModTime time.Time
    
    	// Checksums added on upload.
    	// Encoded, maybe encrypted.
    	Checksum []byte
    
    	// Inlined
    	Inlined bool
    
    	DataBlocks   int
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21.2K bytes
    - Viewed (0)
  8. cmd/erasure-metadata.go

    	}
    
    	// objProps represents properties that go beyond a single version
    	type objProps struct {
    		succModTime time.Time
    		numVersions int
    	}
    	// Find the successor mod time and numVersions in quorum, otherwise leave the
    	// candidate as found
    	otherPropsMap := make(counterMap[objProps])
    	var candidate FileInfo
    	var found bool
    	for i, hash := range metaHashes {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21.3K bytes
    - Viewed (0)
  9. docs/en/docs/alternatives.md

    Then APIStar stopped to exist as a server and Starlette was created, and was a new better foundation for such a system. That was the final inspiration to build **FastAPI**.
    
    I consider **FastAPI** a "spiritual successor" to APIStar, while improving and increasing the features, typing system, and other parts, based on the learnings from all these previous tools.
    
    ///
    
    ## Used by **FastAPI** { #used-by-fastapi }
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:15:41 UTC 2025
    - 23.6K bytes
    - Viewed (0)
  10. CHANGELOG/CHANGELOG-1.34.md

    - Added `started_user_namespaced_pods_total` and `started_user_namespaced_pods_errors_total` for tracking the successes and failures in creating pods if a user namespace was requested. ([#132902](https://github.com/kubernetes/kubernetes/pull/132902), [@haircommander](https://github.com/haircommander)) [SIG Node and Testing]
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Wed Aug 27 10:36:10 UTC 2025
    - 292.8K bytes
    - Viewed (1)
Back to top