Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for Rollback (0.33 sec)

  1. guava/src/com/google/common/primitives/UnsignedBytes.java

                && (BYTE_ARRAY_BASE_OFFSET % 8) == 0
                // sanity check - this should never fail
                && theUnsafe.arrayIndexScale(byte[].class) == 1)) {
              throw new Error(); // force fallback to PureJavaComparator
            }
          }
    
          /**
           * Returns a sun.misc.Unsafe. Suitable for use in a 3rd party package. Replace with a simple
           * call to Unsafe.getUnsafe when integrating into a jdk.
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

      }
    
      // Regression test for a case where we would fail to execute listeners immediately on done futures
      // this would be observable from an afterDone callback
      public void testListenersExecuteImmediately_fromAfterDone() {
        AbstractFuture<String> f =
            new AbstractFuture<String>() {
              @Override
              protected void afterDone() {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

            output.cancel(false);
            throw new MyRuntimeException();
          }
        }
        Fallback fallback = new Fallback();
        SettableFuture<Object> input = SettableFuture.create();
    
        ListenableFuture<Object> output = catching(input, Throwable.class, fallback, directExecutor());
        fallback.output = output;
    
        input.setException(new MyException());
        assertTrue(output.isCancelled());
      }
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 29 16:29:37 UTC 2024
    - 144.1K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

            output.cancel(false);
            throw new MyRuntimeException();
          }
        }
        Fallback fallback = new Fallback();
        SettableFuture<Object> input = SettableFuture.create();
    
        ListenableFuture<Object> output = catching(input, Throwable.class, fallback, directExecutor());
        fallback.output = output;
    
        input.setException(new MyException());
        assertTrue(output.isCancelled());
      }
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 29 16:29:37 UTC 2024
    - 144.1K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/hash/LittleEndianByteArray.java

     *
     * @author Kevin Damm
     * @author Kyle Maddison
     */
    @ElementTypesAreNonnullByDefault
    final class LittleEndianByteArray {
    
      /** The instance that actually does the work; delegates to Unsafe or a pure-Java fallback. */
      private static final LittleEndianBytes byteArray;
    
      /**
       * Load 8 bytes into long in a little endian manner, from the substring between position and
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/hash/Striped64.java

      /** Table of cells. When non-null, size is a power of 2. */
      @CheckForNull transient volatile Cell[] 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: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/primitives/UnsignedBytes.java

                && (BYTE_ARRAY_BASE_OFFSET % 8) == 0
                // sanity check - this should never fail
                && theUnsafe.arrayIndexScale(byte[].class) == 1)) {
              throw new Error(); // force fallback to PureJavaComparator
            }
          }
    
          /**
           * Returns a sun.misc.Unsafe. Suitable for use in a 3rd party package. Replace with a simple
           * call to Unsafe.getUnsafe when integrating into a jdk.
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

            // Some Android 5.0.x Samsung devices have bugs in JDK reflection APIs that cause
            // getDeclaredField to throw a NoSuchFieldException when the field is definitely there.
            // For these users fallback to a suboptimal implementation, based on synchronized. This will
            // be a definite performance hit to those users.
            thrownAtomicReferenceFieldUpdaterFailure = atomicReferenceFieldUpdaterFailure;
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 63.1K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/AbstractFuture.java

            // Some Android 5.0.x Samsung devices have bugs in JDK reflection APIs that cause
            // getDeclaredField to throw a NoSuchFieldException when the field is definitely there.
            // For these users fallback to a suboptimal implementation, based on synchronized. This will
            // be a definite performance hit to those users.
            thrownAtomicReferenceFieldUpdaterFailure = atomicReferenceFieldUpdaterFailure;
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 62.8K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

       *   <li>If an exception propagates out of a {@code Runnable}, it is not necessarily seen by any
       *       {@code UncaughtExceptionHandler} for the thread. For example, if the callback passed to
       *       {@link Futures#addCallback} throws an exception, that exception will be typically be
       *       logged by the {@link ListenableFuture} implementation, even if the thread is configured
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 15 10:40:05 UTC 2024
    - 39K bytes
    - Viewed (0)
Back to top