msgpack.go 23 KB

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