Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 38 for Stale (0.01 sec)

  1. okhttp-testing-support/src/main/kotlin/okhttp3/EventListenerRelay.kt

     * on the same [call] to process the next event.
     *
     * By forcing the list of listeners to change after every event, we can detect if buggy code caches
     * a stale [EventListener] in a field or local variable.
     */
    class EventListenerRelay(
      val call: Call,
      val eventRecorder: EventRecorder,
    ) {
      private val eventListenerAdapter =
        EventListenerAdapter()
          .apply {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 05 18:28:35 UTC 2025
    - 1.5K bytes
    - Viewed (0)
  2. docs/config/README.md

    transition_workers              (number)    set the number of transition workers (default: '100')
    stale_uploads_expiry            (duration)  set to expire stale multipart uploads older than this values (default: '24h')
    stale_uploads_cleanup_interval  (duration)  set to change intervals when stale multipart uploads are expired (default: '6h')
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 18.1K bytes
    - Viewed (1)
  3. src/test/java/jcifs/SmbPipeHandleTest.java

            }
    
            /**
             * Verifies that isStale returns true for a stale handle.
             */
            @Test
            public void testIsStale_ReturnsTrueWhenStale() {
                when(smbPipeHandle.isStale()).thenReturn(true);
                assertTrue(smbPipeHandle.isStale(), "isStale() should return true for a stale handle.");
            }
        }
    
        /**
         * Tests the unwrap functionality.
         */
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 7K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/helper/DataIndexHelper.java

                    final long numOfDeleted = searchEngineClient.deleteByQuery(index, queryBuilder);
                    logger.info("[{}] Deleted {} stale documents.", dataConfig.getName(), numOfDeleted);
                } catch (final Exception e) {
                    logger.error("[{}] Failed to delete stale documents.", dataConfig.getName(), e);
                }
            }
    
            /**
             * Checks if the crawling thread has finished execution.
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 19K bytes
    - Viewed (0)
  5. cmd/erasure-heal_test.go

    }
    
    func TestErasureHeal(t *testing.T) {
    	for i, test := range erasureHealTests {
    		if test.offDisks < test.badStaleDisks {
    			// test case sanity check
    			t.Fatalf("Test %d: Bad test case - number of stale drives cannot be less than number of badstale drives", i)
    		}
    
    		// create some test data
    		setup, err := newErasureTestSetup(t, test.dataBlocks, test.disks-test.dataBlocks, test.blocksize)
    		if err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  6. src/test/java/jcifs/smb/SmbPipeHandleInternalTest.java

            // Simulate invalidation
            assertFalse(handle.isOpen(), "Becomes not open when underlying handle invalid");
    
            // After close, report stale
            handle.close();
            assertTrue(handle.isStale(), "Closed handle reports stale");
        }
    
        @Test
        @DisplayName("getSessionKey propagates CIFSException from session acquisition")
        void getSessionKey_exception_propagates() throws Exception {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 16.7K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Cache.kt

     *   // The resource was cached! Show it.
     * } else {
     *   // The resource was not cached.
     * }
     * ```
     *
     * This technique works even better in situations where a stale response is better than no response.
     * To permit stale cached responses, use the `max-stale` directive with the maximum staleness in
     * seconds:
     *
     * ```java
     * Request request = new Request.Builder()
     *     .cacheControl(new CacheControl.Builder()
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Oct 03 17:41:45 UTC 2025
    - 26.8K bytes
    - Viewed (0)
  8. src/test/java/jcifs/dcerpc/DcerpcPipeHandleTest.java

                assertEquals(80, result);
                verify(mockSmbPipeHandleInternal).recv(inB, 40, 40);
            }
    
            @Test
            @DisplayName("Should throw IOException when handle is stale")
            void testDoSendReceiveFragment_StaleHandle() throws Exception {
                DcerpcPipeHandle handle = createMockedDcerpcPipeHandle();
                when(mockSmbPipeHandleInternal.isStale()).thenReturn(true);
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 21K bytes
    - Viewed (0)
  9. docs/works_with_okhttp.md

     * [okhttp-spring-boot](https://github.com/freefair/okhttp-spring-boot): Spring Boot starters for OkHttp
     * [okhttp-staleiferror-interceptor](https://github.com/PeelTechnologies/okhttp-staleiferror-interceptor/): serve stale responses when the server isn’t reachable.
     * [okhttp-stats](https://github.com/flipkart-incubator/okhttp-stats): Get stats like average network speed.
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 26 07:59:38 UTC 2025
    - 3.8K bytes
    - Viewed (0)
  10. cmd/bucket-metadata-sys.go

    	sys.Lock()
    	for _, bucket := range buckets {
    		sys.group.Forget(bucket)
    		delete(sys.metadataMap, bucket)
    		globalBucketMonitor.DeleteBucket(bucket)
    	}
    	sys.Unlock()
    }
    
    // RemoveStaleBuckets removes all stale buckets in memory that are not on disk.
    func (sys *BucketMetadataSys) RemoveStaleBuckets(diskBuckets set.StringSet) {
    	sys.Lock()
    	defer sys.Unlock()
    
    	for bucket := range sys.metadataMap {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.4K bytes
    - Viewed (0)
Back to top