Search Options

Results per page
Sort
Preferred Languages
Advance

Results 301 - 310 of 401 for rollback (0.05 sec)

  1. android/guava/src/com/google/common/io/TempFileCreator.java

             * were running under a new enough version of Android to support NIO.
             *
             * So this is probably just the "Windows Java 8" case. In that case, if we wanted *another*
             * layer of fallback before consulting the system property, we could try
             * com.sun.security.auth.module.NTSystem.
             *
             * But for now, we use the value from the system property as our best guess.
             */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  2. docs/recipes.md

            }
          }
        ```
    
    ### Asynchronous Get ([.kt][AsynchronousGetKotlin], [.java][AsynchronousGetJava])
    
    Download a file on a worker thread, and get called back when the response is readable. The callback is made after the response headers are ready. Reading the response body may still block. OkHttp doesn't currently offer asynchronous APIs to receive a response body in parts.
    
    === ":material-language-kotlin: Kotlin"
        ```kotlin
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 17:01:12 UTC 2025
    - 47.8K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt

    import java.net.SocketTimeoutException
    import java.util.ArrayDeque
    import java.util.Random
    import java.util.concurrent.TimeUnit
    import java.util.concurrent.TimeUnit.MILLISECONDS
    import okhttp3.Call
    import okhttp3.Callback
    import okhttp3.EventListener
    import okhttp3.OkHttpClient
    import okhttp3.Protocol
    import okhttp3.Request
    import okhttp3.Response
    import okhttp3.WebSocket
    import okhttp3.WebSocketListener
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 21.6K bytes
    - Viewed (0)
  4. src/test/java/org/codelibs/fess/job/PingSearchEngineJobTest.java

            // Assert
            assertEquals("Status of test-cluster is changed to RED.", result);
            // Note: Notification sending is tested but we don't verify the mock since it uses complex callback mechanism
        }
    
        // Test state change with empty notification addresses
        public void test_execute_stateChangeEmptyNotificationAddresses() {
            // Setup mock components
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 18.8K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/cache/Striped64.java

      /** Table of cells. When non-null, size is a power of 2. */
      transient volatile Cell @Nullable [] cells;
    
      /**
       * Base value, used mainly when there is no contention, but also as a fallback during table
       * initialization races. Updated via CAS.
       */
      transient volatile long base;
    
      /** Spinlock (locked via CAS) used when resizing and/or creating Cells. */
      transient volatile int busy;
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jan 15 22:17:15 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/Service.java

       * logged.
       *
       * @param listener the listener to run when the service changes state is complete
       * @param executor the executor in which the listeners callback methods will be run. For fast,
       *     lightweight listeners that would be safe to execute in any thread, consider {@link
       *     MoreExecutors#directExecutor}.
       * @since 13.0
       */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  7. cmd/erasure-healing-common.go

    	if modTime.IsZero() || modTime.Equal(timeSentinel) {
    		etags := listObjectETags(partsMetadata, errs, quorum)
    
    		etag = commonETag(etags, quorum)
    
    		if etag != "" { // allow this fallback only if a non-empty etag is found.
    			for index, e := range etags {
    				if partsMetadata[index].IsValid() && e == etag {
    					onlineDisks[index] = disks[index]
    				} else {
    					onlineDisks[index] = nil
    				}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 12K bytes
    - Viewed (0)
  8. src/test/java/jcifs/smb/SmbTreeHandleImplTest.java

            assertTrue(handle.areSignaturesActive());
    
            verify(session, times(4)).close();
            verify(transport, times(4)).close();
        }
    
        @Test
        @DisplayName("isSMB2 true and exception fallback to false")
        void isSMB2Cases() throws Exception {
            // Happy path returns true; transport exception path returns false
            when(transport.isSMB2()).thenReturn(true);
            assertTrue(handle.isSMB2());
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 14.4K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

       * documentation.
       *
       * @param listener the listener to run when the manager changes state
       * @param executor the executor in which the listeners callback methods will be run.
       */
      public void addListener(Listener listener, Executor executor) {
        state.addListener(listener, executor);
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 33.2K bytes
    - Viewed (1)
  10. src/main/java/org/codelibs/fess/util/ResourceUtil.java

        }
    
        /**
         * Gets the path by trying multiple locations in order of preference.
         * First tries to get the real path from servlet context, then checks various
         * fallback locations including source and target directories.
         *
         * @param root the root directory (e.g., "WEB-INF/")
         * @param base the base directory under root (e.g., "conf", "classes")
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 14.1K bytes
    - Viewed (0)
Back to top