msgpack.go 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996
  1. // Copyright (c) 2012-2018 Ugorji Nwoke. All rights reserved.
  2. // Use of this source code is governed by a MIT license found in the LICENSE file.
  3. /*
  4. MSGPACK
  5. Msgpack-c implementation powers the c, c++, python, ruby, etc libraries.
  6. We need to maintain compatibility with it and how it encodes integer values
  7. without caring about the type.
  8. For compatibility with behaviour of msgpack-c reference implementation:
  9. - Go intX (>0) and uintX
  10. IS ENCODED AS
  11. msgpack +ve fixnum, unsigned
  12. - Go intX (<0)
  13. IS ENCODED AS
  14. msgpack -ve fixnum, signed
  15. */
  16. package codec
  17. import (
  18. "fmt"
  19. "io"
  20. "math"
  21. "net/rpc"
  22. "reflect"
  23. "time"
  24. )
  25. const (
  26. mpPosFixNumMin byte = 0x00
  27. mpPosFixNumMax = 0x7f
  28. mpFixMapMin = 0x80
  29. mpFixMapMax = 0x8f
  30. mpFixArrayMin = 0x90
  31. mpFixArrayMax = 0x9f
  32. mpFixStrMin = 0xa0
  33. mpFixStrMax = 0xbf
  34. mpNil = 0xc0
  35. _ = 0xc1
  36. mpFalse = 0xc2
  37. mpTrue = 0xc3
  38. mpFloat = 0xca
  39. mpDouble = 0xcb
  40. mpUint8 = 0xcc
  41. mpUint16 = 0xcd
  42. mpUint32 = 0xce
  43. mpUint64 = 0xcf
  44. mpInt8 = 0xd0
  45. mpInt16 = 0xd1
  46. mpInt32 = 0xd2
  47. mpInt64 = 0xd3
  48. // extensions below
  49. mpBin8 = 0xc4
  50. mpBin16 = 0xc5
  51. mpBin32 = 0xc6
  52. mpExt8 = 0xc7
  53. mpExt16 = 0xc8
  54. mpExt32 = 0xc9
  55. mpFixExt1 = 0xd4
  56. mpFixExt2 = 0xd5
  57. mpFixExt4 = 0xd6
  58. mpFixExt8 = 0xd7
  59. mpFixExt16 = 0xd8
  60. mpStr8 = 0xd9 // new
  61. mpStr16 = 0xda
  62. mpStr32 = 0xdb
  63. mpArray16 = 0xdc
  64. mpArray32 = 0xdd
  65. mpMap16 = 0xde
  66. mpMap32 = 0xdf
  67. mpNegFixNumMin = 0xe0
  68. mpNegFixNumMax = 0xff
  69. )
  70. var mpTimeExtTag int8 = -1
  71. var mpTimeExtTagU = uint8(mpTimeExtTag)
  72. // MsgpackSpecRpcMultiArgs is a special type which signifies to the MsgpackSpecRpcCodec
  73. // that the backend RPC service takes multiple arguments, which have been arranged
  74. // in sequence in the slice.
  75. //
  76. // The Codec then passes it AS-IS to the rpc service (without wrapping it in an
  77. // array of 1 element).
  78. type MsgpackSpecRpcMultiArgs []interface{}
  79. // A MsgpackContainer type specifies the different types of msgpackContainers.
  80. type msgpackContainerType struct {
  81. fixCutoff int
  82. bFixMin, b8, b16, b32 byte
  83. hasFixMin, has8, has8Always bool
  84. }
  85. var (
  86. msgpackContainerStr = msgpackContainerType{32, mpFixStrMin, mpStr8, mpStr16, mpStr32, true, true, false}
  87. msgpackContainerBin = msgpackContainerType{0, 0, mpBin8, mpBin16, mpBin32, false, true, true}
  88. msgpackContainerList = msgpackContainerType{16, mpFixArrayMin, 0, mpArray16, mpArray32, true, false, false}
  89. msgpackContainerMap = msgpackContainerType{16, mpFixMapMin, 0, mpMap16, mpMap32, true, false, false}
  90. )
  91. //---------------------------------------------
  92. type msgpackEncDriver struct {
  93. noBuiltInTypes
  94. encDriverNoopContainerWriter
  95. // encNoSeparator
  96. e *Encoder
  97. w encWriter
  98. h *MsgpackHandle
  99. x [8]byte
  100. }
  101. func (e *msgpackEncDriver) EncodeNil() {
  102. e.w.writen1(mpNil)
  103. }
  104. func (e *msgpackEncDriver) EncodeInt(i int64) {
  105. // if i >= 0 {
  106. // e.EncodeUint(uint64(i))
  107. // } else if false &&
  108. if i > math.MaxInt8 {
  109. if i <= math.MaxInt16 {
  110. e.w.writen1(mpInt16)
  111. bigenHelper{e.x[:2], e.w}.writeUint16(uint16(i))
  112. } else if i <= math.MaxInt32 {
  113. e.w.writen1(mpInt32)
  114. bigenHelper{e.x[:4], e.w}.writeUint32(uint32(i))
  115. } else {
  116. e.w.writen1(mpInt64)
  117. bigenHelper{e.x[:8], e.w}.writeUint64(uint64(i))
  118. }
  119. } else if i >= -32 {
  120. if e.h.NoFixedNum {
  121. e.w.writen2(mpInt8, byte(i))
  122. } else {
  123. e.w.writen1(byte(i))
  124. }
  125. } else if i >= math.MinInt8 {
  126. e.w.writen2(mpInt8, byte(i))
  127. } else if i >= math.MinInt16 {
  128. e.w.writen1(mpInt16)
  129. bigenHelper{e.x[:2], e.w}.writeUint16(uint16(i))
  130. } else if i >= math.MinInt32 {
  131. e.w.writen1(mpInt32)
  132. bigenHelper{e.x[:4], e.w}.writeUint32(uint32(i))
  133. } else {
  134. e.w.writen1(mpInt64)
  135. bigenHelper{e.x[:8], e.w}.writeUint64(uint64(i))
  136. }
  137. }
  138. func (e *msgpackEncDriver) EncodeUint(i uint64) {
  139. if i <= math.MaxInt8 {
  140. if e.h.NoFixedNum {
  141. e.w.writen2(mpUint8, byte(i))
  142. } else {
  143. e.w.writen1(byte(i))
  144. }
  145. } else if i <= math.MaxUint8 {
  146. e.w.writen2(mpUint8, byte(i))
  147. } else if i <= math.MaxUint16 {
  148. e.w.writen1(mpUint16)
  149. bigenHelper{e.x[:2], e.w}.writeUint16(uint16(i))
  150. } else if i <= math.MaxUint32 {
  151. e.w.writen1(mpUint32)
  152. bigenHelper{e.x[:4], e.w}.writeUint32(uint32(i))
  153. } else {
  154. e.w.writen1(mpUint64)
  155. bigenHelper{e.x[:8], e.w}.writeUint64(uint64(i))
  156. }
  157. }
  158. func (e *msgpackEncDriver) EncodeBool(b bool) {
  159. if b {
  160. e.w.writen1(mpTrue)
  161. } else {
  162. e.w.writen1(mpFalse)
  163. }
  164. }
  165. func (e *msgpackEncDriver) EncodeFloat32(f float32) {
  166. e.w.writen1(mpFloat)
  167. bigenHelper{e.x[:4], e.w}.writeUint32(math.Float32bits(f))
  168. }
  169. func (e *msgpackEncDriver) EncodeFloat64(f float64) {
  170. e.w.writen1(mpDouble)
  171. bigenHelper{e.x[:8], e.w}.writeUint64(math.Float64bits(f))
  172. }
  173. func (e *msgpackEncDriver) EncodeTime(t time.Time) {
  174. if t.IsZero() {
  175. e.EncodeNil()
  176. return
  177. }
  178. t = t.UTC()
  179. sec, nsec := t.Unix(), uint64(t.Nanosecond())
  180. var data64 uint64
  181. var l = 4
  182. if sec >= 0 && sec>>34 == 0 {
  183. data64 = (nsec << 34) | uint64(sec)
  184. if data64&0xffffffff00000000 != 0 {
  185. l = 8
  186. }
  187. } else {
  188. l = 12
  189. }
  190. if e.h.WriteExt {
  191. e.encodeExtPreamble(mpTimeExtTagU, l)
  192. } else {
  193. e.writeContainerLen(msgpackContainerStr, l)
  194. }
  195. switch l {
  196. case 4:
  197. bigenHelper{e.x[:4], e.w}.writeUint32(uint32(data64))
  198. case 8:
  199. bigenHelper{e.x[:8], e.w}.writeUint64(data64)
  200. case 12:
  201. bigenHelper{e.x[:4], e.w}.writeUint32(uint32(nsec))
  202. bigenHelper{e.x[:8], e.w}.writeUint64(uint64(sec))
  203. }
  204. }
  205. func (e *msgpackEncDriver) EncodeExt(v interface{}, xtag uint64, ext Ext, _ *Encoder) {
  206. bs := ext.WriteExt(v)
  207. if bs == nil {
  208. e.EncodeNil()
  209. return
  210. }
  211. if e.h.WriteExt {
  212. e.encodeExtPreamble(uint8(xtag), len(bs))
  213. e.w.writeb(bs)
  214. } else {
  215. e.EncodeStringBytes(cRAW, bs)
  216. }
  217. }
  218. func (e *msgpackEncDriver) EncodeRawExt(re *RawExt, _ *Encoder) {
  219. e.encodeExtPreamble(uint8(re.Tag), len(re.Data))
  220. e.w.writeb(re.Data)
  221. }
  222. func (e *msgpackEncDriver) encodeExtPreamble(xtag byte, l int) {
  223. if l == 1 {
  224. e.w.writen2(mpFixExt1, xtag)
  225. } else if l == 2 {
  226. e.w.writen2(mpFixExt2, xtag)
  227. } else if l == 4 {
  228. e.w.writen2(mpFixExt4, xtag)
  229. } else if l == 8 {
  230. e.w.writen2(mpFixExt8, xtag)
  231. } else if l == 16 {
  232. e.w.writen2(mpFixExt16, xtag)
  233. } else if l < 256 {
  234. e.w.writen2(mpExt8, byte(l))
  235. e.w.writen1(xtag)
  236. } else if l < 65536 {
  237. e.w.writen1(mpExt16)
  238. bigenHelper{e.x[:2], e.w}.writeUint16(uint16(l))
  239. e.w.writen1(xtag)
  240. } else {
  241. e.w.writen1(mpExt32)
  242. bigenHelper{e.x[:4], e.w}.writeUint32(uint32(l))
  243. e.w.writen1(xtag)
  244. }
  245. }
  246. func (e *msgpackEncDriver) WriteArrayStart(length int) {
  247. e.writeContainerLen(msgpackContainerList, length)
  248. }
  249. func (e *msgpackEncDriver) WriteMapStart(length int) {
  250. e.writeContainerLen(msgpackContainerMap, length)
  251. }
  252. func (e *msgpackEncDriver) EncodeString(c charEncoding, s string) {
  253. slen := len(s)
  254. if c == cRAW && e.h.WriteExt {
  255. e.writeContainerLen(msgpackContainerBin, slen)
  256. } else {
  257. e.writeContainerLen(msgpackContainerStr, slen)
  258. }
  259. if slen > 0 {
  260. e.w.writestr(s)
  261. }
  262. }
  263. func (e *msgpackEncDriver) EncodeStringBytes(c charEncoding, bs []byte) {
  264. if bs == nil {
  265. e.EncodeNil()
  266. return
  267. }
  268. slen := len(bs)
  269. if c == cRAW && e.h.WriteExt {
  270. e.writeContainerLen(msgpackContainerBin, slen)
  271. } else {
  272. e.writeContainerLen(msgpackContainerStr, slen)
  273. }
  274. if slen > 0 {
  275. e.w.writeb(bs)
  276. }
  277. }
  278. func (e *msgpackEncDriver) writeContainerLen(ct msgpackContainerType, l int) {
  279. if ct.hasFixMin && l < ct.fixCutoff {
  280. e.w.writen1(ct.bFixMin | byte(l))
  281. } else if ct.has8 && l < 256 && (ct.has8Always || e.h.WriteExt) {
  282. e.w.writen2(ct.b8, uint8(l))
  283. } else if l < 65536 {
  284. e.w.writen1(ct.b16)
  285. bigenHelper{e.x[:2], e.w}.writeUint16(uint16(l))
  286. } else {
  287. e.w.writen1(ct.b32)
  288. bigenHelper{e.x[:4], e.w}.writeUint32(uint32(l))
  289. }
  290. }
  291. //---------------------------------------------
  292. type msgpackDecDriver struct {
  293. d *Decoder
  294. r decReader // *Decoder decReader decReaderT
  295. h *MsgpackHandle
  296. b [scratchByteArrayLen]byte
  297. bd byte
  298. bdRead bool
  299. br bool // bytes reader
  300. noBuiltInTypes
  301. // noStreamingCodec
  302. // decNoSeparator
  303. decDriverNoopContainerReader
  304. }
  305. // Note: This returns either a primitive (int, bool, etc) for non-containers,
  306. // or a containerType, or a specific type denoting nil or extension.
  307. // It is called when a nil interface{} is passed, leaving it up to the DecDriver
  308. // to introspect the stream and decide how best to decode.
  309. // It deciphers the value by looking at the stream first.
  310. func (d *msgpackDecDriver) DecodeNaked() {
  311. if !d.bdRead {
  312. d.readNextBd()
  313. }
  314. bd := d.bd
  315. n := d.d.n
  316. var decodeFurther bool
  317. switch bd {
  318. case mpNil:
  319. n.v = valueTypeNil
  320. d.bdRead = false
  321. case mpFalse:
  322. n.v = valueTypeBool
  323. n.b = false
  324. case mpTrue:
  325. n.v = valueTypeBool
  326. n.b = true
  327. case mpFloat:
  328. n.v = valueTypeFloat
  329. n.f = float64(math.Float32frombits(bigen.Uint32(d.r.readx(4))))
  330. case mpDouble:
  331. n.v = valueTypeFloat
  332. n.f = math.Float64frombits(bigen.Uint64(d.r.readx(8)))
  333. case mpUint8:
  334. n.v = valueTypeUint
  335. n.u = uint64(d.r.readn1())
  336. case mpUint16:
  337. n.v = valueTypeUint
  338. n.u = uint64(bigen.Uint16(d.r.readx(2)))
  339. case mpUint32:
  340. n.v = valueTypeUint
  341. n.u = uint64(bigen.Uint32(d.r.readx(4)))
  342. case mpUint64:
  343. n.v = valueTypeUint
  344. n.u = uint64(bigen.Uint64(d.r.readx(8)))
  345. case mpInt8:
  346. n.v = valueTypeInt
  347. n.i = int64(int8(d.r.readn1()))
  348. case mpInt16:
  349. n.v = valueTypeInt
  350. n.i = int64(int16(bigen.Uint16(d.r.readx(2))))
  351. case mpInt32:
  352. n.v = valueTypeInt
  353. n.i = int64(int32(bigen.Uint32(d.r.readx(4))))
  354. case mpInt64:
  355. n.v = valueTypeInt
  356. n.i = int64(int64(bigen.Uint64(d.r.readx(8))))
  357. default:
  358. switch {
  359. case bd >= mpPosFixNumMin && bd <= mpPosFixNumMax:
  360. // positive fixnum (always signed)
  361. n.v = valueTypeInt
  362. n.i = int64(int8(bd))
  363. case bd >= mpNegFixNumMin && bd <= mpNegFixNumMax:
  364. // negative fixnum
  365. n.v = valueTypeInt
  366. n.i = int64(int8(bd))
  367. case bd == mpStr8, bd == mpStr16, bd == mpStr32, bd >= mpFixStrMin && bd <= mpFixStrMax:
  368. if d.h.RawToString {
  369. n.v = valueTypeString
  370. n.s = d.DecodeString()
  371. } else {
  372. n.v = valueTypeBytes
  373. n.l = d.DecodeBytes(nil, false)
  374. }
  375. case bd == mpBin8, bd == mpBin16, bd == mpBin32:
  376. n.v = valueTypeBytes
  377. n.l = d.DecodeBytes(nil, false)
  378. case bd == mpArray16, bd == mpArray32, bd >= mpFixArrayMin && bd <= mpFixArrayMax:
  379. n.v = valueTypeArray
  380. decodeFurther = true
  381. case bd == mpMap16, bd == mpMap32, bd >= mpFixMapMin && bd <= mpFixMapMax:
  382. n.v = valueTypeMap
  383. decodeFurther = true
  384. case bd >= mpFixExt1 && bd <= mpFixExt16, bd >= mpExt8 && bd <= mpExt32:
  385. n.v = valueTypeExt
  386. clen := d.readExtLen()
  387. n.u = uint64(d.r.readn1())
  388. if n.u == uint64(mpTimeExtTagU) {
  389. n.v = valueTypeTime
  390. n.t = d.decodeTime(clen)
  391. } else {
  392. n.l = d.r.readx(clen)
  393. }
  394. default:
  395. d.d.errorf("Nil-Deciphered DecodeValue: %s: hex: %x, dec: %d", msgBadDesc, bd, bd)
  396. }
  397. }
  398. if !decodeFurther {
  399. d.bdRead = false
  400. }
  401. if n.v == valueTypeUint && d.h.SignedInteger {
  402. n.v = valueTypeInt
  403. n.i = int64(n.u)
  404. }
  405. return
  406. }
  407. // int can be decoded from msgpack type: intXXX or uintXXX
  408. func (d *msgpackDecDriver) DecodeInt64() (i int64) {
  409. if !d.bdRead {
  410. d.readNextBd()
  411. }
  412. switch d.bd {
  413. case mpUint8:
  414. i = int64(uint64(d.r.readn1()))
  415. case mpUint16:
  416. i = int64(uint64(bigen.Uint16(d.r.readx(2))))
  417. case mpUint32:
  418. i = int64(uint64(bigen.Uint32(d.r.readx(4))))
  419. case mpUint64:
  420. i = int64(bigen.Uint64(d.r.readx(8)))
  421. case mpInt8:
  422. i = int64(int8(d.r.readn1()))
  423. case mpInt16:
  424. i = int64(int16(bigen.Uint16(d.r.readx(2))))
  425. case mpInt32:
  426. i = int64(int32(bigen.Uint32(d.r.readx(4))))
  427. case mpInt64:
  428. i = int64(bigen.Uint64(d.r.readx(8)))
  429. default:
  430. switch {
  431. case d.bd >= mpPosFixNumMin && d.bd <= mpPosFixNumMax:
  432. i = int64(int8(d.bd))
  433. case d.bd >= mpNegFixNumMin && d.bd <= mpNegFixNumMax:
  434. i = int64(int8(d.bd))
  435. default:
  436. d.d.errorf("Unhandled single-byte unsigned integer value: %s: %x", msgBadDesc, d.bd)
  437. return
  438. }
  439. }
  440. d.bdRead = false
  441. return
  442. }
  443. // uint can be decoded from msgpack type: intXXX or uintXXX
  444. func (d *msgpackDecDriver) DecodeUint64() (ui uint64) {
  445. if !d.bdRead {
  446. d.readNextBd()
  447. }
  448. switch d.bd {
  449. case mpUint8:
  450. ui = uint64(d.r.readn1())
  451. case mpUint16:
  452. ui = uint64(bigen.Uint16(d.r.readx(2)))
  453. case mpUint32:
  454. ui = uint64(bigen.Uint32(d.r.readx(4)))
  455. case mpUint64:
  456. ui = bigen.Uint64(d.r.readx(8))
  457. case mpInt8:
  458. if i := int64(int8(d.r.readn1())); i >= 0 {
  459. ui = uint64(i)
  460. } else {
  461. d.d.errorf("Assigning negative signed value: %v, to unsigned type", i)
  462. return
  463. }
  464. case mpInt16:
  465. if i := int64(int16(bigen.Uint16(d.r.readx(2)))); i >= 0 {
  466. ui = uint64(i)
  467. } else {
  468. d.d.errorf("Assigning negative signed value: %v, to unsigned type", i)
  469. return
  470. }
  471. case mpInt32:
  472. if i := int64(int32(bigen.Uint32(d.r.readx(4)))); i >= 0 {
  473. ui = uint64(i)
  474. } else {
  475. d.d.errorf("Assigning negative signed value: %v, to unsigned type", i)
  476. return
  477. }
  478. case mpInt64:
  479. if i := int64(bigen.Uint64(d.r.readx(8))); i >= 0 {
  480. ui = uint64(i)
  481. } else {
  482. d.d.errorf("Assigning negative signed value: %v, to unsigned type", i)
  483. return
  484. }
  485. default:
  486. switch {
  487. case d.bd >= mpPosFixNumMin && d.bd <= mpPosFixNumMax:
  488. ui = uint64(d.bd)
  489. case d.bd >= mpNegFixNumMin && d.bd <= mpNegFixNumMax:
  490. d.d.errorf("Assigning negative signed value: %v, to unsigned type", int(d.bd))
  491. return
  492. default:
  493. d.d.errorf("Unhandled single-byte unsigned integer value: %s: %x", msgBadDesc, d.bd)
  494. return
  495. }
  496. }
  497. d.bdRead = false
  498. return
  499. }
  500. // float can either be decoded from msgpack type: float, double or intX
  501. func (d *msgpackDecDriver) DecodeFloat64() (f float64) {
  502. if !d.bdRead {
  503. d.readNextBd()
  504. }
  505. if d.bd == mpFloat {
  506. f = float64(math.Float32frombits(bigen.Uint32(d.r.readx(4))))
  507. } else if d.bd == mpDouble {
  508. f = math.Float64frombits(bigen.Uint64(d.r.readx(8)))
  509. } else {
  510. f = float64(d.DecodeInt64())
  511. }
  512. d.bdRead = false
  513. return
  514. }
  515. // bool can be decoded from bool, fixnum 0 or 1.
  516. func (d *msgpackDecDriver) DecodeBool() (b bool) {
  517. if !d.bdRead {
  518. d.readNextBd()
  519. }
  520. if d.bd == mpFalse || d.bd == 0 {
  521. // b = false
  522. } else if d.bd == mpTrue || d.bd == 1 {
  523. b = true
  524. } else {
  525. d.d.errorf("Invalid single-byte value for bool: %s: %x", msgBadDesc, d.bd)
  526. return
  527. }
  528. d.bdRead = false
  529. return
  530. }
  531. func (d *msgpackDecDriver) DecodeBytes(bs []byte, zerocopy bool) (bsOut []byte) {
  532. if !d.bdRead {
  533. d.readNextBd()
  534. }
  535. // check if an "array" of uint8's (see ContainerType for how to infer if an array)
  536. bd := d.bd
  537. // DecodeBytes could be from: bin str fixstr fixarray array ...
  538. var clen int
  539. vt := d.ContainerType()
  540. switch vt {
  541. case valueTypeBytes:
  542. // valueTypeBytes may be a mpBin or an mpStr container
  543. if bd == mpBin8 || bd == mpBin16 || bd == mpBin32 {
  544. clen = d.readContainerLen(msgpackContainerBin)
  545. } else {
  546. clen = d.readContainerLen(msgpackContainerStr)
  547. }
  548. case valueTypeString:
  549. clen = d.readContainerLen(msgpackContainerStr)
  550. case valueTypeArray:
  551. bsOut, _ = fastpathTV.DecSliceUint8V(bs, true, d.d)
  552. return
  553. default:
  554. d.d.errorf("invalid container type: expecting bin|str|array, got: 0x%x", uint8(vt))
  555. return
  556. }
  557. // these are (bin|str)(8|16|32)
  558. d.bdRead = false
  559. // bytes may be nil, so handle it. if nil, clen=-1.
  560. if clen < 0 {
  561. return nil
  562. }
  563. if zerocopy {
  564. if d.br {
  565. return d.r.readx(clen)
  566. } else if len(bs) == 0 {
  567. bs = d.b[:]
  568. }
  569. }
  570. return decByteSlice(d.r, clen, d.d.h.MaxInitLen, bs)
  571. }
  572. func (d *msgpackDecDriver) DecodeString() (s string) {
  573. return string(d.DecodeBytes(d.b[:], true))
  574. }
  575. func (d *msgpackDecDriver) DecodeStringAsBytes() (s []byte) {
  576. return d.DecodeBytes(d.b[:], true)
  577. }
  578. func (d *msgpackDecDriver) readNextBd() {
  579. d.bd = d.r.readn1()
  580. d.bdRead = true
  581. }
  582. func (d *msgpackDecDriver) uncacheRead() {
  583. if d.bdRead {
  584. d.r.unreadn1()
  585. d.bdRead = false
  586. }
  587. }
  588. func (d *msgpackDecDriver) ContainerType() (vt valueType) {
  589. if !d.bdRead {
  590. d.readNextBd()
  591. }
  592. bd := d.bd
  593. if bd == mpNil {
  594. return valueTypeNil
  595. } else if bd == mpBin8 || bd == mpBin16 || bd == mpBin32 ||
  596. (!d.h.RawToString &&
  597. (bd == mpStr8 || bd == mpStr16 || bd == mpStr32 || (bd >= mpFixStrMin && bd <= mpFixStrMax))) {
  598. return valueTypeBytes
  599. } else if d.h.RawToString &&
  600. (bd == mpStr8 || bd == mpStr16 || bd == mpStr32 || (bd >= mpFixStrMin && bd <= mpFixStrMax)) {
  601. return valueTypeString
  602. } else if bd == mpArray16 || bd == mpArray32 || (bd >= mpFixArrayMin && bd <= mpFixArrayMax) {
  603. return valueTypeArray
  604. } else if bd == mpMap16 || bd == mpMap32 || (bd >= mpFixMapMin && bd <= mpFixMapMax) {
  605. return valueTypeMap
  606. }
  607. // else {
  608. // d.d.errorf("isContainerType: unsupported parameter: %v", vt)
  609. // }
  610. return valueTypeUnset
  611. }
  612. func (d *msgpackDecDriver) TryDecodeAsNil() (v bool) {
  613. if !d.bdRead {
  614. d.readNextBd()
  615. }
  616. if d.bd == mpNil {
  617. d.bdRead = false
  618. return true
  619. }
  620. return
  621. }
  622. func (d *msgpackDecDriver) readContainerLen(ct msgpackContainerType) (clen int) {
  623. bd := d.bd
  624. if bd == mpNil {
  625. clen = -1 // to represent nil
  626. } else if bd == ct.b8 {
  627. clen = int(d.r.readn1())
  628. } else if bd == ct.b16 {
  629. clen = int(bigen.Uint16(d.r.readx(2)))
  630. } else if bd == ct.b32 {
  631. clen = int(bigen.Uint32(d.r.readx(4)))
  632. } else if (ct.bFixMin & bd) == ct.bFixMin {
  633. clen = int(ct.bFixMin ^ bd)
  634. } else {
  635. d.d.errorf("readContainerLen: %s: hex: %x, decimal: %d", msgBadDesc, bd, bd)
  636. return
  637. }
  638. d.bdRead = false
  639. return
  640. }
  641. func (d *msgpackDecDriver) ReadMapStart() int {
  642. if !d.bdRead {
  643. d.readNextBd()
  644. }
  645. return d.readContainerLen(msgpackContainerMap)
  646. }
  647. func (d *msgpackDecDriver) ReadArrayStart() int {
  648. if !d.bdRead {
  649. d.readNextBd()
  650. }
  651. return d.readContainerLen(msgpackContainerList)
  652. }
  653. func (d *msgpackDecDriver) readExtLen() (clen int) {
  654. switch d.bd {
  655. case mpNil:
  656. clen = -1 // to represent nil
  657. case mpFixExt1:
  658. clen = 1
  659. case mpFixExt2:
  660. clen = 2
  661. case mpFixExt4:
  662. clen = 4
  663. case mpFixExt8:
  664. clen = 8
  665. case mpFixExt16:
  666. clen = 16
  667. case mpExt8:
  668. clen = int(d.r.readn1())
  669. case mpExt16:
  670. clen = int(bigen.Uint16(d.r.readx(2)))
  671. case mpExt32:
  672. clen = int(bigen.Uint32(d.r.readx(4)))
  673. default:
  674. d.d.errorf("decoding ext bytes: found unexpected byte: %x", d.bd)
  675. return
  676. }
  677. return
  678. }
  679. func (d *msgpackDecDriver) DecodeTime() (t time.Time) {
  680. // decode time from string bytes or ext
  681. if !d.bdRead {
  682. d.readNextBd()
  683. }
  684. if d.bd == mpNil {
  685. d.bdRead = false
  686. return
  687. }
  688. var clen int
  689. switch d.ContainerType() {
  690. case valueTypeBytes, valueTypeString:
  691. clen = d.readContainerLen(msgpackContainerStr)
  692. default:
  693. // expect to see mpFixExt4,-1 OR mpFixExt8,-1 OR mpExt8,12,-1
  694. d.bdRead = false
  695. b2 := d.r.readn1()
  696. if d.bd == mpFixExt4 && b2 == mpTimeExtTagU {
  697. clen = 4
  698. } else if d.bd == mpFixExt8 && b2 == mpTimeExtTagU {
  699. clen = 8
  700. } else if d.bd == mpExt8 && b2 == 12 && d.r.readn1() == mpTimeExtTagU {
  701. clen = 12
  702. } else {
  703. d.d.errorf("invalid sequence of bytes for decoding time as an extension: got 0x%x, 0x%x", d.bd, b2)
  704. return
  705. }
  706. }
  707. return d.decodeTime(clen)
  708. }
  709. func (d *msgpackDecDriver) decodeTime(clen int) (t time.Time) {
  710. // bs = d.r.readx(clen)
  711. d.bdRead = false
  712. switch clen {
  713. case 4:
  714. t = time.Unix(int64(bigen.Uint32(d.r.readx(4))), 0).UTC()
  715. case 8:
  716. tv := bigen.Uint64(d.r.readx(8))
  717. t = time.Unix(int64(tv&0x00000003ffffffff), int64(tv>>34)).UTC()
  718. case 12:
  719. nsec := bigen.Uint32(d.r.readx(4))
  720. sec := bigen.Uint64(d.r.readx(8))
  721. t = time.Unix(int64(sec), int64(nsec)).UTC()
  722. default:
  723. d.d.errorf("invalid length of bytes for decoding time - expecting 4 or 8 or 12, got %d", clen)
  724. return
  725. }
  726. return
  727. }
  728. func (d *msgpackDecDriver) DecodeExt(rv interface{}, xtag uint64, ext Ext) (realxtag uint64) {
  729. if xtag > 0xff {
  730. d.d.errorf("decodeExt: tag must be <= 0xff; got: %v", xtag)
  731. return
  732. }
  733. realxtag1, xbs := d.decodeExtV(ext != nil, uint8(xtag))
  734. realxtag = uint64(realxtag1)
  735. if ext == nil {
  736. re := rv.(*RawExt)
  737. re.Tag = realxtag
  738. re.Data = detachZeroCopyBytes(d.br, re.Data, xbs)
  739. } else {
  740. ext.ReadExt(rv, xbs)
  741. }
  742. return
  743. }
  744. func (d *msgpackDecDriver) decodeExtV(verifyTag bool, tag byte) (xtag byte, xbs []byte) {
  745. if !d.bdRead {
  746. d.readNextBd()
  747. }
  748. xbd := d.bd
  749. if xbd == mpBin8 || xbd == mpBin16 || xbd == mpBin32 {
  750. xbs = d.DecodeBytes(nil, true)
  751. } else if xbd == mpStr8 || xbd == mpStr16 || xbd == mpStr32 ||
  752. (xbd >= mpFixStrMin && xbd <= mpFixStrMax) {
  753. xbs = d.DecodeStringAsBytes()
  754. } else {
  755. clen := d.readExtLen()
  756. xtag = d.r.readn1()
  757. if verifyTag && xtag != tag {
  758. d.d.errorf("Wrong extension tag. Got %b. Expecting: %v", xtag, tag)
  759. return
  760. }
  761. xbs = d.r.readx(clen)
  762. }
  763. d.bdRead = false
  764. return
  765. }
  766. //--------------------------------------------------
  767. //MsgpackHandle is a Handle for the Msgpack Schema-Free Encoding Format.
  768. type MsgpackHandle struct {
  769. BasicHandle
  770. // RawToString controls how raw bytes are decoded into a nil interface{}.
  771. RawToString bool
  772. // NoFixedNum says to output all signed integers as 2-bytes, never as 1-byte fixednum.
  773. NoFixedNum bool
  774. // WriteExt flag supports encoding configured extensions with extension tags.
  775. // It also controls whether other elements of the new spec are encoded (ie Str8).
  776. //
  777. // With WriteExt=false, configured extensions are serialized as raw bytes
  778. // and Str8 is not encoded.
  779. //
  780. // A stream can still be decoded into a typed value, provided an appropriate value
  781. // is provided, but the type cannot be inferred from the stream. If no appropriate
  782. // type is provided (e.g. decoding into a nil interface{}), you get back
  783. // a []byte or string based on the setting of RawToString.
  784. WriteExt bool
  785. binaryEncodingType
  786. noElemSeparators
  787. }
  788. // Name returns the name of the handle: msgpack
  789. func (h *MsgpackHandle) Name() string { return "msgpack" }
  790. // SetBytesExt sets an extension
  791. func (h *MsgpackHandle) SetBytesExt(rt reflect.Type, tag uint64, ext BytesExt) (err error) {
  792. return h.SetExt(rt, tag, &extWrapper{ext, interfaceExtFailer{}})
  793. }
  794. func (h *MsgpackHandle) newEncDriver(e *Encoder) encDriver {
  795. return &msgpackEncDriver{e: e, w: e.w, h: h}
  796. }
  797. func (h *MsgpackHandle) newDecDriver(d *Decoder) decDriver {
  798. return &msgpackDecDriver{d: d, h: h, r: d.r, br: d.bytes}
  799. }
  800. func (e *msgpackEncDriver) reset() {
  801. e.w = e.e.w
  802. }
  803. func (d *msgpackDecDriver) reset() {
  804. d.r, d.br = d.d.r, d.d.bytes
  805. d.bd, d.bdRead = 0, false
  806. }
  807. //--------------------------------------------------
  808. type msgpackSpecRpcCodec struct {
  809. rpcCodec
  810. }
  811. // /////////////// Spec RPC Codec ///////////////////
  812. func (c *msgpackSpecRpcCodec) WriteRequest(r *rpc.Request, body interface{}) error {
  813. // WriteRequest can write to both a Go service, and other services that do
  814. // not abide by the 1 argument rule of a Go service.
  815. // We discriminate based on if the body is a MsgpackSpecRpcMultiArgs
  816. var bodyArr []interface{}
  817. if m, ok := body.(MsgpackSpecRpcMultiArgs); ok {
  818. bodyArr = ([]interface{})(m)
  819. } else {
  820. bodyArr = []interface{}{body}
  821. }
  822. r2 := []interface{}{0, uint32(r.Seq), r.ServiceMethod, bodyArr}
  823. return c.write(r2, nil, false)
  824. }
  825. func (c *msgpackSpecRpcCodec) WriteResponse(r *rpc.Response, body interface{}) error {
  826. var moe interface{}
  827. if r.Error != "" {
  828. moe = r.Error
  829. }
  830. if moe != nil && body != nil {
  831. body = nil
  832. }
  833. r2 := []interface{}{1, uint32(r.Seq), moe, body}
  834. return c.write(r2, nil, false)
  835. }
  836. func (c *msgpackSpecRpcCodec) ReadResponseHeader(r *rpc.Response) error {
  837. return c.parseCustomHeader(1, &r.Seq, &r.Error)
  838. }
  839. func (c *msgpackSpecRpcCodec) ReadRequestHeader(r *rpc.Request) error {
  840. return c.parseCustomHeader(0, &r.Seq, &r.ServiceMethod)
  841. }
  842. func (c *msgpackSpecRpcCodec) ReadRequestBody(body interface{}) error {
  843. if body == nil { // read and discard
  844. return c.read(nil)
  845. }
  846. bodyArr := []interface{}{body}
  847. return c.read(&bodyArr)
  848. }
  849. func (c *msgpackSpecRpcCodec) parseCustomHeader(expectTypeByte byte, msgid *uint64, methodOrError *string) (err error) {
  850. if c.isClosed() {
  851. return io.EOF
  852. }
  853. // We read the response header by hand
  854. // so that the body can be decoded on its own from the stream at a later time.
  855. const fia byte = 0x94 //four item array descriptor value
  856. // Not sure why the panic of EOF is swallowed above.
  857. // if bs1 := c.dec.r.readn1(); bs1 != fia {
  858. // err = fmt.Errorf("Unexpected value for array descriptor: Expecting %v. Received %v", fia, bs1)
  859. // return
  860. // }
  861. var ba [1]byte
  862. var n int
  863. for {
  864. n, err = c.r.Read(ba[:])
  865. if err != nil {
  866. return
  867. }
  868. if n == 1 {
  869. break
  870. }
  871. }
  872. var b = ba[0]
  873. if b != fia {
  874. err = fmt.Errorf("Unexpected value for array descriptor: Expecting %v. Received %v", fia, b)
  875. } else {
  876. err = c.read(&b)
  877. if err == nil {
  878. if b != expectTypeByte {
  879. err = fmt.Errorf("Unexpected byte descriptor in header. Expecting %v. Received %v", expectTypeByte, b)
  880. } else {
  881. err = c.read(msgid)
  882. if err == nil {
  883. err = c.read(methodOrError)
  884. }
  885. }
  886. }
  887. }
  888. return
  889. }
  890. //--------------------------------------------------
  891. // msgpackSpecRpc is the implementation of Rpc that uses custom communication protocol
  892. // as defined in the msgpack spec at https://github.com/msgpack-rpc/msgpack-rpc/blob/master/spec.md
  893. type msgpackSpecRpc struct{}
  894. // MsgpackSpecRpc implements Rpc using the communication protocol defined in
  895. // the msgpack spec at https://github.com/msgpack-rpc/msgpack-rpc/blob/master/spec.md .
  896. //
  897. // See GoRpc documentation, for information on buffering for better performance.
  898. var MsgpackSpecRpc msgpackSpecRpc
  899. func (x msgpackSpecRpc) ServerCodec(conn io.ReadWriteCloser, h Handle) rpc.ServerCodec {
  900. return &msgpackSpecRpcCodec{newRPCCodec(conn, h)}
  901. }
  902. func (x msgpackSpecRpc) ClientCodec(conn io.ReadWriteCloser, h Handle) rpc.ClientCodec {
  903. return &msgpackSpecRpcCodec{newRPCCodec(conn, h)}
  904. }
  905. var _ decDriver = (*msgpackDecDriver)(nil)
  906. var _ encDriver = (*msgpackEncDriver)(nil)