msgpack.go 26 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015
  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) EncodeSymbol(v string) {
  264. // e.EncodeString(cUTF8, v)
  265. // }
  266. func (e *msgpackEncDriver) EncodeStringBytes(c charEncoding, bs []byte) {
  267. if bs == nil {
  268. e.EncodeNil()
  269. return
  270. }
  271. slen := len(bs)
  272. if c == cRAW && e.h.WriteExt {
  273. e.writeContainerLen(msgpackContainerBin, slen)
  274. } else {
  275. e.writeContainerLen(msgpackContainerStr, slen)
  276. }
  277. if slen > 0 {
  278. e.w.writeb(bs)
  279. }
  280. }
  281. func (e *msgpackEncDriver) writeContainerLen(ct msgpackContainerType, l int) {
  282. if ct.hasFixMin && l < ct.fixCutoff {
  283. e.w.writen1(ct.bFixMin | byte(l))
  284. } else if ct.has8 && l < 256 && (ct.has8Always || e.h.WriteExt) {
  285. e.w.writen2(ct.b8, uint8(l))
  286. } else if l < 65536 {
  287. e.w.writen1(ct.b16)
  288. bigenHelper{e.x[:2], e.w}.writeUint16(uint16(l))
  289. } else {
  290. e.w.writen1(ct.b32)
  291. bigenHelper{e.x[:4], e.w}.writeUint32(uint32(l))
  292. }
  293. }
  294. //---------------------------------------------
  295. type msgpackDecDriver struct {
  296. d *Decoder
  297. r decReader // *Decoder decReader decReaderT
  298. h *MsgpackHandle
  299. b [scratchByteArrayLen]byte
  300. bd byte
  301. bdRead bool
  302. br bool // bytes reader
  303. noBuiltInTypes
  304. // noStreamingCodec
  305. // decNoSeparator
  306. decDriverNoopContainerReader
  307. }
  308. // Note: This returns either a primitive (int, bool, etc) for non-containers,
  309. // or a containerType, or a specific type denoting nil or extension.
  310. // It is called when a nil interface{} is passed, leaving it up to the DecDriver
  311. // to introspect the stream and decide how best to decode.
  312. // It deciphers the value by looking at the stream first.
  313. func (d *msgpackDecDriver) DecodeNaked() {
  314. if !d.bdRead {
  315. d.readNextBd()
  316. }
  317. bd := d.bd
  318. n := d.d.n
  319. var decodeFurther bool
  320. switch bd {
  321. case mpNil:
  322. n.v = valueTypeNil
  323. d.bdRead = false
  324. case mpFalse:
  325. n.v = valueTypeBool
  326. n.b = false
  327. case mpTrue:
  328. n.v = valueTypeBool
  329. n.b = true
  330. case mpFloat:
  331. n.v = valueTypeFloat
  332. n.f = float64(math.Float32frombits(bigen.Uint32(d.r.readx(4))))
  333. case mpDouble:
  334. n.v = valueTypeFloat
  335. n.f = math.Float64frombits(bigen.Uint64(d.r.readx(8)))
  336. case mpUint8:
  337. n.v = valueTypeUint
  338. n.u = uint64(d.r.readn1())
  339. case mpUint16:
  340. n.v = valueTypeUint
  341. n.u = uint64(bigen.Uint16(d.r.readx(2)))
  342. case mpUint32:
  343. n.v = valueTypeUint
  344. n.u = uint64(bigen.Uint32(d.r.readx(4)))
  345. case mpUint64:
  346. n.v = valueTypeUint
  347. n.u = uint64(bigen.Uint64(d.r.readx(8)))
  348. case mpInt8:
  349. n.v = valueTypeInt
  350. n.i = int64(int8(d.r.readn1()))
  351. case mpInt16:
  352. n.v = valueTypeInt
  353. n.i = int64(int16(bigen.Uint16(d.r.readx(2))))
  354. case mpInt32:
  355. n.v = valueTypeInt
  356. n.i = int64(int32(bigen.Uint32(d.r.readx(4))))
  357. case mpInt64:
  358. n.v = valueTypeInt
  359. n.i = int64(int64(bigen.Uint64(d.r.readx(8))))
  360. default:
  361. switch {
  362. case bd >= mpPosFixNumMin && bd <= mpPosFixNumMax:
  363. // positive fixnum (always signed)
  364. n.v = valueTypeInt
  365. n.i = int64(int8(bd))
  366. case bd >= mpNegFixNumMin && bd <= mpNegFixNumMax:
  367. // negative fixnum
  368. n.v = valueTypeInt
  369. n.i = int64(int8(bd))
  370. case bd == mpStr8, bd == mpStr16, bd == mpStr32, bd >= mpFixStrMin && bd <= mpFixStrMax:
  371. if d.h.RawToString {
  372. n.v = valueTypeString
  373. n.s = d.DecodeString()
  374. } else {
  375. n.v = valueTypeBytes
  376. n.l = d.DecodeBytes(nil, false)
  377. }
  378. case bd == mpBin8, bd == mpBin16, bd == mpBin32:
  379. n.v = valueTypeBytes
  380. n.l = d.DecodeBytes(nil, false)
  381. case bd == mpArray16, bd == mpArray32, bd >= mpFixArrayMin && bd <= mpFixArrayMax:
  382. n.v = valueTypeArray
  383. decodeFurther = true
  384. case bd == mpMap16, bd == mpMap32, bd >= mpFixMapMin && bd <= mpFixMapMax:
  385. n.v = valueTypeMap
  386. decodeFurther = true
  387. case bd >= mpFixExt1 && bd <= mpFixExt16, bd >= mpExt8 && bd <= mpExt32:
  388. n.v = valueTypeExt
  389. clen := d.readExtLen()
  390. n.u = uint64(d.r.readn1())
  391. if n.u == uint64(mpTimeExtTagU) {
  392. n.v = valueTypeTime
  393. n.t = d.decodeTime(clen)
  394. } else {
  395. n.l = d.r.readx(clen)
  396. }
  397. default:
  398. d.d.errorf("Nil-Deciphered DecodeValue: %s: hex: %x, dec: %d", msgBadDesc, bd, bd)
  399. }
  400. }
  401. if !decodeFurther {
  402. d.bdRead = false
  403. }
  404. if n.v == valueTypeUint && d.h.SignedInteger {
  405. n.v = valueTypeInt
  406. n.i = int64(n.u)
  407. }
  408. return
  409. }
  410. // int can be decoded from msgpack type: intXXX or uintXXX
  411. func (d *msgpackDecDriver) DecodeInt64() (i int64) {
  412. if !d.bdRead {
  413. d.readNextBd()
  414. }
  415. switch d.bd {
  416. case mpUint8:
  417. i = int64(uint64(d.r.readn1()))
  418. case mpUint16:
  419. i = int64(uint64(bigen.Uint16(d.r.readx(2))))
  420. case mpUint32:
  421. i = int64(uint64(bigen.Uint32(d.r.readx(4))))
  422. case mpUint64:
  423. i = int64(bigen.Uint64(d.r.readx(8)))
  424. case mpInt8:
  425. i = int64(int8(d.r.readn1()))
  426. case mpInt16:
  427. i = int64(int16(bigen.Uint16(d.r.readx(2))))
  428. case mpInt32:
  429. i = int64(int32(bigen.Uint32(d.r.readx(4))))
  430. case mpInt64:
  431. i = int64(bigen.Uint64(d.r.readx(8)))
  432. default:
  433. switch {
  434. case d.bd >= mpPosFixNumMin && d.bd <= mpPosFixNumMax:
  435. i = int64(int8(d.bd))
  436. case d.bd >= mpNegFixNumMin && d.bd <= mpNegFixNumMax:
  437. i = int64(int8(d.bd))
  438. default:
  439. d.d.errorf("Unhandled single-byte unsigned integer value: %s: %x", msgBadDesc, d.bd)
  440. return
  441. }
  442. }
  443. d.bdRead = false
  444. return
  445. }
  446. // uint can be decoded from msgpack type: intXXX or uintXXX
  447. func (d *msgpackDecDriver) DecodeUint64() (ui uint64) {
  448. if !d.bdRead {
  449. d.readNextBd()
  450. }
  451. switch d.bd {
  452. case mpUint8:
  453. ui = uint64(d.r.readn1())
  454. case mpUint16:
  455. ui = uint64(bigen.Uint16(d.r.readx(2)))
  456. case mpUint32:
  457. ui = uint64(bigen.Uint32(d.r.readx(4)))
  458. case mpUint64:
  459. ui = bigen.Uint64(d.r.readx(8))
  460. case mpInt8:
  461. if i := int64(int8(d.r.readn1())); i >= 0 {
  462. ui = uint64(i)
  463. } else {
  464. d.d.errorf("Assigning negative signed value: %v, to unsigned type", i)
  465. return
  466. }
  467. case mpInt16:
  468. if i := int64(int16(bigen.Uint16(d.r.readx(2)))); i >= 0 {
  469. ui = uint64(i)
  470. } else {
  471. d.d.errorf("Assigning negative signed value: %v, to unsigned type", i)
  472. return
  473. }
  474. case mpInt32:
  475. if i := int64(int32(bigen.Uint32(d.r.readx(4)))); i >= 0 {
  476. ui = uint64(i)
  477. } else {
  478. d.d.errorf("Assigning negative signed value: %v, to unsigned type", i)
  479. return
  480. }
  481. case mpInt64:
  482. if i := int64(bigen.Uint64(d.r.readx(8))); i >= 0 {
  483. ui = uint64(i)
  484. } else {
  485. d.d.errorf("Assigning negative signed value: %v, to unsigned type", i)
  486. return
  487. }
  488. default:
  489. switch {
  490. case d.bd >= mpPosFixNumMin && d.bd <= mpPosFixNumMax:
  491. ui = uint64(d.bd)
  492. case d.bd >= mpNegFixNumMin && d.bd <= mpNegFixNumMax:
  493. d.d.errorf("Assigning negative signed value: %v, to unsigned type", int(d.bd))
  494. return
  495. default:
  496. d.d.errorf("Unhandled single-byte unsigned integer value: %s: %x", msgBadDesc, d.bd)
  497. return
  498. }
  499. }
  500. d.bdRead = false
  501. return
  502. }
  503. // float can either be decoded from msgpack type: float, double or intX
  504. func (d *msgpackDecDriver) DecodeFloat64() (f float64) {
  505. if !d.bdRead {
  506. d.readNextBd()
  507. }
  508. if d.bd == mpFloat {
  509. f = float64(math.Float32frombits(bigen.Uint32(d.r.readx(4))))
  510. } else if d.bd == mpDouble {
  511. f = math.Float64frombits(bigen.Uint64(d.r.readx(8)))
  512. } else {
  513. f = float64(d.DecodeInt64())
  514. }
  515. d.bdRead = false
  516. return
  517. }
  518. // bool can be decoded from bool, fixnum 0 or 1.
  519. func (d *msgpackDecDriver) DecodeBool() (b bool) {
  520. if !d.bdRead {
  521. d.readNextBd()
  522. }
  523. if d.bd == mpFalse || d.bd == 0 {
  524. // b = false
  525. } else if d.bd == mpTrue || d.bd == 1 {
  526. b = true
  527. } else {
  528. d.d.errorf("Invalid single-byte value for bool: %s: %x", msgBadDesc, d.bd)
  529. return
  530. }
  531. d.bdRead = false
  532. return
  533. }
  534. func (d *msgpackDecDriver) DecodeBytes(bs []byte, zerocopy bool) (bsOut []byte) {
  535. if !d.bdRead {
  536. d.readNextBd()
  537. }
  538. // check if an "array" of uint8's (see ContainerType for how to infer if an array)
  539. bd := d.bd
  540. // DecodeBytes could be from: bin str fixstr fixarray array ...
  541. var clen int
  542. vt := d.ContainerType()
  543. switch vt {
  544. case valueTypeBytes:
  545. // valueTypeBytes may be a mpBin or an mpStr container
  546. if bd == mpBin8 || bd == mpBin16 || bd == mpBin32 {
  547. clen = d.readContainerLen(msgpackContainerBin)
  548. } else {
  549. clen = d.readContainerLen(msgpackContainerStr)
  550. }
  551. case valueTypeString:
  552. clen = d.readContainerLen(msgpackContainerStr)
  553. case valueTypeArray:
  554. bsOut, _ = fastpathTV.DecSliceUint8V(bs, true, d.d)
  555. return
  556. // clen = d.readContainerLen(msgpackContainerList)
  557. // // ensure everything after is one byte each
  558. // for i := 0; i < clen; i++ {
  559. // d.readNextBd()
  560. // if d.bd == mpNil {
  561. // bs = append(bs, 0)
  562. // } else if d.bd == mpUint8 {
  563. // bs = append(bs, d.r.readn1())
  564. // } else {
  565. // d.d.errorf("cannot read non-byte into a byte array")
  566. // return
  567. // }
  568. // }
  569. // d.bdRead = false
  570. // return bs
  571. default:
  572. d.d.errorf("invalid container type: expecting bin|str|array, got: 0x%x", uint8(vt))
  573. return
  574. }
  575. // these are (bin|str)(8|16|32)
  576. // println("DecodeBytes: clen: ", clen)
  577. d.bdRead = false
  578. // bytes may be nil, so handle it. if nil, clen=-1.
  579. if clen < 0 {
  580. return nil
  581. }
  582. if zerocopy {
  583. if d.br {
  584. return d.r.readx(clen)
  585. } else if len(bs) == 0 {
  586. bs = d.b[:]
  587. }
  588. }
  589. return decByteSlice(d.r, clen, d.d.h.MaxInitLen, bs)
  590. }
  591. func (d *msgpackDecDriver) DecodeString() (s string) {
  592. return string(d.DecodeBytes(d.b[:], true))
  593. }
  594. func (d *msgpackDecDriver) DecodeStringAsBytes() (s []byte) {
  595. return d.DecodeBytes(d.b[:], true)
  596. }
  597. func (d *msgpackDecDriver) readNextBd() {
  598. d.bd = d.r.readn1()
  599. d.bdRead = true
  600. }
  601. func (d *msgpackDecDriver) uncacheRead() {
  602. if d.bdRead {
  603. d.r.unreadn1()
  604. d.bdRead = false
  605. }
  606. }
  607. func (d *msgpackDecDriver) ContainerType() (vt valueType) {
  608. if !d.bdRead {
  609. d.readNextBd()
  610. }
  611. bd := d.bd
  612. if bd == mpNil {
  613. return valueTypeNil
  614. } else if bd == mpBin8 || bd == mpBin16 || bd == mpBin32 ||
  615. (!d.h.RawToString &&
  616. (bd == mpStr8 || bd == mpStr16 || bd == mpStr32 || (bd >= mpFixStrMin && bd <= mpFixStrMax))) {
  617. return valueTypeBytes
  618. } else if d.h.RawToString &&
  619. (bd == mpStr8 || bd == mpStr16 || bd == mpStr32 || (bd >= mpFixStrMin && bd <= mpFixStrMax)) {
  620. return valueTypeString
  621. } else if bd == mpArray16 || bd == mpArray32 || (bd >= mpFixArrayMin && bd <= mpFixArrayMax) {
  622. return valueTypeArray
  623. } else if bd == mpMap16 || bd == mpMap32 || (bd >= mpFixMapMin && bd <= mpFixMapMax) {
  624. return valueTypeMap
  625. }
  626. // else {
  627. // d.d.errorf("isContainerType: unsupported parameter: %v", vt)
  628. // }
  629. return valueTypeUnset
  630. }
  631. func (d *msgpackDecDriver) TryDecodeAsNil() (v bool) {
  632. if !d.bdRead {
  633. d.readNextBd()
  634. }
  635. if d.bd == mpNil {
  636. d.bdRead = false
  637. return true
  638. }
  639. return
  640. }
  641. func (d *msgpackDecDriver) readContainerLen(ct msgpackContainerType) (clen int) {
  642. bd := d.bd
  643. if bd == mpNil {
  644. clen = -1 // to represent nil
  645. } else if bd == ct.b8 {
  646. clen = int(d.r.readn1())
  647. } else if bd == ct.b16 {
  648. clen = int(bigen.Uint16(d.r.readx(2)))
  649. } else if bd == ct.b32 {
  650. clen = int(bigen.Uint32(d.r.readx(4)))
  651. } else if (ct.bFixMin & bd) == ct.bFixMin {
  652. clen = int(ct.bFixMin ^ bd)
  653. } else {
  654. d.d.errorf("readContainerLen: %s: hex: %x, decimal: %d", msgBadDesc, bd, bd)
  655. return
  656. }
  657. d.bdRead = false
  658. return
  659. }
  660. func (d *msgpackDecDriver) ReadMapStart() int {
  661. if !d.bdRead {
  662. d.readNextBd()
  663. }
  664. return d.readContainerLen(msgpackContainerMap)
  665. }
  666. func (d *msgpackDecDriver) ReadArrayStart() int {
  667. if !d.bdRead {
  668. d.readNextBd()
  669. }
  670. return d.readContainerLen(msgpackContainerList)
  671. }
  672. func (d *msgpackDecDriver) readExtLen() (clen int) {
  673. switch d.bd {
  674. case mpNil:
  675. clen = -1 // to represent nil
  676. case mpFixExt1:
  677. clen = 1
  678. case mpFixExt2:
  679. clen = 2
  680. case mpFixExt4:
  681. clen = 4
  682. case mpFixExt8:
  683. clen = 8
  684. case mpFixExt16:
  685. clen = 16
  686. case mpExt8:
  687. clen = int(d.r.readn1())
  688. case mpExt16:
  689. clen = int(bigen.Uint16(d.r.readx(2)))
  690. case mpExt32:
  691. clen = int(bigen.Uint32(d.r.readx(4)))
  692. default:
  693. d.d.errorf("decoding ext bytes: found unexpected byte: %x", d.bd)
  694. return
  695. }
  696. return
  697. }
  698. func (d *msgpackDecDriver) DecodeTime() (t time.Time) {
  699. // decode time from string bytes or ext
  700. if !d.bdRead {
  701. d.readNextBd()
  702. }
  703. if d.bd == mpNil {
  704. d.bdRead = false
  705. return
  706. }
  707. var clen int
  708. switch d.ContainerType() {
  709. case valueTypeBytes, valueTypeString:
  710. clen = d.readContainerLen(msgpackContainerStr)
  711. default:
  712. // expect to see mpFixExt4,-1 OR mpFixExt8,-1 OR mpExt8,12,-1
  713. d.bdRead = false
  714. b2 := d.r.readn1()
  715. if d.bd == mpFixExt4 && b2 == mpTimeExtTagU {
  716. clen = 4
  717. } else if d.bd == mpFixExt8 && b2 == mpTimeExtTagU {
  718. clen = 8
  719. } else if d.bd == mpExt8 && b2 == 12 && d.r.readn1() == mpTimeExtTagU {
  720. clen = 12
  721. } else {
  722. d.d.errorf("invalid sequence of bytes for decoding time as an extension: got 0x%x, 0x%x", d.bd, b2)
  723. return
  724. }
  725. }
  726. return d.decodeTime(clen)
  727. }
  728. func (d *msgpackDecDriver) decodeTime(clen int) (t time.Time) {
  729. // bs = d.r.readx(clen)
  730. d.bdRead = false
  731. switch clen {
  732. case 4:
  733. t = time.Unix(int64(bigen.Uint32(d.r.readx(4))), 0).UTC()
  734. case 8:
  735. tv := bigen.Uint64(d.r.readx(8))
  736. t = time.Unix(int64(tv&0x00000003ffffffff), int64(tv>>34)).UTC()
  737. case 12:
  738. nsec := bigen.Uint32(d.r.readx(4))
  739. sec := bigen.Uint64(d.r.readx(8))
  740. t = time.Unix(int64(sec), int64(nsec)).UTC()
  741. default:
  742. d.d.errorf("invalid length of bytes for decoding time - expecting 4 or 8 or 12, got %d", clen)
  743. return
  744. }
  745. return
  746. }
  747. func (d *msgpackDecDriver) DecodeExt(rv interface{}, xtag uint64, ext Ext) (realxtag uint64) {
  748. if xtag > 0xff {
  749. d.d.errorf("decodeExt: tag must be <= 0xff; got: %v", xtag)
  750. return
  751. }
  752. realxtag1, xbs := d.decodeExtV(ext != nil, uint8(xtag))
  753. realxtag = uint64(realxtag1)
  754. if ext == nil {
  755. re := rv.(*RawExt)
  756. re.Tag = realxtag
  757. re.Data = detachZeroCopyBytes(d.br, re.Data, xbs)
  758. } else {
  759. ext.ReadExt(rv, xbs)
  760. }
  761. return
  762. }
  763. func (d *msgpackDecDriver) decodeExtV(verifyTag bool, tag byte) (xtag byte, xbs []byte) {
  764. if !d.bdRead {
  765. d.readNextBd()
  766. }
  767. xbd := d.bd
  768. if xbd == mpBin8 || xbd == mpBin16 || xbd == mpBin32 {
  769. xbs = d.DecodeBytes(nil, true)
  770. } else if xbd == mpStr8 || xbd == mpStr16 || xbd == mpStr32 ||
  771. (xbd >= mpFixStrMin && xbd <= mpFixStrMax) {
  772. xbs = d.DecodeStringAsBytes()
  773. } else {
  774. clen := d.readExtLen()
  775. xtag = d.r.readn1()
  776. if verifyTag && xtag != tag {
  777. d.d.errorf("Wrong extension tag. Got %b. Expecting: %v", xtag, tag)
  778. return
  779. }
  780. xbs = d.r.readx(clen)
  781. }
  782. d.bdRead = false
  783. return
  784. }
  785. //--------------------------------------------------
  786. //MsgpackHandle is a Handle for the Msgpack Schema-Free Encoding Format.
  787. type MsgpackHandle struct {
  788. BasicHandle
  789. // RawToString controls how raw bytes are decoded into a nil interface{}.
  790. RawToString bool
  791. // NoFixedNum says to output all signed integers as 2-bytes, never as 1-byte fixednum.
  792. NoFixedNum bool
  793. // WriteExt flag supports encoding configured extensions with extension tags.
  794. // It also controls whether other elements of the new spec are encoded (ie Str8).
  795. //
  796. // With WriteExt=false, configured extensions are serialized as raw bytes
  797. // and Str8 is not encoded.
  798. //
  799. // A stream can still be decoded into a typed value, provided an appropriate value
  800. // is provided, but the type cannot be inferred from the stream. If no appropriate
  801. // type is provided (e.g. decoding into a nil interface{}), you get back
  802. // a []byte or string based on the setting of RawToString.
  803. WriteExt bool
  804. binaryEncodingType
  805. noElemSeparators
  806. }
  807. // Name returns the name of the handle: msgpack
  808. func (h *MsgpackHandle) Name() string { return "msgpack" }
  809. // SetBytesExt sets an extension
  810. func (h *MsgpackHandle) SetBytesExt(rt reflect.Type, tag uint64, ext BytesExt) (err error) {
  811. return h.SetExt(rt, tag, &setExtWrapper{b: ext})
  812. }
  813. func (h *MsgpackHandle) newEncDriver(e *Encoder) encDriver {
  814. return &msgpackEncDriver{e: e, w: e.w, h: h}
  815. }
  816. func (h *MsgpackHandle) newDecDriver(d *Decoder) decDriver {
  817. return &msgpackDecDriver{d: d, h: h, r: d.r, br: d.bytes}
  818. }
  819. func (e *msgpackEncDriver) reset() {
  820. e.w = e.e.w
  821. }
  822. func (d *msgpackDecDriver) reset() {
  823. d.r, d.br = d.d.r, d.d.bytes
  824. d.bd, d.bdRead = 0, false
  825. }
  826. //--------------------------------------------------
  827. type msgpackSpecRpcCodec struct {
  828. rpcCodec
  829. }
  830. // /////////////// Spec RPC Codec ///////////////////
  831. func (c *msgpackSpecRpcCodec) WriteRequest(r *rpc.Request, body interface{}) error {
  832. // WriteRequest can write to both a Go service, and other services that do
  833. // not abide by the 1 argument rule of a Go service.
  834. // We discriminate based on if the body is a MsgpackSpecRpcMultiArgs
  835. var bodyArr []interface{}
  836. if m, ok := body.(MsgpackSpecRpcMultiArgs); ok {
  837. bodyArr = ([]interface{})(m)
  838. } else {
  839. bodyArr = []interface{}{body}
  840. }
  841. r2 := []interface{}{0, uint32(r.Seq), r.ServiceMethod, bodyArr}
  842. return c.write(r2, nil, false)
  843. }
  844. func (c *msgpackSpecRpcCodec) WriteResponse(r *rpc.Response, body interface{}) error {
  845. var moe interface{}
  846. if r.Error != "" {
  847. moe = r.Error
  848. }
  849. if moe != nil && body != nil {
  850. body = nil
  851. }
  852. r2 := []interface{}{1, uint32(r.Seq), moe, body}
  853. return c.write(r2, nil, false)
  854. }
  855. func (c *msgpackSpecRpcCodec) ReadResponseHeader(r *rpc.Response) error {
  856. return c.parseCustomHeader(1, &r.Seq, &r.Error)
  857. }
  858. func (c *msgpackSpecRpcCodec) ReadRequestHeader(r *rpc.Request) error {
  859. return c.parseCustomHeader(0, &r.Seq, &r.ServiceMethod)
  860. }
  861. func (c *msgpackSpecRpcCodec) ReadRequestBody(body interface{}) error {
  862. if body == nil { // read and discard
  863. return c.read(nil)
  864. }
  865. bodyArr := []interface{}{body}
  866. return c.read(&bodyArr)
  867. }
  868. func (c *msgpackSpecRpcCodec) parseCustomHeader(expectTypeByte byte, msgid *uint64, methodOrError *string) (err error) {
  869. if c.isClosed() {
  870. return io.EOF
  871. }
  872. // We read the response header by hand
  873. // so that the body can be decoded on its own from the stream at a later time.
  874. const fia byte = 0x94 //four item array descriptor value
  875. // Not sure why the panic of EOF is swallowed above.
  876. // if bs1 := c.dec.r.readn1(); bs1 != fia {
  877. // err = fmt.Errorf("Unexpected value for array descriptor: Expecting %v. Received %v", fia, bs1)
  878. // return
  879. // }
  880. var ba [1]byte
  881. var n int
  882. for {
  883. n, err = c.r.Read(ba[:])
  884. if err != nil {
  885. return
  886. }
  887. if n == 1 {
  888. break
  889. }
  890. }
  891. var b = ba[0]
  892. if b != fia {
  893. err = fmt.Errorf("Unexpected value for array descriptor: Expecting %v. Received %v", fia, b)
  894. } else {
  895. err = c.read(&b)
  896. if err == nil {
  897. if b != expectTypeByte {
  898. err = fmt.Errorf("Unexpected byte descriptor in header. Expecting %v. Received %v", expectTypeByte, b)
  899. } else {
  900. err = c.read(msgid)
  901. if err == nil {
  902. err = c.read(methodOrError)
  903. }
  904. }
  905. }
  906. }
  907. return
  908. }
  909. //--------------------------------------------------
  910. // msgpackSpecRpc is the implementation of Rpc that uses custom communication protocol
  911. // as defined in the msgpack spec at https://github.com/msgpack-rpc/msgpack-rpc/blob/master/spec.md
  912. type msgpackSpecRpc struct{}
  913. // MsgpackSpecRpc implements Rpc using the communication protocol defined in
  914. // the msgpack spec at https://github.com/msgpack-rpc/msgpack-rpc/blob/master/spec.md .
  915. //
  916. // See GoRpc documentation, for information on buffering for better performance.
  917. var MsgpackSpecRpc msgpackSpecRpc
  918. func (x msgpackSpecRpc) ServerCodec(conn io.ReadWriteCloser, h Handle) rpc.ServerCodec {
  919. return &msgpackSpecRpcCodec{newRPCCodec(conn, h)}
  920. }
  921. func (x msgpackSpecRpc) ClientCodec(conn io.ReadWriteCloser, h Handle) rpc.ClientCodec {
  922. return &msgpackSpecRpcCodec{newRPCCodec(conn, h)}
  923. }
  924. var _ decDriver = (*msgpackDecDriver)(nil)
  925. var _ encDriver = (*msgpackEncDriver)(nil)