- Sort Score
- Result 10 results
- Languages All
Results 201 - 207 of 207 for NewReader (0.09 sec)
-
cmd/notification.go
for idx, client := range sys.peerClients { if client == nil { continue } client := client ng.Go(ctx, func() error { return client.VerifyBinary(ctx, u, sha256Sum, releaseInfo, bytes.NewReader(bin)) }, idx, *client.host) } return ng.Wait() } // CommitBinary - asks remote peers to overwrite the old binary with the new one
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 46.2K bytes - Viewed (0) -
cmd/peer-rest-server.go
return } if lrTime.Sub(currentReleaseTime) <= 0 { s.writeErrorResponse(w, fmt.Errorf("server is running the latest version: %s", Version)) return } zr, err := zstd.NewReader(r.Body) if err != nil { s.writeErrorResponse(w, err) return } defer zr.Close() if err = verifyBinary(u, sha256Sum, releaseInfo, getMinioMode(), zr); err != nil { s.writeErrorResponse(w, err)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 11:32:32 UTC 2024 - 53.2K bytes - Viewed (0) -
api/go1.5.txt
pkg mime, type WordDecoder struct pkg mime, type WordDecoder struct, CharsetReader func(string, io.Reader) (io.Reader, error) pkg mime, type WordEncoder uint8 pkg mime/quotedprintable, func NewReader(io.Reader) *Reader pkg mime/quotedprintable, func NewWriter(io.Writer) *Writer pkg mime/quotedprintable, method (*Reader) Read([]uint8) (int, error) pkg mime/quotedprintable, method (*Writer) Close() error
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Thu Jul 30 21:14:09 UTC 2015 - 46.6K bytes - Viewed (0) -
cmd/xl-storage_test.go
algo = HighwayHash256S shardSize := int64(1024 * 1024) shard := make([]byte, shardSize) w := newStreamingBitrotWriter(storage, "", volName, fileName, size, algo, shardSize) reader := bytes.NewReader(data) for { // Using io.Copy instead of this loop will not work for us as io.Copy // will use bytes.Reader.WriteTo() which will not do shardSize'ed writes // causing error. n, err := reader.Read(shard)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 14 17:11:51 UTC 2024 - 66.7K bytes - Viewed (0) -
cmd/xl-storage.go
// fdatasync() at the end instead of opening the file with O_DSYNC. // // This is an optimization mainly to ensure faster I/O. if len(b) > xioutil.DirectioAlignSize { r := bytes.NewReader(b) return s.writeAllDirect(ctx, filePath, r.Size(), r, flags, skipParent, true) } w, err = s.openFileSync(filePath, flags, skipParent) } else { w, err = s.openFile(filePath, flags, skipParent) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 91.3K bytes - Viewed (0) -
api/go1.txt
pkg archive/tar, const TypeRegA ideal-char pkg archive/tar, const TypeSymlink ideal-char pkg archive/tar, const TypeXGlobalHeader ideal-char pkg archive/tar, const TypeXHeader ideal-char pkg archive/tar, func NewReader(io.Reader) *Reader pkg archive/tar, func NewWriter(io.Writer) *Writer pkg archive/tar, method (*Reader) Next() (*Header, error) pkg archive/tar, method (*Reader) Read([]uint8) (int, error)
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Wed Aug 14 18:58:28 UTC 2013 - 1.7M bytes - Viewed (0) -
guava/src/com/google/common/collect/LinkedHashMultimap.java
this.nextInValueBucket = nextInValueBucket; } @SuppressWarnings("nullness") // see the comment on the class fields, especially about newHeader static <K extends @Nullable Object, V extends @Nullable Object> ValueEntry<K, V> newHeader() { return new ValueEntry<>(null, null, 0, null); } boolean matchesValue(@CheckForNull Object v, int smearedVHash) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 24.3K bytes - Viewed (0)