feature_iter_int.go 6.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268
  1. package jsoniter
  2. import (
  3. "math"
  4. "strconv"
  5. )
  6. var intDigits []int8
  7. const uint32SafeToMultiply10 = uint32(0xffffffff)/10 - 1
  8. const uint64SafeToMultiple10 = uint64(0xffffffffffffffff)/10 - 1
  9. func init() {
  10. intDigits = make([]int8, 256)
  11. for i := 0; i < len(intDigits); i++ {
  12. intDigits[i] = invalidCharForNumber
  13. }
  14. for i := int8('0'); i <= int8('9'); i++ {
  15. intDigits[i] = i - int8('0')
  16. }
  17. }
  18. // ReadUint read uint
  19. func (iter *Iterator) ReadUint() uint {
  20. return uint(iter.ReadUint64())
  21. }
  22. // ReadInt read int
  23. func (iter *Iterator) ReadInt() int {
  24. return int(iter.ReadInt64())
  25. }
  26. // ReadInt8 read int8
  27. func (iter *Iterator) ReadInt8() (ret int8) {
  28. c := iter.nextToken()
  29. if c == '-' {
  30. val := iter.readUint32(iter.readByte())
  31. if val > math.MaxInt8+1 {
  32. iter.ReportError("ReadInt8", "overflow: "+strconv.FormatInt(int64(val), 10))
  33. return
  34. }
  35. return -int8(val)
  36. }
  37. val := iter.readUint32(c)
  38. if val > math.MaxInt8 {
  39. iter.ReportError("ReadInt8", "overflow: "+strconv.FormatInt(int64(val), 10))
  40. return
  41. }
  42. return int8(val)
  43. }
  44. // ReadUint8 read uint8
  45. func (iter *Iterator) ReadUint8() (ret uint8) {
  46. val := iter.readUint32(iter.nextToken())
  47. if val > math.MaxUint8 {
  48. iter.ReportError("ReadUint8", "overflow: "+strconv.FormatInt(int64(val), 10))
  49. return
  50. }
  51. return uint8(val)
  52. }
  53. // ReadInt16 read int16
  54. func (iter *Iterator) ReadInt16() (ret int16) {
  55. c := iter.nextToken()
  56. if c == '-' {
  57. val := iter.readUint32(iter.readByte())
  58. if val > math.MaxInt16+1 {
  59. iter.ReportError("ReadInt16", "overflow: "+strconv.FormatInt(int64(val), 10))
  60. return
  61. }
  62. return -int16(val)
  63. }
  64. val := iter.readUint32(c)
  65. if val > math.MaxInt16 {
  66. iter.ReportError("ReadInt16", "overflow: "+strconv.FormatInt(int64(val), 10))
  67. return
  68. }
  69. return int16(val)
  70. }
  71. // ReadUint16 read uint16
  72. func (iter *Iterator) ReadUint16() (ret uint16) {
  73. val := iter.readUint32(iter.nextToken())
  74. if val > math.MaxUint16 {
  75. iter.ReportError("ReadUint16", "overflow: "+strconv.FormatInt(int64(val), 10))
  76. return
  77. }
  78. return uint16(val)
  79. }
  80. // ReadInt32 read int32
  81. func (iter *Iterator) ReadInt32() (ret int32) {
  82. c := iter.nextToken()
  83. if c == '-' {
  84. val := iter.readUint32(iter.readByte())
  85. if val > math.MaxInt32+1 {
  86. iter.ReportError("ReadInt32", "overflow: "+strconv.FormatInt(int64(val), 10))
  87. return
  88. }
  89. return -int32(val)
  90. }
  91. val := iter.readUint32(c)
  92. if val > math.MaxInt32 {
  93. iter.ReportError("ReadInt32", "overflow: "+strconv.FormatInt(int64(val), 10))
  94. return
  95. }
  96. return int32(val)
  97. }
  98. // ReadUint32 read uint32
  99. func (iter *Iterator) ReadUint32() (ret uint32) {
  100. return iter.readUint32(iter.nextToken())
  101. }
  102. func (iter *Iterator) readUint32(c byte) (ret uint32) {
  103. defer func() {
  104. if iter.head < len(iter.buf) && iter.buf[iter.head] == '.' {
  105. iter.ReportError("readUint32", "can not decode float as int")
  106. }
  107. }()
  108. ind := intDigits[c]
  109. if ind == 0 {
  110. return 0 // single zero
  111. }
  112. if ind == invalidCharForNumber {
  113. iter.ReportError("readUint32", "unexpected character: "+string([]byte{byte(ind)}))
  114. return
  115. }
  116. value := uint32(ind)
  117. if iter.tail-iter.head > 10 {
  118. i := iter.head
  119. ind2 := intDigits[iter.buf[i]]
  120. if ind2 == invalidCharForNumber {
  121. iter.head = i
  122. return value
  123. }
  124. i++
  125. ind3 := intDigits[iter.buf[i]]
  126. if ind3 == invalidCharForNumber {
  127. iter.head = i
  128. return value*10 + uint32(ind2)
  129. }
  130. //iter.head = i + 1
  131. //value = value * 100 + uint32(ind2) * 10 + uint32(ind3)
  132. i++
  133. ind4 := intDigits[iter.buf[i]]
  134. if ind4 == invalidCharForNumber {
  135. iter.head = i
  136. return value*100 + uint32(ind2)*10 + uint32(ind3)
  137. }
  138. i++
  139. ind5 := intDigits[iter.buf[i]]
  140. if ind5 == invalidCharForNumber {
  141. iter.head = i
  142. return value*1000 + uint32(ind2)*100 + uint32(ind3)*10 + uint32(ind4)
  143. }
  144. i++
  145. ind6 := intDigits[iter.buf[i]]
  146. if ind6 == invalidCharForNumber {
  147. iter.head = i
  148. return value*10000 + uint32(ind2)*1000 + uint32(ind3)*100 + uint32(ind4)*10 + uint32(ind5)
  149. }
  150. i++
  151. ind7 := intDigits[iter.buf[i]]
  152. if ind7 == invalidCharForNumber {
  153. iter.head = i
  154. return value*100000 + uint32(ind2)*10000 + uint32(ind3)*1000 + uint32(ind4)*100 + uint32(ind5)*10 + uint32(ind6)
  155. }
  156. i++
  157. ind8 := intDigits[iter.buf[i]]
  158. if ind8 == invalidCharForNumber {
  159. iter.head = i
  160. return value*1000000 + uint32(ind2)*100000 + uint32(ind3)*10000 + uint32(ind4)*1000 + uint32(ind5)*100 + uint32(ind6)*10 + uint32(ind7)
  161. }
  162. i++
  163. ind9 := intDigits[iter.buf[i]]
  164. value = value*10000000 + uint32(ind2)*1000000 + uint32(ind3)*100000 + uint32(ind4)*10000 + uint32(ind5)*1000 + uint32(ind6)*100 + uint32(ind7)*10 + uint32(ind8)
  165. iter.head = i
  166. if ind9 == invalidCharForNumber {
  167. return value
  168. }
  169. }
  170. for {
  171. for i := iter.head; i < iter.tail; i++ {
  172. ind = intDigits[iter.buf[i]]
  173. if ind == invalidCharForNumber {
  174. iter.head = i
  175. return value
  176. }
  177. if value > uint32SafeToMultiply10 {
  178. value2 := (value << 3) + (value << 1) + uint32(ind)
  179. if value2 < value {
  180. iter.ReportError("readUint32", "overflow")
  181. return
  182. }
  183. value = value2
  184. continue
  185. }
  186. value = (value << 3) + (value << 1) + uint32(ind)
  187. }
  188. if !iter.loadMore() {
  189. return value
  190. }
  191. }
  192. }
  193. // ReadInt64 read int64
  194. func (iter *Iterator) ReadInt64() (ret int64) {
  195. c := iter.nextToken()
  196. if c == '-' {
  197. val := iter.readUint64(iter.readByte())
  198. if val > math.MaxInt64+1 {
  199. iter.ReportError("ReadInt64", "overflow: "+strconv.FormatUint(uint64(val), 10))
  200. return
  201. }
  202. return -int64(val)
  203. }
  204. val := iter.readUint64(c)
  205. if val > math.MaxInt64 {
  206. iter.ReportError("ReadInt64", "overflow: "+strconv.FormatUint(uint64(val), 10))
  207. return
  208. }
  209. return int64(val)
  210. }
  211. // ReadUint64 read uint64
  212. func (iter *Iterator) ReadUint64() uint64 {
  213. return iter.readUint64(iter.nextToken())
  214. }
  215. func (iter *Iterator) readUint64(c byte) (ret uint64) {
  216. defer func() {
  217. if iter.head < len(iter.buf) && iter.buf[iter.head] == '.' {
  218. iter.ReportError("readUint64", "can not decode float as int")
  219. }
  220. }()
  221. ind := intDigits[c]
  222. if ind == 0 {
  223. return 0 // single zero
  224. }
  225. if ind == invalidCharForNumber {
  226. iter.ReportError("readUint64", "unexpected character: "+string([]byte{byte(ind)}))
  227. return
  228. }
  229. value := uint64(ind)
  230. for {
  231. for i := iter.head; i < iter.tail; i++ {
  232. ind = intDigits[iter.buf[i]]
  233. if ind == invalidCharForNumber {
  234. iter.head = i
  235. return value
  236. }
  237. if value > uint64SafeToMultiple10 {
  238. value2 := (value << 3) + (value << 1) + uint64(ind)
  239. if value2 < value {
  240. iter.ReportError("readUint64", "overflow")
  241. return
  242. }
  243. value = value2
  244. continue
  245. }
  246. value = (value << 3) + (value << 1) + uint64(ind)
  247. }
  248. if !iter.loadMore() {
  249. return value
  250. }
  251. }
  252. }