util

Documentation

Index

• Variables
• func IsEOFOrNetReadError(err error) bool
• func RecvLTVPacket(reader io.Reader, maxPacketSize int) (msg interface{}, err error)
• func SendLTVPacket(writer io.Writer, ctx cellnet.ContextSet, data interface{}) error
• func SpliteAddress(addr string) (host string, port int, err error)
• func StringHash(s string) (hash uint16)
• func WriteFull(writer io.Writer, p []byte) error
• type Queue
  • func NewQueue(size int) *Queue
  • func (self *Queue) Count() int
  • func (self *Queue) Dequeue() (ret interface{})
  • func (self *Queue) Enqueue(data interface{})
  • func (self *Queue) Peek() interface{}
• type SignalTester
  • func NewSignalTester(t *testing.T) *SignalTester
  • func (self *SignalTester) Done(value interface{})
  • func (self *SignalTester) SetTimeout(du time.Duration)
  • func (self *SignalTester) WaitAndExpect(msg string, values ...interface{}) bool

Variables

var (
	ErrMaxPacket = errors.New("Invalid packet size")
)

Functions

func IsEOFOrNetReadError

func IsEOFOrNetReadError(err error) bool

func RecvLTVPacket

func RecvLTVPacket(reader io.Reader, maxPacketSize int) (msg interface{}, err error)

接收Length-Type-Value格式的封包流程

func SendLTVPacket

func SendLTVPacket(writer io.Writer, ctx cellnet.ContextSet, data interface{}) error

发送Length-Type-Value格式的封包流程

func SpliteAddress

func SpliteAddress(addr string) (host string, port int, err error)

func StringHash

func StringHash(s string) (hash uint16)

字符串转为16位整形值

func WriteFull

func WriteFull(writer io.Writer, p []byte) error

完整发送所有封包

Types

type Queue

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

func NewQueue

func NewQueue(size int) *Queue

func (*Queue) Count

func (self *Queue) Count() int

func (*Queue) Dequeue

func (self *Queue) Dequeue() (ret interface{})

func (*Queue) Enqueue

func (self *Queue) Enqueue(data interface{})

func (*Queue) Peek

func (self *Queue) Peek() interface{}

type SignalTester

type SignalTester struct {
	*testing.T
	// contains filtered or unexported fields
}

func NewSignalTester

func NewSignalTester(t *testing.T) *SignalTester

func (*SignalTester) Done

func (self *SignalTester) Done(value interface{})

func (*SignalTester) SetTimeout

func (self *SignalTester) SetTimeout(du time.Duration)

func (*SignalTester) WaitAndExpect

func (self *SignalTester) WaitAndExpect(msg string, values ...interface{}) bool