util

package
v0.0.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 27, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewDelimitedWriter

func NewDelimitedWriter(w io.Writer) pbio.WriteCloser

func PeerInfoToPeerV2

func PeerInfoToPeerV2(pi peer.AddrInfo) *pbv2.Peer

func PeerToPeerInfoV2

func PeerToPeerInfoV2(p *pbv2.Peer) (peer.AddrInfo, error)

Types

type DelimitedReader

type DelimitedReader struct {
	// contains filtered or unexported fields
}

func NewDelimitedReader

func NewDelimitedReader(r io.Reader, maxSize int) *DelimitedReader

The gogo protobuf NewDelimitedReader is buffered, which may eat up stream data. So we need to implement a compatible delimited reader that reads unbuffered. There is a slowdown from unbuffered reading: when reading the message it can take multiple single byte Reads to read the length and another Read to read the message payload. However, this is not critical performance degradation as

  • the reader is utilized to read one (dialer, stop) or two messages (hop) during the handshake, so it's a drop in the water for the connection lifetime.
  • messages are small (max 4k) and the length fits in a couple of bytes, so overall we have at most three reads per message.

func (*DelimitedReader) Close

func (d *DelimitedReader) Close()

func (*DelimitedReader) ReadByte

func (d *DelimitedReader) ReadByte() (byte, error)

func (*DelimitedReader) ReadMsg

func (d *DelimitedReader) ReadMsg(msg proto.Message) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL