- Sort Score
- Num 10 results
- Language All
Results 261 - 270 of 1,023 for readOp (0.05 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)