Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1581 - 1590 of 4,785 for New (0.03 sec)

  1. guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

      }
    
      public void testListenersNotifiedOnError() throws Exception {
        CountDownLatch successLatch = new CountDownLatch(1);
        CountDownLatch listenerLatch = new CountDownLatch(1);
    
        ExecutorService exec = Executors.newCachedThreadPool();
    
        future.addListener(listenerLatch::countDown, exec);
    
        new Thread(
                () -> {
                  assertThrows(CancellationException.class, future::get);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 18:30:30 UTC 2023
    - 6K bytes
    - Viewed (0)
  2. compat/maven-compat/src/main/java/org/apache/maven/repository/metadata/DefaultGraphConflictResolver.java

            if (policy == null) {
                throw new GraphConflictResolutionException("no GraphConflictResolutionPolicy injected");
            }
    
            if (graph == null) {
                return null;
            }
    
            final MetadataGraphVertex entry = graph.getEntry();
            if (entry == null) {
                return null;
            }
    
            if (graph.isEmpty()) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  3. cmd/warm-backend-s3.go

    		return nil, errors.New("AWS Role cannot be activated with static credentials or the web identity token file")
    	case conf.Bucket == "":
    		return nil, errors.New("no bucket name was provided")
    	}
    
    	// Credentials initialization
    	var creds *credentials.Credentials
    	switch {
    	case conf.AWSRole:
    		creds = credentials.New(&credentials.IAM{
    			Client: &http.Client{
    				Transport: NewHTTPTransport(),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedInputs.java

      static final RuntimeException RUNTIME_EXCEPTION = new RuntimeException();
      static final OtherThrowable OTHER_THROWABLE = new OtherThrowable();
      static final Future<String> FAILED_FUTURE_OTHER_THROWABLE =
          immediateFailedFuture(OTHER_THROWABLE);
      static final Error ERROR = new Error("mymessage");
      static final Future<String> FAILED_FUTURE_ERROR = immediateFailedFuture(ERROR);
      static final Future<String> RUNTIME_EXCEPTION_FUTURE =
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 13:46:56 UTC 2023
    - 6.2K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb1/http/Handler.java

        protected int getDefaultPort() {
            return DEFAULT_HTTP_PORT;
        }
    
        protected URLConnection openConnection(URL url) throws IOException {
            url = new URL(url, url.toExternalForm(),
                    getDefaultStreamHandler(url.getProtocol()));
            return new NtlmHttpURLConnection((HttpURLConnection)
                    url.openConnection());
        }
    
        private static URLStreamHandler getDefaultStreamHandler(String protocol)
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 6.1K bytes
    - Viewed (0)
  6. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/source/model/TypeMetaData.java

            }
            TypeMetaData rawType = new TypeMetaData(name);
            rawType.arrayDimensions = arrayDimensions;
            if (varargs) {
                rawType.arrayDimensions++;
            }
            return rawType;
        }
    
        public String getSignature() {
            final StringBuilder builder = new StringBuilder();
    
            visitSignature(new SignatureVisitor() {
                @Override
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Wed Dec 09 08:14:05 UTC 2020
    - 6.1K bytes
    - Viewed (0)
  7. guava-tests/benchmark/com/google/common/math/IntMathBenchmark.java

     */
    public class IntMathBenchmark {
      private static int[] exponent = new int[ARRAY_SIZE];
      private static int[] factorial = new int[ARRAY_SIZE];
      private static int[] binomial = new int[ARRAY_SIZE];
      private static final int[] positive = new int[ARRAY_SIZE];
      private static final int[] nonnegative = new int[ARRAY_SIZE];
      private static final int[] ints = new int[ARRAY_SIZE];
    
      @BeforeExperiment
      void setUp() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 3.2K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

        checkNotNull(unit);
        final Thread interruptee = Thread.currentThread();
        new Thread(
                new Runnable() {
                  @Override
                  public void run() {
                    try {
                      unit.sleep(time);
                    } catch (InterruptedException wontHappen) {
                      throw new AssertionError(wontHappen);
                    }
                    interruptee.interrupt();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 4.4K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb/SmbWatchHandleImpl.java

                        throw new SmbUnsupportedOperationException("Not supported without CAP_NT_SMBS");
                    }
    
                    /*
                     * NtTrans Notify Change Request / Response
                     */
                    req = new NtTransNotifyChange(th.getConfig(), this.handle.getFid(), this.filter, this.recursive);
                    resp = new NtTransNotifyChangeResponse(th.getConfig());
                }
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 4.5K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb1/util/HMACT64.java

        private static final byte IPAD = (byte) 0x36;
    
        private static final byte OPAD = (byte) 0x5c;
    
        private MessageDigest md5;
    
        private byte[] ipad = new byte[BLOCK_LENGTH];
    
        private byte[] opad = new byte[BLOCK_LENGTH];
    
        /**
         * Creates an HMACT64 instance which uses the given secret key material.
         *
         * @param key The key material to use in hashing.
         */
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 3.4K bytes
    - Viewed (0)
Back to top