const.go 2.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899
  1. package pomeloPacket
  2. import (
  3. "bytes"
  4. cerr "github.com/mhaya/error"
  5. )
  6. type (
  7. Type = byte // packet type
  8. )
  9. const (
  10. None Type = 0x00 // None
  11. Handshake Type = 0x01 // Handshake represents a handshake: request(client) <====> handshake response(server)
  12. HandshakeAck Type = 0x02 // HandshakeAck represents a handshake ack from client to server
  13. Heartbeat Type = 0x03 // Heartbeat represents a heartbeat
  14. Data Type = 0x04 // settings represents a common data packet
  15. Kick Type = 0x05 // Kick represents a kick off packet
  16. )
  17. var (
  18. HeadLength = 4 // 4 bytes
  19. MaxPacketSize = 1 << 24 // 16mb
  20. packetTypes = map[Type]string{
  21. None: "None",
  22. Handshake: "Handshake",
  23. HandshakeAck: "HandshakeAck",
  24. Heartbeat: "Heartbeat",
  25. Data: "Data",
  26. Kick: "Kick",
  27. }
  28. )
  29. func TypeName(t Type) string {
  30. return packetTypes[t]
  31. }
  32. func InvalidType(t Type) bool {
  33. return t < Handshake || t > Kick
  34. }
  35. // ParseHeader parses a packet header and returns its dataLen and packetType or an error
  36. func ParseHeader(header []byte) (int, error) {
  37. if len(header) != HeadLength {
  38. return 0, cerr.PacketInvalidHeader
  39. }
  40. typ := header[0]
  41. if InvalidType(typ) {
  42. return 0, cerr.PacketWrongType
  43. }
  44. size := BytesToInt(header[1:])
  45. if size > MaxPacketSize {
  46. return 0, cerr.PacketSizeExceed
  47. }
  48. return size, nil
  49. }
  50. // BytesToInt Decode packet data length byte to int(Big end)
  51. func BytesToInt(b []byte) int {
  52. result := 0
  53. for _, v := range b {
  54. result = result<<8 + int(v)
  55. }
  56. return result
  57. }
  58. // IntToBytes Encode packet data length to bytes(Big end)
  59. func IntToBytes(n int) []byte {
  60. buf := make([]byte, 3)
  61. buf[0] = byte((n >> 16) & 0xFF)
  62. buf[1] = byte((n >> 8) & 0xFF)
  63. buf[2] = byte(n & 0xFF)
  64. return buf
  65. }
  66. func forward(buf *bytes.Buffer) (int, Type, error) {
  67. header := buf.Next(HeadLength)
  68. typ := header[0]
  69. if InvalidType(typ) {
  70. return 0, None, cerr.PacketSizeExceed
  71. }
  72. // get 2,3,4 byte
  73. size := BytesToInt(header[1:])
  74. // packet length limitation
  75. if size > MaxPacketSize {
  76. return 0, None, cerr.PacketSizeExceed
  77. }
  78. return size, typ, nil
  79. }