msgpack.go 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017
  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. "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. t = t.UTC()
  175. sec, nsec := t.Unix(), uint64(t.Nanosecond())
  176. var data64 uint64
  177. var l = 4
  178. if sec >= 0 && sec>>34 == 0 {
  179. data64 = (nsec << 34) | uint64(sec)
  180. if data64&0xffffffff00000000 != 0 {
  181. l = 8
  182. }
  183. } else {
  184. l = 12
  185. }
  186. if e.h.WriteExt {
  187. e.encodeExtPreamble(mpTimeExtTagU, l)
  188. } else {
  189. e.writeContainerLen(msgpackContainerStr, l)
  190. }
  191. switch l {
  192. case 4:
  193. bigenHelper{e.x[:4], e.w}.writeUint32(uint32(data64))
  194. case 8:
  195. bigenHelper{e.x[:8], e.w}.writeUint64(data64)
  196. case 12:
  197. bigenHelper{e.x[:4], e.w}.writeUint32(uint32(nsec))
  198. bigenHelper{e.x[:8], e.w}.writeUint64(uint64(sec))
  199. }
  200. }
  201. func (e *msgpackEncDriver) EncodeExt(v interface{}, xtag uint64, ext Ext, _ *Encoder) {
  202. bs := ext.WriteExt(v)
  203. if bs == nil {
  204. e.EncodeNil()
  205. return
  206. }
  207. if e.h.WriteExt {
  208. e.encodeExtPreamble(uint8(xtag), len(bs))
  209. e.w.writeb(bs)
  210. } else {
  211. e.EncodeStringBytes(cRAW, bs)
  212. }
  213. }
  214. func (e *msgpackEncDriver) EncodeRawExt(re *RawExt, _ *Encoder) {
  215. e.encodeExtPreamble(uint8(re.Tag), len(re.Data))
  216. e.w.writeb(re.Data)
  217. }
  218. func (e *msgpackEncDriver) encodeExtPreamble(xtag byte, l int) {
  219. if l == 1 {
  220. e.w.writen2(mpFixExt1, xtag)
  221. } else if l == 2 {
  222. e.w.writen2(mpFixExt2, xtag)
  223. } else if l == 4 {
  224. e.w.writen2(mpFixExt4, xtag)
  225. } else if l == 8 {
  226. e.w.writen2(mpFixExt8, xtag)
  227. } else if l == 16 {
  228. e.w.writen2(mpFixExt16, xtag)
  229. } else if l < 256 {
  230. e.w.writen2(mpExt8, byte(l))
  231. e.w.writen1(xtag)
  232. } else if l < 65536 {
  233. e.w.writen1(mpExt16)
  234. bigenHelper{e.x[:2], e.w}.writeUint16(uint16(l))
  235. e.w.writen1(xtag)
  236. } else {
  237. e.w.writen1(mpExt32)
  238. bigenHelper{e.x[:4], e.w}.writeUint32(uint32(l))
  239. e.w.writen1(xtag)
  240. }
  241. }
  242. func (e *msgpackEncDriver) WriteArrayStart(length int) {
  243. e.writeContainerLen(msgpackContainerList, length)
  244. }
  245. func (e *msgpackEncDriver) WriteMapStart(length int) {
  246. e.writeContainerLen(msgpackContainerMap, length)
  247. }
  248. func (e *msgpackEncDriver) EncodeString(c charEncoding, s string) {
  249. slen := len(s)
  250. if c == cRAW && e.h.WriteExt {
  251. e.writeContainerLen(msgpackContainerBin, slen)
  252. } else {
  253. e.writeContainerLen(msgpackContainerStr, slen)
  254. }
  255. if slen > 0 {
  256. e.w.writestr(s)
  257. }
  258. }
  259. func (e *msgpackEncDriver) EncodeSymbol(v string) {
  260. e.EncodeString(cUTF8, v)
  261. }
  262. func (e *msgpackEncDriver) EncodeStringBytes(c charEncoding, bs []byte) {
  263. slen := len(bs)
  264. if c == cRAW && e.h.WriteExt {
  265. e.writeContainerLen(msgpackContainerBin, slen)
  266. } else {
  267. e.writeContainerLen(msgpackContainerStr, slen)
  268. }
  269. if slen > 0 {
  270. e.w.writeb(bs)
  271. }
  272. }
  273. func (e *msgpackEncDriver) writeContainerLen(ct msgpackContainerType, l int) {
  274. if ct.hasFixMin && l < ct.fixCutoff {
  275. e.w.writen1(ct.bFixMin | byte(l))
  276. } else if ct.has8 && l < 256 && (ct.has8Always || e.h.WriteExt) {
  277. e.w.writen2(ct.b8, uint8(l))
  278. } else if l < 65536 {
  279. e.w.writen1(ct.b16)
  280. bigenHelper{e.x[:2], e.w}.writeUint16(uint16(l))
  281. } else {
  282. e.w.writen1(ct.b32)
  283. bigenHelper{e.x[:4], e.w}.writeUint32(uint32(l))
  284. }
  285. }
  286. //---------------------------------------------
  287. type msgpackDecDriver struct {
  288. d *Decoder
  289. r decReader // *Decoder decReader decReaderT
  290. h *MsgpackHandle
  291. b [scratchByteArrayLen]byte
  292. bd byte
  293. bdRead bool
  294. br bool // bytes reader
  295. noBuiltInTypes
  296. // noStreamingCodec
  297. // decNoSeparator
  298. decDriverNoopContainerReader
  299. }
  300. // Note: This returns either a primitive (int, bool, etc) for non-containers,
  301. // or a containerType, or a specific type denoting nil or extension.
  302. // It is called when a nil interface{} is passed, leaving it up to the DecDriver
  303. // to introspect the stream and decide how best to decode.
  304. // It deciphers the value by looking at the stream first.
  305. func (d *msgpackDecDriver) DecodeNaked() {
  306. if !d.bdRead {
  307. d.readNextBd()
  308. }
  309. bd := d.bd
  310. n := d.d.n
  311. var decodeFurther bool
  312. switch bd {
  313. case mpNil:
  314. n.v = valueTypeNil
  315. d.bdRead = false
  316. case mpFalse:
  317. n.v = valueTypeBool
  318. n.b = false
  319. case mpTrue:
  320. n.v = valueTypeBool
  321. n.b = true
  322. case mpFloat:
  323. n.v = valueTypeFloat
  324. n.f = float64(math.Float32frombits(bigen.Uint32(d.r.readx(4))))
  325. case mpDouble:
  326. n.v = valueTypeFloat
  327. n.f = math.Float64frombits(bigen.Uint64(d.r.readx(8)))
  328. case mpUint8:
  329. n.v = valueTypeUint
  330. n.u = uint64(d.r.readn1())
  331. case mpUint16:
  332. n.v = valueTypeUint
  333. n.u = uint64(bigen.Uint16(d.r.readx(2)))
  334. case mpUint32:
  335. n.v = valueTypeUint
  336. n.u = uint64(bigen.Uint32(d.r.readx(4)))
  337. case mpUint64:
  338. n.v = valueTypeUint
  339. n.u = uint64(bigen.Uint64(d.r.readx(8)))
  340. case mpInt8:
  341. n.v = valueTypeInt
  342. n.i = int64(int8(d.r.readn1()))
  343. case mpInt16:
  344. n.v = valueTypeInt
  345. n.i = int64(int16(bigen.Uint16(d.r.readx(2))))
  346. case mpInt32:
  347. n.v = valueTypeInt
  348. n.i = int64(int32(bigen.Uint32(d.r.readx(4))))
  349. case mpInt64:
  350. n.v = valueTypeInt
  351. n.i = int64(int64(bigen.Uint64(d.r.readx(8))))
  352. default:
  353. switch {
  354. case bd >= mpPosFixNumMin && bd <= mpPosFixNumMax:
  355. // positive fixnum (always signed)
  356. n.v = valueTypeInt
  357. n.i = int64(int8(bd))
  358. case bd >= mpNegFixNumMin && bd <= mpNegFixNumMax:
  359. // negative fixnum
  360. n.v = valueTypeInt
  361. n.i = int64(int8(bd))
  362. case bd == mpStr8, bd == mpStr16, bd == mpStr32, bd >= mpFixStrMin && bd <= mpFixStrMax:
  363. if d.h.RawToString {
  364. n.v = valueTypeString
  365. n.s = d.DecodeString()
  366. } else {
  367. n.v = valueTypeBytes
  368. n.l = d.DecodeBytes(nil, false)
  369. }
  370. case bd == mpBin8, bd == mpBin16, bd == mpBin32:
  371. n.v = valueTypeBytes
  372. n.l = d.DecodeBytes(nil, false)
  373. case bd == mpArray16, bd == mpArray32, bd >= mpFixArrayMin && bd <= mpFixArrayMax:
  374. n.v = valueTypeArray
  375. decodeFurther = true
  376. case bd == mpMap16, bd == mpMap32, bd >= mpFixMapMin && bd <= mpFixMapMax:
  377. n.v = valueTypeMap
  378. decodeFurther = true
  379. case bd >= mpFixExt1 && bd <= mpFixExt16, bd >= mpExt8 && bd <= mpExt32:
  380. n.v = valueTypeExt
  381. clen := d.readExtLen()
  382. n.u = uint64(d.r.readn1())
  383. if n.u == uint64(mpTimeExtTagU) {
  384. n.v = valueTypeTime
  385. n.t = d.decodeTime(clen)
  386. } else {
  387. n.l = d.r.readx(clen)
  388. }
  389. default:
  390. d.d.errorf("Nil-Deciphered DecodeValue: %s: hex: %x, dec: %d", msgBadDesc, bd, bd)
  391. }
  392. }
  393. if !decodeFurther {
  394. d.bdRead = false
  395. }
  396. if n.v == valueTypeUint && d.h.SignedInteger {
  397. n.v = valueTypeInt
  398. n.i = int64(n.u)
  399. }
  400. return
  401. }
  402. // int can be decoded from msgpack type: intXXX or uintXXX
  403. func (d *msgpackDecDriver) DecodeInt(bitsize uint8) (i int64) {
  404. if !d.bdRead {
  405. d.readNextBd()
  406. }
  407. switch d.bd {
  408. case mpUint8:
  409. i = int64(uint64(d.r.readn1()))
  410. case mpUint16:
  411. i = int64(uint64(bigen.Uint16(d.r.readx(2))))
  412. case mpUint32:
  413. i = int64(uint64(bigen.Uint32(d.r.readx(4))))
  414. case mpUint64:
  415. i = int64(bigen.Uint64(d.r.readx(8)))
  416. case mpInt8:
  417. i = int64(int8(d.r.readn1()))
  418. case mpInt16:
  419. i = int64(int16(bigen.Uint16(d.r.readx(2))))
  420. case mpInt32:
  421. i = int64(int32(bigen.Uint32(d.r.readx(4))))
  422. case mpInt64:
  423. i = int64(bigen.Uint64(d.r.readx(8)))
  424. default:
  425. switch {
  426. case d.bd >= mpPosFixNumMin && d.bd <= mpPosFixNumMax:
  427. i = int64(int8(d.bd))
  428. case d.bd >= mpNegFixNumMin && d.bd <= mpNegFixNumMax:
  429. i = int64(int8(d.bd))
  430. default:
  431. d.d.errorf("Unhandled single-byte unsigned integer value: %s: %x", msgBadDesc, d.bd)
  432. return
  433. }
  434. }
  435. // check overflow (logic adapted from std pkg reflect/value.go OverflowUint()
  436. if bitsize > 0 {
  437. if trunc := (i << (64 - bitsize)) >> (64 - bitsize); i != trunc {
  438. d.d.errorf("Overflow int value: %v", i)
  439. return
  440. }
  441. }
  442. d.bdRead = false
  443. return
  444. }
  445. // uint can be decoded from msgpack type: intXXX or uintXXX
  446. func (d *msgpackDecDriver) DecodeUint(bitsize uint8) (ui uint64) {
  447. if !d.bdRead {
  448. d.readNextBd()
  449. }
  450. switch d.bd {
  451. case mpUint8:
  452. ui = uint64(d.r.readn1())
  453. case mpUint16:
  454. ui = uint64(bigen.Uint16(d.r.readx(2)))
  455. case mpUint32:
  456. ui = uint64(bigen.Uint32(d.r.readx(4)))
  457. case mpUint64:
  458. ui = bigen.Uint64(d.r.readx(8))
  459. case mpInt8:
  460. if i := int64(int8(d.r.readn1())); i >= 0 {
  461. ui = uint64(i)
  462. } else {
  463. d.d.errorf("Assigning negative signed value: %v, to unsigned type", i)
  464. return
  465. }
  466. case mpInt16:
  467. if i := int64(int16(bigen.Uint16(d.r.readx(2)))); i >= 0 {
  468. ui = uint64(i)
  469. } else {
  470. d.d.errorf("Assigning negative signed value: %v, to unsigned type", i)
  471. return
  472. }
  473. case mpInt32:
  474. if i := int64(int32(bigen.Uint32(d.r.readx(4)))); i >= 0 {
  475. ui = uint64(i)
  476. } else {
  477. d.d.errorf("Assigning negative signed value: %v, to unsigned type", i)
  478. return
  479. }
  480. case mpInt64:
  481. if i := int64(bigen.Uint64(d.r.readx(8))); i >= 0 {
  482. ui = uint64(i)
  483. } else {
  484. d.d.errorf("Assigning negative signed value: %v, to unsigned type", i)
  485. return
  486. }
  487. default:
  488. switch {
  489. case d.bd >= mpPosFixNumMin && d.bd <= mpPosFixNumMax:
  490. ui = uint64(d.bd)
  491. case d.bd >= mpNegFixNumMin && d.bd <= mpNegFixNumMax:
  492. d.d.errorf("Assigning negative signed value: %v, to unsigned type", int(d.bd))
  493. return
  494. default:
  495. d.d.errorf("Unhandled single-byte unsigned integer value: %s: %x", msgBadDesc, d.bd)
  496. return
  497. }
  498. }
  499. // check overflow (logic adapted from std pkg reflect/value.go OverflowUint()
  500. if bitsize > 0 {
  501. if trunc := (ui << (64 - bitsize)) >> (64 - bitsize); ui != trunc {
  502. d.d.errorf("Overflow uint value: %v", ui)
  503. return
  504. }
  505. }
  506. d.bdRead = false
  507. return
  508. }
  509. // float can either be decoded from msgpack type: float, double or intX
  510. func (d *msgpackDecDriver) DecodeFloat(chkOverflow32 bool) (f float64) {
  511. if !d.bdRead {
  512. d.readNextBd()
  513. }
  514. if d.bd == mpFloat {
  515. f = float64(math.Float32frombits(bigen.Uint32(d.r.readx(4))))
  516. } else if d.bd == mpDouble {
  517. f = math.Float64frombits(bigen.Uint64(d.r.readx(8)))
  518. } else {
  519. f = float64(d.DecodeInt(0))
  520. }
  521. if chkOverflow32 && chkOvf.Float32(f) {
  522. d.d.errorf("msgpack: float32 overflow: %v", f)
  523. return
  524. }
  525. d.bdRead = false
  526. return
  527. }
  528. // bool can be decoded from bool, fixnum 0 or 1.
  529. func (d *msgpackDecDriver) DecodeBool() (b bool) {
  530. if !d.bdRead {
  531. d.readNextBd()
  532. }
  533. if d.bd == mpFalse || d.bd == 0 {
  534. // b = false
  535. } else if d.bd == mpTrue || d.bd == 1 {
  536. b = true
  537. } else {
  538. d.d.errorf("Invalid single-byte value for bool: %s: %x", msgBadDesc, d.bd)
  539. return
  540. }
  541. d.bdRead = false
  542. return
  543. }
  544. func (d *msgpackDecDriver) DecodeBytes(bs []byte, zerocopy bool) (bsOut []byte) {
  545. if !d.bdRead {
  546. d.readNextBd()
  547. }
  548. // DecodeBytes could be from: bin str fixstr fixarray array ...
  549. var clen int
  550. vt := d.ContainerType()
  551. switch vt {
  552. case valueTypeBytes:
  553. // valueTypeBytes may be a mpBin or an mpStr container
  554. if bd := d.bd; bd == mpBin8 || bd == mpBin16 || bd == mpBin32 {
  555. clen = d.readContainerLen(msgpackContainerBin)
  556. } else {
  557. clen = d.readContainerLen(msgpackContainerStr)
  558. }
  559. case valueTypeString:
  560. clen = d.readContainerLen(msgpackContainerStr)
  561. case valueTypeArray:
  562. clen = d.readContainerLen(msgpackContainerList)
  563. // ensure everything after is one byte each
  564. for i := 0; i < clen; i++ {
  565. d.readNextBd()
  566. if d.bd == mpNil {
  567. bs = append(bs, 0)
  568. } else if d.bd == mpUint8 {
  569. bs = append(bs, d.r.readn1())
  570. } else {
  571. d.d.errorf("cannot read non-byte into a byte array")
  572. return
  573. }
  574. }
  575. d.bdRead = false
  576. return bs
  577. default:
  578. d.d.errorf("invalid container type: expecting bin|str|array, got: 0x%x", uint8(vt))
  579. return
  580. }
  581. // these are (bin|str)(8|16|32)
  582. // println("DecodeBytes: clen: ", clen)
  583. d.bdRead = false
  584. // bytes may be nil, so handle it. if nil, clen=-1.
  585. if clen < 0 {
  586. return nil
  587. }
  588. if zerocopy {
  589. if d.br {
  590. return d.r.readx(clen)
  591. } else if len(bs) == 0 {
  592. bs = d.b[:]
  593. }
  594. }
  595. return decByteSlice(d.r, clen, d.d.h.MaxInitLen, bs)
  596. }
  597. func (d *msgpackDecDriver) DecodeString() (s string) {
  598. return string(d.DecodeBytes(d.b[:], true))
  599. }
  600. func (d *msgpackDecDriver) DecodeStringAsBytes() (s []byte) {
  601. return d.DecodeBytes(d.b[:], true)
  602. }
  603. func (d *msgpackDecDriver) readNextBd() {
  604. d.bd = d.r.readn1()
  605. d.bdRead = true
  606. }
  607. func (d *msgpackDecDriver) uncacheRead() {
  608. if d.bdRead {
  609. d.r.unreadn1()
  610. d.bdRead = false
  611. }
  612. }
  613. func (d *msgpackDecDriver) ContainerType() (vt valueType) {
  614. if !d.bdRead {
  615. d.readNextBd()
  616. }
  617. bd := d.bd
  618. if bd == mpNil {
  619. return valueTypeNil
  620. } else if bd == mpBin8 || bd == mpBin16 || bd == mpBin32 ||
  621. (!d.h.RawToString &&
  622. (bd == mpStr8 || bd == mpStr16 || bd == mpStr32 || (bd >= mpFixStrMin && bd <= mpFixStrMax))) {
  623. return valueTypeBytes
  624. } else if d.h.RawToString &&
  625. (bd == mpStr8 || bd == mpStr16 || bd == mpStr32 || (bd >= mpFixStrMin && bd <= mpFixStrMax)) {
  626. return valueTypeString
  627. } else if bd == mpArray16 || bd == mpArray32 || (bd >= mpFixArrayMin && bd <= mpFixArrayMax) {
  628. return valueTypeArray
  629. } else if bd == mpMap16 || bd == mpMap32 || (bd >= mpFixMapMin && bd <= mpFixMapMax) {
  630. return valueTypeMap
  631. }
  632. // else {
  633. // d.d.errorf("isContainerType: unsupported parameter: %v", vt)
  634. // }
  635. return valueTypeUnset
  636. }
  637. func (d *msgpackDecDriver) TryDecodeAsNil() (v bool) {
  638. if !d.bdRead {
  639. d.readNextBd()
  640. }
  641. if d.bd == mpNil {
  642. d.bdRead = false
  643. v = true
  644. }
  645. return
  646. }
  647. func (d *msgpackDecDriver) readContainerLen(ct msgpackContainerType) (clen int) {
  648. bd := d.bd
  649. if bd == mpNil {
  650. clen = -1 // to represent nil
  651. } else if bd == ct.b8 {
  652. clen = int(d.r.readn1())
  653. } else if bd == ct.b16 {
  654. clen = int(bigen.Uint16(d.r.readx(2)))
  655. } else if bd == ct.b32 {
  656. clen = int(bigen.Uint32(d.r.readx(4)))
  657. } else if (ct.bFixMin & bd) == ct.bFixMin {
  658. clen = int(ct.bFixMin ^ bd)
  659. } else {
  660. d.d.errorf("readContainerLen: %s: hex: %x, decimal: %d", msgBadDesc, bd, bd)
  661. return
  662. }
  663. d.bdRead = false
  664. return
  665. }
  666. func (d *msgpackDecDriver) ReadMapStart() int {
  667. if !d.bdRead {
  668. d.readNextBd()
  669. }
  670. return d.readContainerLen(msgpackContainerMap)
  671. }
  672. func (d *msgpackDecDriver) ReadArrayStart() int {
  673. if !d.bdRead {
  674. d.readNextBd()
  675. }
  676. return d.readContainerLen(msgpackContainerList)
  677. }
  678. func (d *msgpackDecDriver) readExtLen() (clen int) {
  679. switch d.bd {
  680. case mpNil:
  681. clen = -1 // to represent nil
  682. case mpFixExt1:
  683. clen = 1
  684. case mpFixExt2:
  685. clen = 2
  686. case mpFixExt4:
  687. clen = 4
  688. case mpFixExt8:
  689. clen = 8
  690. case mpFixExt16:
  691. clen = 16
  692. case mpExt8:
  693. clen = int(d.r.readn1())
  694. case mpExt16:
  695. clen = int(bigen.Uint16(d.r.readx(2)))
  696. case mpExt32:
  697. clen = int(bigen.Uint32(d.r.readx(4)))
  698. default:
  699. d.d.errorf("decoding ext bytes: found unexpected byte: %x", d.bd)
  700. return
  701. }
  702. return
  703. }
  704. func (d *msgpackDecDriver) DecodeTime() (t time.Time) {
  705. // decode time from string bytes or ext
  706. if !d.bdRead {
  707. d.readNextBd()
  708. }
  709. var clen int
  710. switch d.ContainerType() {
  711. case valueTypeBytes, valueTypeString:
  712. clen = d.readContainerLen(msgpackContainerStr)
  713. default:
  714. // expect to see mpFixExt4,-1 OR mpFixExt8,-1 OR mpExt8,12,-1
  715. d.bdRead = false
  716. b2 := d.r.readn1()
  717. if d.bd == mpFixExt4 && b2 == mpTimeExtTagU {
  718. clen = 4
  719. } else if d.bd == mpFixExt8 && b2 == mpTimeExtTagU {
  720. clen = 8
  721. } else if d.bd == mpExt8 && b2 == 12 && d.r.readn1() == mpTimeExtTagU {
  722. clen = 12
  723. } else {
  724. d.d.errorf("invalid sequence of bytes for decoding time as an extension: got 0x%x, 0x%x", d.bd, b2)
  725. return
  726. }
  727. }
  728. return d.decodeTime(clen)
  729. }
  730. func (d *msgpackDecDriver) decodeTime(clen int) (t time.Time) {
  731. // bs = d.r.readx(clen)
  732. d.bdRead = false
  733. switch clen {
  734. case 4:
  735. t = time.Unix(int64(bigen.Uint32(d.r.readx(4))), 0).UTC()
  736. case 8:
  737. tv := bigen.Uint64(d.r.readx(8))
  738. t = time.Unix(int64(tv&0x00000003ffffffff), int64(tv>>34)).UTC()
  739. case 12:
  740. nsec := bigen.Uint32(d.r.readx(4))
  741. sec := bigen.Uint64(d.r.readx(8))
  742. t = time.Unix(int64(sec), int64(nsec)).UTC()
  743. default:
  744. d.d.errorf("invalid length of bytes for decoding time - expecting 4 or 8 or 12, got %d", clen)
  745. return
  746. }
  747. return
  748. }
  749. func (d *msgpackDecDriver) DecodeExt(rv interface{}, xtag uint64, ext Ext) (realxtag uint64) {
  750. if xtag > 0xff {
  751. d.d.errorf("decodeExt: tag must be <= 0xff; got: %v", xtag)
  752. return
  753. }
  754. realxtag1, xbs := d.decodeExtV(ext != nil, uint8(xtag))
  755. realxtag = uint64(realxtag1)
  756. if ext == nil {
  757. re := rv.(*RawExt)
  758. re.Tag = realxtag
  759. re.Data = detachZeroCopyBytes(d.br, re.Data, xbs)
  760. } else {
  761. ext.ReadExt(rv, xbs)
  762. }
  763. return
  764. }
  765. func (d *msgpackDecDriver) decodeExtV(verifyTag bool, tag byte) (xtag byte, xbs []byte) {
  766. if !d.bdRead {
  767. d.readNextBd()
  768. }
  769. xbd := d.bd
  770. if xbd == mpBin8 || xbd == mpBin16 || xbd == mpBin32 {
  771. xbs = d.DecodeBytes(nil, true)
  772. } else if xbd == mpStr8 || xbd == mpStr16 || xbd == mpStr32 ||
  773. (xbd >= mpFixStrMin && xbd <= mpFixStrMax) {
  774. xbs = d.DecodeStringAsBytes()
  775. } else {
  776. clen := d.readExtLen()
  777. xtag = d.r.readn1()
  778. if verifyTag && xtag != tag {
  779. d.d.errorf("Wrong extension tag. Got %b. Expecting: %v", xtag, tag)
  780. return
  781. }
  782. xbs = d.r.readx(clen)
  783. }
  784. d.bdRead = false
  785. return
  786. }
  787. //--------------------------------------------------
  788. //MsgpackHandle is a Handle for the Msgpack Schema-Free Encoding Format.
  789. type MsgpackHandle struct {
  790. BasicHandle
  791. // RawToString controls how raw bytes are decoded into a nil interface{}.
  792. RawToString bool
  793. // NoFixedNum says to output all signed integers as 2-bytes, never as 1-byte fixednum.
  794. NoFixedNum bool
  795. // WriteExt flag supports encoding configured extensions with extension tags.
  796. // It also controls whether other elements of the new spec are encoded (ie Str8).
  797. //
  798. // With WriteExt=false, configured extensions are serialized as raw bytes
  799. // and Str8 is not encoded.
  800. //
  801. // A stream can still be decoded into a typed value, provided an appropriate value
  802. // is provided, but the type cannot be inferred from the stream. If no appropriate
  803. // type is provided (e.g. decoding into a nil interface{}), you get back
  804. // a []byte or string based on the setting of RawToString.
  805. WriteExt bool
  806. binaryEncodingType
  807. noElemSeparators
  808. }
  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. return
  895. }
  896. if err = c.read(&b); err != nil {
  897. return
  898. }
  899. if b != expectTypeByte {
  900. err = fmt.Errorf("Unexpected byte descriptor in header. Expecting %v. Received %v", expectTypeByte, b)
  901. return
  902. }
  903. if err = c.read(msgid); err != nil {
  904. return
  905. }
  906. if err = c.read(methodOrError); err != nil {
  907. return
  908. }
  909. return
  910. }
  911. //--------------------------------------------------
  912. // msgpackSpecRpc is the implementation of Rpc that uses custom communication protocol
  913. // as defined in the msgpack spec at https://github.com/msgpack-rpc/msgpack-rpc/blob/master/spec.md
  914. type msgpackSpecRpc struct{}
  915. // MsgpackSpecRpc implements Rpc using the communication protocol defined in
  916. // the msgpack spec at https://github.com/msgpack-rpc/msgpack-rpc/blob/master/spec.md .
  917. //
  918. // See GoRpc documentation, for information on buffering for better performance.
  919. var MsgpackSpecRpc msgpackSpecRpc
  920. func (x msgpackSpecRpc) ServerCodec(conn io.ReadWriteCloser, h Handle) rpc.ServerCodec {
  921. return &msgpackSpecRpcCodec{newRPCCodec(conn, h)}
  922. }
  923. func (x msgpackSpecRpc) ClientCodec(conn io.ReadWriteCloser, h Handle) rpc.ClientCodec {
  924. return &msgpackSpecRpcCodec{newRPCCodec(conn, h)}
  925. }
  926. var _ decDriver = (*msgpackDecDriver)(nil)
  927. var _ encDriver = (*msgpackEncDriver)(nil)