msgpack.go 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826
  1. // Copyright (c) 2012-2015 Ugorji Nwoke. All rights reserved.
  2. // Use of this source code is governed by a BSD-style 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. w encWriter
  91. h *MsgpackHandle
  92. noBuiltInTypes
  93. encNoMapArrayEnd
  94. encNoMapArraySeparator
  95. }
  96. func (e *msgpackEncDriver) encodeNil() {
  97. e.w.writen1(mpNil)
  98. }
  99. func (e *msgpackEncDriver) encodeInt(i int64) {
  100. switch {
  101. case i >= 0:
  102. e.encodeUint(uint64(i))
  103. case i >= -32:
  104. e.w.writen1(byte(i))
  105. case i >= math.MinInt8:
  106. e.w.writen2(mpInt8, byte(i))
  107. case i >= math.MinInt16:
  108. e.w.writen1(mpInt16)
  109. e.w.writeUint16(uint16(i))
  110. case i >= math.MinInt32:
  111. e.w.writen1(mpInt32)
  112. e.w.writeUint32(uint32(i))
  113. default:
  114. e.w.writen1(mpInt64)
  115. e.w.writeUint64(uint64(i))
  116. }
  117. }
  118. func (e *msgpackEncDriver) encodeUint(i uint64) {
  119. switch {
  120. case i <= math.MaxInt8:
  121. e.w.writen1(byte(i))
  122. case i <= math.MaxUint8:
  123. e.w.writen2(mpUint8, byte(i))
  124. case i <= math.MaxUint16:
  125. e.w.writen1(mpUint16)
  126. e.w.writeUint16(uint16(i))
  127. case i <= math.MaxUint32:
  128. e.w.writen1(mpUint32)
  129. e.w.writeUint32(uint32(i))
  130. default:
  131. e.w.writen1(mpUint64)
  132. e.w.writeUint64(uint64(i))
  133. }
  134. }
  135. func (e *msgpackEncDriver) encodeBool(b bool) {
  136. if b {
  137. e.w.writen1(mpTrue)
  138. } else {
  139. e.w.writen1(mpFalse)
  140. }
  141. }
  142. func (e *msgpackEncDriver) encodeFloat32(f float32) {
  143. e.w.writen1(mpFloat)
  144. e.w.writeUint32(math.Float32bits(f))
  145. }
  146. func (e *msgpackEncDriver) encodeFloat64(f float64) {
  147. e.w.writen1(mpDouble)
  148. e.w.writeUint64(math.Float64bits(f))
  149. }
  150. func (e *msgpackEncDriver) encodeExt(rv reflect.Value, xtag uint64, ext Ext, _ *Encoder) {
  151. bs := ext.WriteExt(rv)
  152. if bs == nil {
  153. e.encodeNil()
  154. return
  155. }
  156. if e.h.WriteExt {
  157. e.encodeExtPreamble(uint8(xtag), len(bs))
  158. e.w.writeb(bs)
  159. } else {
  160. e.encodeStringBytes(c_RAW, bs)
  161. }
  162. }
  163. func (e *msgpackEncDriver) encodeRawExt(re *RawExt, _ *Encoder) {
  164. e.encodeExtPreamble(uint8(re.Tag), len(re.Data))
  165. e.w.writeb(re.Data)
  166. }
  167. func (e *msgpackEncDriver) encodeExtPreamble(xtag byte, l int) {
  168. switch {
  169. case l == 1:
  170. e.w.writen2(mpFixExt1, xtag)
  171. case l == 2:
  172. e.w.writen2(mpFixExt2, xtag)
  173. case l == 4:
  174. e.w.writen2(mpFixExt4, xtag)
  175. case l == 8:
  176. e.w.writen2(mpFixExt8, xtag)
  177. case l == 16:
  178. e.w.writen2(mpFixExt16, xtag)
  179. case l < 256:
  180. e.w.writen2(mpExt8, byte(l))
  181. e.w.writen1(xtag)
  182. case l < 65536:
  183. e.w.writen1(mpExt16)
  184. e.w.writeUint16(uint16(l))
  185. e.w.writen1(xtag)
  186. default:
  187. e.w.writen1(mpExt32)
  188. e.w.writeUint32(uint32(l))
  189. e.w.writen1(xtag)
  190. }
  191. }
  192. func (e *msgpackEncDriver) encodeArrayStart(length int) {
  193. e.writeContainerLen(msgpackContainerList, length)
  194. }
  195. func (e *msgpackEncDriver) encodeMapStart(length int) {
  196. e.writeContainerLen(msgpackContainerMap, length)
  197. }
  198. func (e *msgpackEncDriver) encodeString(c charEncoding, s string) {
  199. if c == c_RAW && e.h.WriteExt {
  200. e.writeContainerLen(msgpackContainerBin, len(s))
  201. } else {
  202. e.writeContainerLen(msgpackContainerStr, len(s))
  203. }
  204. if len(s) > 0 {
  205. e.w.writestr(s)
  206. }
  207. }
  208. func (e *msgpackEncDriver) encodeSymbol(v string) {
  209. e.encodeString(c_UTF8, v)
  210. }
  211. func (e *msgpackEncDriver) encodeStringBytes(c charEncoding, bs []byte) {
  212. if c == c_RAW && e.h.WriteExt {
  213. e.writeContainerLen(msgpackContainerBin, len(bs))
  214. } else {
  215. e.writeContainerLen(msgpackContainerStr, len(bs))
  216. }
  217. if len(bs) > 0 {
  218. e.w.writeb(bs)
  219. }
  220. }
  221. func (e *msgpackEncDriver) writeContainerLen(ct msgpackContainerType, l int) {
  222. switch {
  223. case ct.hasFixMin && l < ct.fixCutoff:
  224. e.w.writen1(ct.bFixMin | byte(l))
  225. case ct.has8 && l < 256 && (ct.has8Always || e.h.WriteExt):
  226. e.w.writen2(ct.b8, uint8(l))
  227. case l < 65536:
  228. e.w.writen1(ct.b16)
  229. e.w.writeUint16(uint16(l))
  230. default:
  231. e.w.writen1(ct.b32)
  232. e.w.writeUint32(uint32(l))
  233. }
  234. }
  235. //---------------------------------------------
  236. type msgpackDecDriver struct {
  237. r decReader
  238. h *MsgpackHandle
  239. bd byte
  240. bdRead bool
  241. bdType valueType
  242. noBuiltInTypes
  243. noStreamingCodec
  244. decNoMapArrayEnd
  245. decNoMapArraySeparator
  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(_ *Decoder) (v interface{}, vt valueType, decodeFurther bool) {
  253. d.initReadNext()
  254. bd := d.bd
  255. switch bd {
  256. case mpNil:
  257. vt = valueTypeNil
  258. d.bdRead = false
  259. case mpFalse:
  260. vt = valueTypeBool
  261. v = false
  262. case mpTrue:
  263. vt = valueTypeBool
  264. v = true
  265. case mpFloat:
  266. vt = valueTypeFloat
  267. v = float64(math.Float32frombits(d.r.readUint32()))
  268. case mpDouble:
  269. vt = valueTypeFloat
  270. v = math.Float64frombits(d.r.readUint64())
  271. case mpUint8:
  272. vt = valueTypeUint
  273. v = uint64(d.r.readn1())
  274. case mpUint16:
  275. vt = valueTypeUint
  276. v = uint64(d.r.readUint16())
  277. case mpUint32:
  278. vt = valueTypeUint
  279. v = uint64(d.r.readUint32())
  280. case mpUint64:
  281. vt = valueTypeUint
  282. v = uint64(d.r.readUint64())
  283. case mpInt8:
  284. vt = valueTypeInt
  285. v = int64(int8(d.r.readn1()))
  286. case mpInt16:
  287. vt = valueTypeInt
  288. v = int64(int16(d.r.readUint16()))
  289. case mpInt32:
  290. vt = valueTypeInt
  291. v = int64(int32(d.r.readUint32()))
  292. case mpInt64:
  293. vt = valueTypeInt
  294. v = int64(int64(d.r.readUint64()))
  295. default:
  296. switch {
  297. case bd >= mpPosFixNumMin && bd <= mpPosFixNumMax:
  298. // positive fixnum (always signed)
  299. vt = valueTypeInt
  300. v = int64(int8(bd))
  301. case bd >= mpNegFixNumMin && bd <= mpNegFixNumMax:
  302. // negative fixnum
  303. vt = valueTypeInt
  304. v = int64(int8(bd))
  305. case bd == mpStr8, bd == mpStr16, bd == mpStr32, bd >= mpFixStrMin && bd <= mpFixStrMax:
  306. if d.h.RawToString {
  307. var rvm string
  308. vt = valueTypeString
  309. v = &rvm
  310. } else {
  311. var rvm = []byte{}
  312. vt = valueTypeBytes
  313. v = &rvm
  314. }
  315. decodeFurther = true
  316. case bd == mpBin8, bd == mpBin16, bd == mpBin32:
  317. var rvm = []byte{}
  318. vt = valueTypeBytes
  319. v = &rvm
  320. decodeFurther = true
  321. case bd == mpArray16, bd == mpArray32, bd >= mpFixArrayMin && bd <= mpFixArrayMax:
  322. vt = valueTypeArray
  323. decodeFurther = true
  324. case bd == mpMap16, bd == mpMap32, bd >= mpFixMapMin && bd <= mpFixMapMax:
  325. vt = valueTypeMap
  326. decodeFurther = true
  327. case bd >= mpFixExt1 && bd <= mpFixExt16, bd >= mpExt8 && bd <= mpExt32:
  328. clen := d.readExtLen()
  329. var re RawExt
  330. re.Tag = uint64(d.r.readn1())
  331. re.Data = d.r.readn(clen)
  332. v = &re
  333. vt = valueTypeExt
  334. default:
  335. decErr("Nil-Deciphered DecodeValue: %s: hex: %x, dec: %d", msgBadDesc, bd, bd)
  336. }
  337. }
  338. if !decodeFurther {
  339. d.bdRead = false
  340. }
  341. if vt == valueTypeUint && d.h.SignedInteger {
  342. d.bdType = valueTypeInt
  343. v = int64(v.(uint64))
  344. }
  345. return
  346. }
  347. // int can be decoded from msgpack type: intXXX or uintXXX
  348. func (d *msgpackDecDriver) decodeInt(bitsize uint8) (i int64) {
  349. switch d.bd {
  350. case mpUint8:
  351. i = int64(uint64(d.r.readn1()))
  352. case mpUint16:
  353. i = int64(uint64(d.r.readUint16()))
  354. case mpUint32:
  355. i = int64(uint64(d.r.readUint32()))
  356. case mpUint64:
  357. i = int64(d.r.readUint64())
  358. case mpInt8:
  359. i = int64(int8(d.r.readn1()))
  360. case mpInt16:
  361. i = int64(int16(d.r.readUint16()))
  362. case mpInt32:
  363. i = int64(int32(d.r.readUint32()))
  364. case mpInt64:
  365. i = int64(d.r.readUint64())
  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. decErr("Unhandled single-byte unsigned integer value: %s: %x", msgBadDesc, d.bd)
  374. }
  375. }
  376. // check overflow (logic adapted from std pkg reflect/value.go OverflowUint()
  377. if bitsize > 0 {
  378. if trunc := (i << (64 - bitsize)) >> (64 - bitsize); i != trunc {
  379. decErr("Overflow int value: %v", i)
  380. }
  381. }
  382. d.bdRead = false
  383. return
  384. }
  385. // uint can be decoded from msgpack type: intXXX or uintXXX
  386. func (d *msgpackDecDriver) decodeUint(bitsize uint8) (ui uint64) {
  387. switch d.bd {
  388. case mpUint8:
  389. ui = uint64(d.r.readn1())
  390. case mpUint16:
  391. ui = uint64(d.r.readUint16())
  392. case mpUint32:
  393. ui = uint64(d.r.readUint32())
  394. case mpUint64:
  395. ui = d.r.readUint64()
  396. case mpInt8:
  397. if i := int64(int8(d.r.readn1())); i >= 0 {
  398. ui = uint64(i)
  399. } else {
  400. decErr("Assigning negative signed value: %v, to unsigned type", i)
  401. }
  402. case mpInt16:
  403. if i := int64(int16(d.r.readUint16())); i >= 0 {
  404. ui = uint64(i)
  405. } else {
  406. decErr("Assigning negative signed value: %v, to unsigned type", i)
  407. }
  408. case mpInt32:
  409. if i := int64(int32(d.r.readUint32())); i >= 0 {
  410. ui = uint64(i)
  411. } else {
  412. decErr("Assigning negative signed value: %v, to unsigned type", i)
  413. }
  414. case mpInt64:
  415. if i := int64(d.r.readUint64()); i >= 0 {
  416. ui = uint64(i)
  417. } else {
  418. decErr("Assigning negative signed value: %v, to unsigned type", i)
  419. }
  420. default:
  421. switch {
  422. case d.bd >= mpPosFixNumMin && d.bd <= mpPosFixNumMax:
  423. ui = uint64(d.bd)
  424. case d.bd >= mpNegFixNumMin && d.bd <= mpNegFixNumMax:
  425. decErr("Assigning negative signed value: %v, to unsigned type", int(d.bd))
  426. default:
  427. decErr("Unhandled single-byte unsigned integer value: %s: %x", msgBadDesc, d.bd)
  428. }
  429. }
  430. // check overflow (logic adapted from std pkg reflect/value.go OverflowUint()
  431. if bitsize > 0 {
  432. if trunc := (ui << (64 - bitsize)) >> (64 - bitsize); ui != trunc {
  433. decErr("Overflow uint value: %v", ui)
  434. }
  435. }
  436. d.bdRead = false
  437. return
  438. }
  439. // float can either be decoded from msgpack type: float, double or intX
  440. func (d *msgpackDecDriver) decodeFloat(chkOverflow32 bool) (f float64) {
  441. switch d.bd {
  442. case mpFloat:
  443. f = float64(math.Float32frombits(d.r.readUint32()))
  444. case mpDouble:
  445. f = math.Float64frombits(d.r.readUint64())
  446. default:
  447. f = float64(d.decodeInt(0))
  448. }
  449. checkOverflowFloat32(f, chkOverflow32)
  450. d.bdRead = false
  451. return
  452. }
  453. // bool can be decoded from bool, fixnum 0 or 1.
  454. func (d *msgpackDecDriver) decodeBool() (b bool) {
  455. switch d.bd {
  456. case mpFalse, 0:
  457. // b = false
  458. case mpTrue, 1:
  459. b = true
  460. default:
  461. decErr("Invalid single-byte value for bool: %s: %x", msgBadDesc, d.bd)
  462. }
  463. d.bdRead = false
  464. return
  465. }
  466. func (d *msgpackDecDriver) decodeString() (s string) {
  467. clen := d.readContainerLen(msgpackContainerStr)
  468. if clen > 0 {
  469. s = string(d.r.readn(clen))
  470. }
  471. d.bdRead = false
  472. return
  473. }
  474. // Callers must check if changed=true (to decide whether to replace the one they have)
  475. func (d *msgpackDecDriver) decodeBytes(bs []byte) (bsOut []byte, changed bool) {
  476. // bytes can be decoded from msgpackContainerStr or msgpackContainerBin
  477. var clen int
  478. switch d.bd {
  479. case mpBin8, mpBin16, mpBin32:
  480. clen = d.readContainerLen(msgpackContainerBin)
  481. default:
  482. clen = d.readContainerLen(msgpackContainerStr)
  483. }
  484. // if clen < 0 {
  485. // changed = true
  486. // panic("length cannot be zero. this cannot be nil.")
  487. // }
  488. if clen >= 0 {
  489. if bs == nil {
  490. bs = []byte{}
  491. bsOut = bs
  492. changed = true
  493. }
  494. if len(bs) != clen {
  495. if len(bs) > clen {
  496. bs = bs[:clen]
  497. } else {
  498. bs = make([]byte, clen)
  499. }
  500. bsOut = bs
  501. changed = true
  502. }
  503. if len(bs) > 0 {
  504. d.r.readb(bs)
  505. }
  506. }
  507. d.bdRead = false
  508. return
  509. }
  510. // Every top-level decode funcs (i.e. decodeValue, decode) must call this first.
  511. func (d *msgpackDecDriver) initReadNext() {
  512. if d.bdRead {
  513. return
  514. }
  515. d.bd = d.r.readn1()
  516. d.bdRead = true
  517. d.bdType = valueTypeUnset
  518. }
  519. func (d *msgpackDecDriver) isContainerType(vt valueType) bool {
  520. bd := d.bd
  521. switch vt {
  522. case valueTypeNil:
  523. return bd == mpNil
  524. case valueTypeBytes:
  525. return bd == mpBin8 || bd == mpBin16 || bd == mpBin32 ||
  526. (!d.h.RawToString &&
  527. (bd == mpStr8 || bd == mpStr16 || bd == mpStr32 || (bd >= mpFixStrMin && bd <= mpFixStrMax)))
  528. case valueTypeString:
  529. return d.h.RawToString &&
  530. (bd == mpStr8 || bd == mpStr16 || bd == mpStr32 || (bd >= mpFixStrMin && bd <= mpFixStrMax))
  531. case valueTypeArray:
  532. return bd == mpArray16 || bd == mpArray32 || (bd >= mpFixArrayMin && bd <= mpFixArrayMax)
  533. case valueTypeMap:
  534. return bd == mpMap16 || bd == mpMap32 || (bd >= mpFixMapMin && bd <= mpFixMapMax)
  535. }
  536. decErr("isContainerType: unsupported parameter: %v", vt)
  537. panic("unreachable")
  538. }
  539. func (d *msgpackDecDriver) tryDecodeAsNil() bool {
  540. if d.bd == mpNil {
  541. d.bdRead = false
  542. return true
  543. }
  544. return false
  545. }
  546. func (d *msgpackDecDriver) readContainerLen(ct msgpackContainerType) (clen int) {
  547. bd := d.bd
  548. switch {
  549. case bd == mpNil:
  550. clen = -1 // to represent nil
  551. case bd == ct.b8:
  552. clen = int(d.r.readn1())
  553. case bd == ct.b16:
  554. clen = int(d.r.readUint16())
  555. case bd == ct.b32:
  556. clen = int(d.r.readUint32())
  557. case (ct.bFixMin & bd) == ct.bFixMin:
  558. clen = int(ct.bFixMin ^ bd)
  559. default:
  560. decErr("readContainerLen: %s: hex: %x, dec: %d", msgBadDesc, bd, bd)
  561. }
  562. d.bdRead = false
  563. return
  564. }
  565. func (d *msgpackDecDriver) readMapStart() int {
  566. return d.readContainerLen(msgpackContainerMap)
  567. }
  568. func (d *msgpackDecDriver) readArrayStart() int {
  569. return d.readContainerLen(msgpackContainerList)
  570. }
  571. func (d *msgpackDecDriver) readExtLen() (clen int) {
  572. switch d.bd {
  573. case mpNil:
  574. clen = -1 // to represent nil
  575. case mpFixExt1:
  576. clen = 1
  577. case mpFixExt2:
  578. clen = 2
  579. case mpFixExt4:
  580. clen = 4
  581. case mpFixExt8:
  582. clen = 8
  583. case mpFixExt16:
  584. clen = 16
  585. case mpExt8:
  586. clen = int(d.r.readn1())
  587. case mpExt16:
  588. clen = int(d.r.readUint16())
  589. case mpExt32:
  590. clen = int(d.r.readUint32())
  591. default:
  592. decErr("decoding ext bytes: found unexpected byte: %x", d.bd)
  593. }
  594. return
  595. }
  596. func (d *msgpackDecDriver) decodeExt(rv reflect.Value, xtag uint64, ext Ext, _ *Decoder) (realxtag uint64) {
  597. if xtag > 0xff {
  598. decErr("decodeExt: tag must be <= 0xff; got: %v", xtag)
  599. }
  600. realxtag1, xbs := d.decodeExtV(ext != nil, uint8(xtag))
  601. realxtag = uint64(realxtag1)
  602. if ext == nil {
  603. re := rv.Interface().(*RawExt)
  604. re.Tag = realxtag
  605. re.Data = xbs
  606. } else {
  607. ext.ReadExt(rv, xbs)
  608. }
  609. return
  610. }
  611. func (d *msgpackDecDriver) decodeExtV(verifyTag bool, tag byte) (xtag byte, xbs []byte) {
  612. xbd := d.bd
  613. switch {
  614. case xbd == mpBin8, xbd == mpBin16, xbd == mpBin32:
  615. xbs, _ = d.decodeBytes(nil)
  616. case xbd == mpStr8, xbd == mpStr16, xbd == mpStr32,
  617. xbd >= mpFixStrMin && xbd <= mpFixStrMax:
  618. xbs = []byte(d.decodeString())
  619. default:
  620. clen := d.readExtLen()
  621. xtag = d.r.readn1()
  622. if verifyTag && xtag != tag {
  623. decErr("Wrong extension tag. Got %b. Expecting: %v", xtag, tag)
  624. }
  625. xbs = d.r.readn(clen)
  626. }
  627. d.bdRead = false
  628. return
  629. }
  630. //--------------------------------------------------
  631. //MsgpackHandle is a Handle for the Msgpack Schema-Free Encoding Format.
  632. type MsgpackHandle struct {
  633. BasicHandle
  634. // RawToString controls how raw bytes are decoded into a nil interface{}.
  635. RawToString bool
  636. // WriteExt flag supports encoding configured extensions with extension tags.
  637. // It also controls whether other elements of the new spec are encoded (ie Str8).
  638. //
  639. // With WriteExt=false, configured extensions are serialized as raw bytes
  640. // and Str8 is not encoded.
  641. //
  642. // A stream can still be decoded into a typed value, provided an appropriate value
  643. // is provided, but the type cannot be inferred from the stream. If no appropriate
  644. // type is provided (e.g. decoding into a nil interface{}), you get back
  645. // a []byte or string based on the setting of RawToString.
  646. WriteExt bool
  647. }
  648. func (h *MsgpackHandle) newEncDriver(w encWriter) encDriver {
  649. return &msgpackEncDriver{w: w, h: h}
  650. }
  651. func (h *MsgpackHandle) newDecDriver(r decReader) decDriver {
  652. return &msgpackDecDriver{r: r, h: h}
  653. }
  654. //--------------------------------------------------
  655. type msgpackSpecRpcCodec struct {
  656. rpcCodec
  657. }
  658. // /////////////// Spec RPC Codec ///////////////////
  659. func (c *msgpackSpecRpcCodec) WriteRequest(r *rpc.Request, body interface{}) error {
  660. // WriteRequest can write to both a Go service, and other services that do
  661. // not abide by the 1 argument rule of a Go service.
  662. // We discriminate based on if the body is a MsgpackSpecRpcMultiArgs
  663. var bodyArr []interface{}
  664. if m, ok := body.(MsgpackSpecRpcMultiArgs); ok {
  665. bodyArr = ([]interface{})(m)
  666. } else {
  667. bodyArr = []interface{}{body}
  668. }
  669. r2 := []interface{}{0, uint32(r.Seq), r.ServiceMethod, bodyArr}
  670. return c.write(r2, nil, false, true)
  671. }
  672. func (c *msgpackSpecRpcCodec) WriteResponse(r *rpc.Response, body interface{}) error {
  673. var moe interface{}
  674. if r.Error != "" {
  675. moe = r.Error
  676. }
  677. if moe != nil && body != nil {
  678. body = nil
  679. }
  680. r2 := []interface{}{1, uint32(r.Seq), moe, body}
  681. return c.write(r2, nil, false, true)
  682. }
  683. func (c *msgpackSpecRpcCodec) ReadResponseHeader(r *rpc.Response) error {
  684. return c.parseCustomHeader(1, &r.Seq, &r.Error)
  685. }
  686. func (c *msgpackSpecRpcCodec) ReadRequestHeader(r *rpc.Request) error {
  687. return c.parseCustomHeader(0, &r.Seq, &r.ServiceMethod)
  688. }
  689. func (c *msgpackSpecRpcCodec) ReadRequestBody(body interface{}) error {
  690. if body == nil { // read and discard
  691. return c.read(nil)
  692. }
  693. bodyArr := []interface{}{body}
  694. return c.read(&bodyArr)
  695. }
  696. func (c *msgpackSpecRpcCodec) parseCustomHeader(expectTypeByte byte, msgid *uint64, methodOrError *string) (err error) {
  697. if c.cls {
  698. return io.EOF
  699. }
  700. // We read the response header by hand
  701. // so that the body can be decoded on its own from the stream at a later time.
  702. const fia byte = 0x94 //four item array descriptor value
  703. // Not sure why the panic of EOF is swallowed above.
  704. // if bs1 := c.dec.r.readn1(); bs1 != fia {
  705. // err = fmt.Errorf("Unexpected value for array descriptor: Expecting %v. Received %v", fia, bs1)
  706. // return
  707. // }
  708. var b byte
  709. b, err = c.br.ReadByte()
  710. if err != nil {
  711. return
  712. }
  713. if b != fia {
  714. err = fmt.Errorf("Unexpected value for array descriptor: Expecting %v. Received %v", fia, b)
  715. return
  716. }
  717. if err = c.read(&b); err != nil {
  718. return
  719. }
  720. if b != expectTypeByte {
  721. err = fmt.Errorf("Unexpected byte descriptor in header. Expecting %v. Received %v", expectTypeByte, b)
  722. return
  723. }
  724. if err = c.read(msgid); err != nil {
  725. return
  726. }
  727. if err = c.read(methodOrError); err != nil {
  728. return
  729. }
  730. return
  731. }
  732. //--------------------------------------------------
  733. // msgpackSpecRpc is the implementation of Rpc that uses custom communication protocol
  734. // as defined in the msgpack spec at https://github.com/msgpack-rpc/msgpack-rpc/blob/master/spec.md
  735. type msgpackSpecRpc struct{}
  736. // MsgpackSpecRpc implements Rpc using the communication protocol defined in
  737. // the msgpack spec at https://github.com/msgpack-rpc/msgpack-rpc/blob/master/spec.md .
  738. // Its methods (ServerCodec and ClientCodec) return values that implement RpcCodecBuffered.
  739. var MsgpackSpecRpc msgpackSpecRpc
  740. func (x msgpackSpecRpc) ServerCodec(conn io.ReadWriteCloser, h Handle) rpc.ServerCodec {
  741. return &msgpackSpecRpcCodec{newRPCCodec(conn, h)}
  742. }
  743. func (x msgpackSpecRpc) ClientCodec(conn io.ReadWriteCloser, h Handle) rpc.ClientCodec {
  744. return &msgpackSpecRpcCodec{newRPCCodec(conn, h)}
  745. }
  746. var _ decDriver = (*msgpackDecDriver)(nil)
  747. var _ encDriver = (*msgpackEncDriver)(nil)