feature_iter_object.go 2.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145
  1. package jsoniter
  2. import "fmt"
  3. func (iter *Iterator) ReadObject() (ret string) {
  4. c := iter.nextToken()
  5. switch c {
  6. case 'n':
  7. iter.skipFixedBytes(3)
  8. return "" // null
  9. case '{':
  10. c = iter.nextToken()
  11. if c == '"' {
  12. iter.unreadByte()
  13. return string(iter.readObjectFieldAsBytes())
  14. }
  15. if c == '}' {
  16. return "" // end of object
  17. }
  18. iter.reportError("ReadObject", `expect " after {`)
  19. return
  20. case ',':
  21. return string(iter.readObjectFieldAsBytes())
  22. case '}':
  23. return "" // end of object
  24. default:
  25. iter.reportError("ReadObject", fmt.Sprintf(`expect { or , or } or n, but found %s`, string([]byte{c})))
  26. return
  27. }
  28. }
  29. func (iter *Iterator) readFieldHash() int32 {
  30. hash := int64(0x811c9dc5)
  31. c := iter.nextToken()
  32. if c == '"' {
  33. for {
  34. for i := iter.head; i < iter.tail; i++ {
  35. // require ascii string and no escape
  36. b := iter.buf[i]
  37. if b == '"' {
  38. iter.head = i+1
  39. c = iter.nextToken()
  40. if c != ':' {
  41. iter.reportError("readFieldHash", `expect :, but found ` + string([]byte{c}))
  42. }
  43. return int32(hash)
  44. }
  45. hash ^= int64(b)
  46. hash *= 0x1000193
  47. }
  48. if !iter.loadMore() {
  49. iter.reportError("readFieldHash", `incomplete field name`)
  50. return 0
  51. }
  52. }
  53. }
  54. iter.reportError("readFieldHash", `expect ", but found ` + string([]byte{c}))
  55. return 0
  56. }
  57. func calcHash(str string) int32 {
  58. hash := int64(0x811c9dc5)
  59. for _, b := range str {
  60. hash ^= int64(b)
  61. hash *= 0x1000193
  62. }
  63. return int32(hash)
  64. }
  65. func (iter *Iterator) ReadObjectCB(callback func(*Iterator, string) bool) bool {
  66. c := iter.nextToken()
  67. if c == '{' {
  68. c = iter.nextToken()
  69. if c == '"' {
  70. iter.unreadByte()
  71. field := string(iter.readObjectFieldAsBytes())
  72. if !callback(iter, field) {
  73. return false
  74. }
  75. for iter.nextToken() == ',' {
  76. field := string(iter.readObjectFieldAsBytes())
  77. if !callback(iter, field) {
  78. return false
  79. }
  80. }
  81. return true
  82. }
  83. if c == '}' {
  84. return true
  85. }
  86. iter.reportError("ReadObjectCB", `expect " after }`)
  87. return false
  88. }
  89. if c == 'n' {
  90. iter.skipFixedBytes(3)
  91. return true // null
  92. }
  93. iter.reportError("ReadObjectCB", `expect { or n`)
  94. return false
  95. }
  96. func (iter *Iterator) readObjectStart() bool {
  97. c := iter.nextToken()
  98. if c == '{' {
  99. c = iter.nextToken()
  100. if c == '}' {
  101. return false
  102. }
  103. iter.unreadByte()
  104. return true
  105. }
  106. iter.reportError("readObjectStart", "expect { ")
  107. return false
  108. }
  109. func (iter *Iterator) readObjectFieldAsBytes() (ret []byte) {
  110. str := iter.ReadStringAsSlice()
  111. if iter.skipWhitespacesWithoutLoadMore() {
  112. if ret == nil {
  113. ret = make([]byte, len(str))
  114. copy(ret, str)
  115. }
  116. if !iter.loadMore() {
  117. return
  118. }
  119. }
  120. if iter.buf[iter.head] != ':' {
  121. iter.reportError("readObjectFieldAsBytes", "expect : after object field")
  122. return
  123. }
  124. iter.head++
  125. if iter.skipWhitespacesWithoutLoadMore() {
  126. if ret == nil {
  127. ret = make([]byte, len(str))
  128. copy(ret, str)
  129. }
  130. if !iter.loadMore() {
  131. return
  132. }
  133. }
  134. if ret == nil {
  135. return str
  136. }
  137. return ret
  138. }