Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for ReadBytes (0.17 sec)

  1. cmd/xl-storage-format-v2_gen.go

    	s = msgp.Uint8Size
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *xlMetaBuf) DecodeMsg(dc *msgp.Reader) (err error) {
    	{
    		var zb0001 []byte
    		zb0001, err = dc.ReadBytes([]byte((*z)))
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = xlMetaBuf(zb0001)
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 53.8K bytes
    - Viewed (0)
  2. cmd/metrics-v2.go

    				MetricV2{
    					Description: getMinIOProcessSysCallWMD(),
    					Value:       float64(io.SyscW),
    				})
    		}
    
    		if io.ReadBytes > 0 {
    			metrics = append(metrics,
    				MetricV2{
    					Description: getMinioProcessIOReadBytesMD(),
    					Value:       float64(io.ReadBytes),
    				})
    		}
    
    		if io.WriteBytes > 0 {
    			metrics = append(metrics,
    				MetricV2{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
  3. internal/grid/msg_gen.go

    	}
    	{
    		var zb0004 uint8
    		zb0004, err = dc.ReadUint8()
    		if err != nil {
    			err = msgp.WrapError(err, "Flags")
    			return
    		}
    		z.Flags = Flags(zb0004)
    	}
    	z.Payload, err = dc.ReadBytes(z.Payload)
    	if err != nil {
    		err = msgp.WrapError(err, "Payload")
    		return
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z *message) EncodeMsg(en *msgp.Writer) (err error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 18.8K bytes
    - Viewed (0)
  4. internal/s3select/csv/reader.go

    			// ReadFull returns ErrUnexpectedEOF.
    			return dst[:n], err
    		}
    		dst = dst[:n]
    		if err == io.ErrUnexpectedEOF {
    			return dst, io.EOF
    		}
    	}
    	// Read until next line.
    	in, err := r.buf.ReadBytes('\n')
    	dst = append(dst, in...)
    	return dst, err
    }
    
    // csvSplitSize is the size of each block.
    // Blocks will read this much and find the first following newline.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 8.9K bytes
    - Viewed (0)
  5. cmd/storage-datatypes_gen.go

    		return
    	}
    	if dc.IsNil() {
    		err = dc.ReadNil()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		z.Data = nil
    	} else {
    		z.Data, err = dc.ReadBytes(z.Data)
    		if err != nil {
    			err = msgp.WrapError(err, "Data")
    			return
    		}
    	}
    	z.NumVersions, err = dc.ReadInt()
    	if err != nil {
    		err = msgp.WrapError(err, "NumVersions")
    		return
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 127.5K bytes
    - Viewed (0)
  6. cmd/metrics-v3-system-process.go

    	}
    }
    
    func loadProcIOMetrics(ctx context.Context, io procfs.ProcIO, m MetricValues) {
    	if io.RChar > 0 {
    		m.Set(processIORCharBytes, float64(io.RChar))
    	}
    
    	if io.ReadBytes > 0 {
    		m.Set(processIOReadBytes, float64(io.ReadBytes))
    	}
    
    	if io.WChar > 0 {
    		m.Set(processIOWCharBytes, float64(io.WChar))
    	}
    
    	if io.WriteBytes > 0 {
    		m.Set(processIOWriteBytes, float64(io.WriteBytes))
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 16:07:23 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  7. cmd/bucket-metadata_gen.go

    			z.LifecycleConfigXML, err = dc.ReadBytes(z.LifecycleConfigXML)
    			if err != nil {
    				err = msgp.WrapError(err, "LifecycleConfigXML")
    				return
    			}
    		case "ObjectLockConfigXML":
    			z.ObjectLockConfigXML, err = dc.ReadBytes(z.ObjectLockConfigXML)
    			if err != nil {
    				err = msgp.WrapError(err, "ObjectLockConfigXML")
    				return
    			}
    		case "VersioningConfigXML":
    			z.VersioningConfigXML, err = dc.ReadBytes(z.VersioningConfigXML)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 25 05:52:39 GMT 2023
    - 22.1K bytes
    - Viewed (0)
  8. cmd/metacache-stream.go

    	if r.current.name, err = r.mr.ReadString(); err != nil {
    		if err == io.EOF {
    			err = io.ErrUnexpectedEOF
    		}
    		r.err = err
    		return metaCacheEntry{}, err
    	}
    	r.current.metadata, err = r.mr.ReadBytes(r.current.metadata[:0])
    	if err == io.EOF {
    		err = io.ErrUnexpectedEOF
    	}
    	r.err = err
    	return r.current, err
    }
    
    // next will read one entry from the stream.
    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)
  9. internal/s3select/json/preader.go

    			// ReadFull returns ErrUnexpectedEOF.
    			return dst[:n], err
    		}
    		dst = dst[:n]
    		if err == io.ErrUnexpectedEOF {
    			return dst, io.EOF
    		}
    	}
    	// Read until next line.
    	in, err := r.buf.ReadBytes('\n')
    	dst = append(dst, in...)
    	return dst, err
    }
    
    // jsonSplitSize is the size of each block.
    // Blocks will read this much and find the first following newline.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 05 04:57:35 GMT 2023
    - 6.4K bytes
    - Viewed (0)
  10. internal/config/cache/remote_gen.go

    				return
    			}
    		case "Size":
    			z.Size, err = dc.ReadInt64()
    			if err != nil {
    				err = msgp.WrapError(err, "Size")
    				return
    			}
    		case "Data":
    			z.Data, err = dc.ReadBytes(z.Data)
    			if err != nil {
    				err = msgp.WrapError(err, "Data")
    				return
    			}
    		default:
    			err = dc.Skip()
    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Nov 22 21:46:17 GMT 2023
    - 18.9K bytes
    - Viewed (0)
Back to top