feature_iter_object.go 3.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148
  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. } else if c == 'n' {
  106. iter.skipFixedBytes(3)
  107. return false
  108. }
  109. iter.reportError("readObjectStart", "expect { or n")
  110. return false
  111. }
  112. func (iter *Iterator) readObjectFieldAsBytes() (ret []byte) {
  113. str := iter.ReadStringAsSlice()
  114. if iter.skipWhitespacesWithoutLoadMore() {
  115. if ret == nil {
  116. ret = make([]byte, len(str))
  117. copy(ret, str)
  118. }
  119. if !iter.loadMore() {
  120. return
  121. }
  122. }
  123. if iter.buf[iter.head] != ':' {
  124. iter.reportError("readObjectFieldAsBytes", "expect : after object field")
  125. return
  126. }
  127. iter.head++
  128. if iter.skipWhitespacesWithoutLoadMore() {
  129. if ret == nil {
  130. ret = make([]byte, len(str))
  131. copy(ret, str)
  132. }
  133. if !iter.loadMore() {
  134. return
  135. }
  136. }
  137. if ret == nil {
  138. return str
  139. }
  140. return ret
  141. }