Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 261 - 270 of 1,023 for readOp (0.05 seconds)

  1. internal/auth/credentials.go

    	accessKey, err = GenerateAccessKey(accessKeyMaxLen, rand.Reader)
    	if err != nil {
    		return "", "", err
    	}
    	secretKey, err = GenerateSecretKey(secretKeyMaxLen, rand.Reader)
    	if err != nil {
    		return "", "", err
    	}
    	return accessKey, secretKey, nil
    }
    
    // GenerateAccessKey returns a new access key generated randomly using
    // the given io.Reader. If random is nil, crypto/rand.Reader is used.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  2. cmd/object-multipart-handlers.go

    	if isCompressed {
    		wantEncryption := crypto.Requested(r.Header) || isEncrypted
    		s2c, cb := newS2CompressReader(reader, actualPartSize, wantEncryption)
    		idxCb = cb
    		defer s2c.Close()
    		reader = etag.Wrap(s2c, reader)
    		length = -1
    	}
    
    	srcInfo.Reader, err = hash.NewReader(ctx, reader, length, "", "", actualPartSize)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 07 16:13:09 GMT 2025
    - 39.5K bytes
    - Click Count (1)
  3. compat/maven-settings-builder/src/main/java/org/apache/maven/settings/io/DefaultSettingsReader.java

            }
        }
    
        @Override
        public Settings read(Reader input, Map<String, ?> options) throws IOException {
            Objects.requireNonNull(input, "input cannot be null");
    
            try (Reader in = input) {
                InputSource source = (InputSource) options.get(InputSource.class.getName());
                return new Settings(new SettingsStaxReader().read(in, isStrict(options), source));
            } catch (XMLStreamException e) {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Mon Sep 29 14:45:25 GMT 2025
    - 3.6K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

            }
          }
          int undrainedIndex = reads.size() - segment.recencyQueue.size();
          checkAndDrainRecencyQueue(map, segment, reads.subList(undrainedIndex, reads.size()));
          readOrder.addAll(reads);
    
          checkEvictionQueues(map, segment, readOrder, writeOrder);
          checkExpirationTimes(map);
        }
      }
    
      public void testComputeExistingEntry() throws ExecutionException {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 114.9K bytes
    - Click Count (0)
  5. guava-tests/test/com/google/common/cache/LocalCacheTest.java

            }
          }
          int undrainedIndex = reads.size() - segment.recencyQueue.size();
          checkAndDrainRecencyQueue(map, segment, reads.subList(undrainedIndex, reads.size()));
          readOrder.addAll(reads);
    
          checkEvictionQueues(map, segment, readOrder, writeOrder);
          checkExpirationTimes(map);
        }
      }
    
      public void testComputeExistingEntry() throws ExecutionException {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 116.4K bytes
    - Click Count (0)
  6. build-logic/documentation/src/main/groovy/gradlebuild/docs/ReleaseNotesTransformer.java

        private File baseCss;
        private File releaseNotesCss;
        private File releaseNotesJavascript;
    
        public ReleaseNotesTransformer(Reader original) {
            super(original);
            this.in = new Reader() {
                Reader delegate = null;
    
                @Override
                public int read(char[] cbuf, int off, int len) throws IOException {
                    if (delegate == null) {
                        delegate = transform(original);
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Tue Mar 03 01:59:51 GMT 2026
    - 11.3K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/io/CharSequenceReader.java

    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import java.io.IOException;
    import java.io.Reader;
    import java.nio.CharBuffer;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A {@link Reader} that reads the characters in a {@link CharSequence}. Like {@code StringReader},
     * but works with any {@link CharSequence}.
     *
     * @author Colin Decker
     */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 4.5K bytes
    - Click Count (0)
  8. cmd/postpolicyform.go

    }
    
    // parsePostPolicyForm - Parse JSON policy string into typed PostPolicyForm structure.
    func parsePostPolicyForm(r io.Reader) (PostPolicyForm, error) {
    	reader, err := sanitizePolicy(r)
    	if err != nil {
    		return PostPolicyForm{}, err
    	}
    
    	d := json.NewDecoder(reader)
    
    	// Convert po into interfaces and
    	// perform strict type conversion using reflection.
    	var rawPolicy struct {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Oct 23 15:10:12 GMT 2025
    - 12.1K bytes
    - Click Count (0)
  9. build-logic/documentation/src/main/groovy/gradlebuild/docs/FindMissingDocumentationFiles.java

            Gson gson = new Gson();
            List<AdocFileEntry> entries;
            try (FileReader reader = new FileReader(jsonFile)) {
                entries = gson.fromJson(reader, new TypeToken<List<AdocFileEntry>>() {}.getType());
            }
    
            Set<String> foundAdocFiles = new HashSet<>();
            try (Stream<Path> pathStream = Files.walk(Paths.get(directoryPath))) {
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Thu Aug 21 15:38:58 GMT 2025
    - 8.5K bytes
    - Click Count (0)
  10. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/CertificateAdapters.kt

          override fun fromDer(reader: DerReader): Long {
            val peekHeader =
              reader.peekHeader()
                ?: throw ProtocolException("expected time but was exhausted at $reader")
    
            return when {
              peekHeader.tagClass == Adapters.UTC_TIME.tagClass &&
                peekHeader.tag == Adapters.UTC_TIME.tag -> {
                Adapters.UTC_TIME.fromDer(reader)
              }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 13.6K bytes
    - Click Count (0)
Back to Top