reader.go 1.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758
  1. package mux
  2. import (
  3. "io"
  4. "github.com/xtls/xray-core/common/buf"
  5. "github.com/xtls/xray-core/common/crypto"
  6. "github.com/xtls/xray-core/common/net"
  7. "github.com/xtls/xray-core/common/serial"
  8. )
  9. // PacketReader is an io.Reader that reads whole chunk of Mux frames every time.
  10. type PacketReader struct {
  11. reader io.Reader
  12. eof bool
  13. dest *net.Destination
  14. }
  15. // NewPacketReader creates a new PacketReader.
  16. func NewPacketReader(reader io.Reader, dest *net.Destination) *PacketReader {
  17. return &PacketReader{
  18. reader: reader,
  19. eof: false,
  20. dest: dest,
  21. }
  22. }
  23. // ReadMultiBuffer implements buf.Reader.
  24. func (r *PacketReader) ReadMultiBuffer() (buf.MultiBuffer, error) {
  25. if r.eof {
  26. return nil, io.EOF
  27. }
  28. size, err := serial.ReadUint16(r.reader)
  29. if err != nil {
  30. return nil, err
  31. }
  32. if size > buf.Size {
  33. return nil, newError("packet size too large: ", size)
  34. }
  35. b := buf.New()
  36. if _, err := b.ReadFullFrom(r.reader, int32(size)); err != nil {
  37. b.Release()
  38. return nil, err
  39. }
  40. r.eof = true
  41. if r.dest != nil && r.dest.Network == net.Network_UDP {
  42. b.UDP = r.dest
  43. }
  44. return buf.MultiBuffer{b}, nil
  45. }
  46. // NewStreamReader creates a new StreamReader.
  47. func NewStreamReader(reader *buf.BufferedReader) buf.Reader {
  48. return crypto.NewChunkStreamReaderWithChunkCount(crypto.PlainChunkSizeParser{}, reader, 1)
  49. }