- Sort Score
- Result 10 results
- Languages All
Results 241 - 250 of 1,066 for readOp (0.08 sec)
-
internal/crypto/key_test.go
package crypto import ( "bytes" "crypto/rand" "encoding/hex" "io" "testing" "github.com/minio/minio/internal/logger" ) var shortRandom = func(limit int64) io.Reader { return io.LimitReader(rand.Reader, limit) } func recoverTest(i int, shouldPass bool, t *testing.T) { if err := recover(); err == nil && !shouldPass { t.Errorf("Test %d should fail but passed successfully", i)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 6.7K bytes - Viewed (0) -
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.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue May 28 17:14:16 UTC 2024 - 12K bytes - Viewed (0) -
build-logic-commons/basics/src/main/kotlin/gradlebuild/basics/classanalysis/AnalyzeAndShade.kt
fun visitClassFile(file: Path) { try { val reader = ClassReader(Files.newInputStream(file)) val details = classes[reader.className] details.visited = true val classWriter = ClassWriter(0) reader.accept( ClassRemapper( classWriter,
Registered: Wed Oct 30 11:36:09 UTC 2024 - Last Modified: Mon Oct 28 12:55:30 UTC 2024 - 6.8K bytes - Viewed (0) -
cmd/bucket-replication.go
} closeReader := func() { obj.Close() } reader, err := fn(obj, h, closeReader) if err != nil { return nil, proxy, err } reader.ObjInfo = oi.Clone() if rs != nil { contentSize, err := parseSizeFromContentRange(h) if err != nil { return nil, proxy, err } reader.ObjInfo.Size = contentSize } return reader, proxyResult{Proxy: true}, nil }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Oct 10 06:49:55 UTC 2024 - 116.1K bytes - Viewed (0) -
cmd/warm-backend-minio.go
// Part size. partSize = int64(partSizeFlt) if partSize == 0 { return minPartSize, nil } return partSize, nil } func (m *warmBackendMinIO) Put(ctx context.Context, object string, r io.Reader, length int64) (remoteVersionID, error) { partSize, err := optimalPartSize(length) if err != nil { return remoteVersionID(""), err }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Apr 21 11:43:18 UTC 2024 - 3.8K bytes - Viewed (0) -
docs/debugging/inspect/export.go
// Read metadata CRC (added in v2, ignore if not found) b = nbuf } _, e = msgp.CopyToJSON(buf, bytes.NewReader(v)) if e != nil { return nil, e } data = b case 3: v, b, e := msgp.ReadBytesZC(b) if e != nil { return nil, e } if _, nbuf, e := msgp.ReadUint32Bytes(b); e == nil { // Read metadata CRC (added in v2, ignore if not found)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Nov 08 15:58:02 UTC 2022 - 9.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/Crawler.java
try (BufferedReader reader = new BufferedReader(new InputStreamReader(System.in))) { String command; while (true) { try { while (!reader.ready()) { ThreadUtil.sleep(1000L); } command = reader.readLine().trim();
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Fri Oct 11 21:20:39 UTC 2024 - 24K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SuggestHelper.java
final ESSourceReader reader = new ESSourceReader(ComponentUtil.getSearchEngineClient(), suggester.settings(), fessConfig.getIndexDocumentSearchIndex()); reader.setScrollSize(fessConfig.getSuggestSourceReaderScrollSizeAsInteger()); reader.setLimitDocNumPercentage(fessConfig.getSuggestUpdateContentsLimitNumPercentage());
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Fri Oct 11 21:20:39 UTC 2024 - 18.1K bytes - Viewed (0) -
internal/config/config.go
// ContextKeyForTargetFromConfig - key for context for target from config const ContextKeyForTargetFromConfig = ContextKeyString("ContextKeyForTargetFromConfig") // ParseConfigTargetID - read all targetIDs from reader func ParseConfigTargetID(r io.Reader) (ids map[string]bool, err error) { ids = make(map[string]bool) scanner := bufio.NewScanner(r) for scanner.Scan() { // Skip any empty lines, or comment like characters
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Sep 03 18:23:41 UTC 2024 - 37.7K bytes - Viewed (0) -
cmd/metacache-set.go
} } o.debugln("forwarded to ", o.Prefix, "marker:", o.Marker, "sep:", o.Separator) // Filter if !o.Recursive { entries.o = make(metaCacheEntries, 0, o.Limit) pastPrefix := false err := r.readFn(func(entry metaCacheEntry) bool { if o.Prefix != "" && !strings.HasPrefix(entry.name, o.Prefix) { // We are past the prefix, don't continue. pastPrefix = true return false }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Jul 12 16:23:16 UTC 2024 - 30.7K bytes - Viewed (0)