Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 182 for checkMd5 (0.16 sec)

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

     * array. If any method encounters the end of the array prematurely, it throws {@link
     * IllegalStateException} to signify <i>programmer error</i>. This behavior is a technical violation
     * of the supertype's contract, which specifies a checked exception.
     *
     * @author Kevin Bourrillion
     * @since 1.0
     */
    @J2ktIncompatible
    @GwtIncompatible
    @ElementTypesAreNonnullByDefault
    public interface ByteArrayDataInput extends DataInput {
      @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 28 20:13:02 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/collect/Streams.java

          } catch (Exception e) { // sneaky checked exception
            if (exception == null) {
              exception = e;
            } else {
              exception.addSuppressed(e);
            }
          }
        }
        if (exception != null) {
          // Normally this is a RuntimeException that doesn't need sneakyThrow.
          // But theoretically we could see sneaky checked exception
          sneakyThrow(exception);
        }
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 37.4K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

       *   <li>To treat {@link InterruptedException} uniformly with other exceptions, use {@link
       *       Futures#getChecked(Future, Class) Futures.getChecked}.
       *   <li>To get uninterruptibility and remove checked exceptions, use {@link
       *       Futures#getUnchecked}.
       * </ul>
       *
       * @throws ExecutionException if the computation threw an exception
       * @throws CancellationException if the computation was cancelled
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  4. cmd/metacache-walk.go

    		}
    		return nil
    	}
    
    	// Stream output.
    	return scanDir(opts.BaseDir)
    }
    
    func (p *xlStorageDiskIDCheck) WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) (err error) {
    	if err := p.checkID(opts.DiskID); err != nil {
    		return err
    	}
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricWalkDir, opts.Bucket, opts.BaseDir)
    	if err != nil {
    		return err
    	}
    	defer done(0, &err)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  5. android/guava-tests/benchmark/com/google/common/util/concurrent/FuturesGetCheckedBenchmark.java

        FAILURE(immediateFailedFuture(new Exception()));
    
        final Future<Object> future;
    
        Result(Future<Object> result) {
          this.future = result;
        }
      }
    
      private enum ExceptionType {
        CHECKED(IOException.class),
        UNCHECKED(RuntimeException.class);
    
        final Class<? extends Exception> exceptionType;
    
        ExceptionType(Class<? extends Exception> exceptionType) {
          this.exceptionType = exceptionType;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Mar 22 03:01:34 UTC 2022
    - 6.5K bytes
    - Viewed (0)
  6. internal/pubsub/pubsub.go

    					continue
    				case <-doneCh:
    					return
    				}
    			}
    		}
    	}()
    
    	return nil
    }
    
    // NumSubscribers returns the number of current subscribers,
    // The mask is checked against the active subscribed types,
    // and 0 will be returned if nobody is subscribed for the type(s).
    func (ps *PubSub[T, M]) NumSubscribers(mask M) int32 {
    	types := Mask(atomic.LoadUint64(&ps.types))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 16:57:30 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  7. istioctl/pkg/writer/pilot/status.go

    				listenerStatus:        lds,
    				routeStatus:           rds,
    				endpointStatus:        eds,
    				extensionconfigStatus: ecds,
    			})
    			if len(fullStatus) == 0 {
    				return nil, nil, fmt.Errorf("no proxies found (checked %d istiods)", len(drs))
    			}
    
    			sort.Slice(fullStatus, func(i, j int) bool {
    				return fullStatus[i].proxyID < fullStatus[j].proxyID
    			})
    		}
    	}
    	if len(mappedResp) > 0 {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 21 22:47:20 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  8. src/main/webapp/js/admin/jquery-3.7.1.min.js

    /i,Ce=/^$|^module$|\/(?:java|ecma)script/i;xe=C.createDocumentFragment().appendChild(C.createElement("div")),(be=C.createElement("input")).setAttribute("type","radio"),be.setAttribute("checked","checked"),be.setAttribute("name","t"),xe.appendChild(be),le.checkClone=xe.cloneNode(!0).cloneNode(!0).lastChild.checked,xe.innerHTML="<textarea>x</textarea>",le.noCloneChecked=!!xe.cloneNode(!0).lastChild.defaultValue,xe.innerHTML="<option></option>",le.option=!!xe.lastChild;var ke={thead:[1,"<table>","<...
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 26 01:07:52 UTC 2024
    - 85.5K bytes
    - Viewed (0)
  9. internal/jwt/parser.go

    //
    // This method parses the token but doesn't validate the signature. It's only
    // ever useful in cases where you know the signature is valid (because it has
    // been checked previously in the stack) and you want to extract values from
    // it.
    func ParseUnverifiedStandardClaims(token []byte, claims *StandardClaims, buf []byte) (*SigningMethodHMAC, error) {
    	if bytes.Count(token, []byte(".")) != 2 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/collect/AbstractIteratorTest.java

      // hasNext/next/peek), but we'll cop out for now, knowing that peek() and
      // next() both start by invoking hasNext() anyway.
    
      /** Throws an undeclared checked exception. */
      private static void sneakyThrow(Throwable t) {
        class SneakyThrower<T extends Throwable> {
          @SuppressWarnings("unchecked") // not really safe, but that's the point
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 15 17:36:06 UTC 2024
    - 8.1K bytes
    - Viewed (0)
Back to top