- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for mr (0.3 sec)
-
cmd/metacache-stream.go
mr: mr, closer: func() { dec.Reset(nil) s2DecPool.Put(dec) readMsgpReaderPoolPut(mr) }, creator: func() error { v, err := mr.ReadByte() if err != nil { return err } switch v { case 1, 2: default: return fmt.Errorf("metacacheReader: Unknown version: %d", v) } return nil }, } } func (r *metacacheReader) checkInit() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 19.5K bytes - Viewed (0) -
cmd/tier-journal.go
logger.LogIf(ctx, fmt.Errorf("tier-journal: failed open read-only journal for processing %s", err)) return } defer ro.Close() mr := msgpNewReader(ro) defer readMsgpReaderPoolPut(mr) done := false for { var entry jentry err := entry.DecodeMsg(mr) if errors.Is(err, io.EOF) { done = true break } if err != nil {
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.4K bytes - Viewed (0) -
cmd/storage-rest-client.go
} defer xhttp.DrainBody(respBody) pr, pw := io.Pipe() go func() { pw.CloseWithError(waitForHTTPStream(respBody, pw)) }() mr := msgp.NewReader(pr) defer readMsgpReaderPoolPut(mr) for { var file ReadMultipleResp if err := file.DecodeMsg(mr); err != nil { if errors.Is(err, io.EOF) { err = nil } pr.CloseWithError(err) return toStorageErr(err) } select {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
cmd/storage-rest-server.go
if r := recover(); r != nil { debug.PrintStack() rw.CloseWithError(fmt.Errorf("panic: %v", r)) } }() var req ReadMultipleReq mr := msgpNewReader(r.Body) defer readMsgpReaderPoolPut(mr) err := req.DecodeMsg(mr) if err != nil { rw.CloseWithError(err) return } mw := msgp.NewWriter(rw) responses := make(chan ReadMultipleResp, len(req.Files))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0)