- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 790 for stiate (0.06 sec)
-
cmd/admin-heal-ops.go
} // newHealState - initialize global heal state management func newHealState(ctx context.Context, cleanup bool) *allHealState { hstate := &allHealState{ healSeqMap: make(map[string]*healSequence), healLocalDisks: make(map[Endpoint]bool), healStatus: make(map[string]healingTracker), } if cleanup { go hstate.periodicHealSeqsClean(ctx) } return hstate }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 25.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
assertThat(limiter.getRate()).isEqualTo(5.0); limiter.setRate(10.0); assertThat(limiter.getRate()).isEqualTo(10.0); assertThrows(IllegalArgumentException.class, () -> limiter.setRate(0.0)); assertThrows(IllegalArgumentException.class, () -> limiter.setRate(-10.0)); assertThrows(IllegalArgumentException.class, () -> limiter.setRate(Double.NaN)); } public void testAcquireParameterValidation() {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 21.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
assertThat(limiter.getRate()).isEqualTo(5.0); limiter.setRate(10.0); assertThat(limiter.getRate()).isEqualTo(10.0); assertThrows(IllegalArgumentException.class, () -> limiter.setRate(0.0)); assertThrows(IllegalArgumentException.class, () -> limiter.setRate(-10.0)); assertThrows(IllegalArgumentException.class, () -> limiter.setRate(Double.NaN)); } public void testAcquireParameterValidation() {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 21.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/sso/aad/AzureAdAuthenticator.java
} } /** * Validates the OAuth2 state parameter. * @param session The HTTP session containing stored state data. * @param state The state parameter to validate. * @return The validated state data. */ protected StateData validateState(final HttpSession session, final String state) { if (StringUtils.isNotEmpty(state)) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 28 09:13:08 UTC 2025 - 37.3K bytes - Viewed (0) -
cmd/admin-handlers-site-replication.go
} // SRStateEdit - PUT /minio/admin/v3/site-replication/state/edit // // used internally to tell current cluster to update site replication state func (a adminAPIHandlers) SRStateEdit(w http.ResponseWriter, r *http.Request) { ctx := r.Context() objectAPI, _ := validateAdminReq(ctx, w, r, policy.SiteReplicationOperationAction) if objectAPI == nil { return } var state madmin.SRStateEditReq
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 19.3K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/rdma/RdmaIntegrationTest.java
RdmaStatistics stats = new RdmaStatistics(); // Simulate various RDMA operations stats.recordRdmaRead(1024, 1000000); // 1KB in 1ms stats.recordRdmaWrite(2048, 2000000); // 2KB in 2ms stats.recordRdmaSend(512, 500000); // 512B in 0.5ms stats.recordRdmaReceive(1536, 1500000); // 1.5KB in 1.5ms stats.recordError(); // Verify counters
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 13.8K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/interval/IntervalController.java
* different types of processing states and a method to introduce a delay * based on the type of processing. * <p> * Constants: * </p> * <ul> * <li>{@code PRE_PROCESSING} - Represents the pre-processing state.</li> * <li>{@code POST_PROCESSING} - Represents the post-processing state.</li> * <li>{@code NO_URL_IN_QUEUE} - Indicates that there are no URLs in the queue.</li>
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 1.8K bytes - Viewed (0) -
.github/workflows/stale.yml
name: "Stale" on: schedule: - cron: "0 2 * * *" permissions: contents: read jobs: stale: permissions: issues: write # for actions/stale to close stale issues pull-requests: write # for actions/stale to close stale PRs runs-on: ubuntu-latest env: ACTIONS_STEP_DEBUG: true steps: - name: Close Stale Issues uses: actions/stale@v8 with:
Registered: Sun Sep 07 09:35:13 UTC 2025 - Last Modified: Tue Apr 11 02:27:05 UTC 2023 - 972 bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/lease/DirectoryLeaseState.java
/** * Check if directory can cache enumeration results * @param state lease state * @return true if directory enumeration can be cached */ public static boolean canCacheEnumeration(int state) { return Smb2LeaseState.hasReadCaching(state); } /** * Check if directory can keep handles open * @param state lease state * @return true if directory handles can be kept open */
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 02:21:31 UTC 2025 - 2.5K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/lease/Smb2LeaseStateTest.java
import org.junit.jupiter.api.DisplayName; import org.junit.jupiter.api.Test; @DisplayName("Smb2LeaseState Tests") class Smb2LeaseStateTest { @Test @DisplayName("Should define correct lease state constants") void testLeaseStateConstants() { assertEquals(0x00, Smb2LeaseState.SMB2_LEASE_NONE); assertEquals(0x01, Smb2LeaseState.SMB2_LEASE_READ_CACHING);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 00:16:17 UTC 2025 - 5.2K bytes - Viewed (0)