msgpack.go 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831
  1. // Copyright (c) 2012, 2013 Ugorji Nwoke. All rights reserved.
  2. // Use of this source code is governed by a BSD-style license found in the LICENSE file.
  3. package codec
  4. import (
  5. "fmt"
  6. "io"
  7. "math"
  8. "net/rpc"
  9. "reflect"
  10. "time"
  11. )
  12. const (
  13. mpPosFixNumMin byte = 0x00
  14. mpPosFixNumMax = 0x7f
  15. mpFixMapMin = 0x80
  16. mpFixMapMax = 0x8f
  17. mpFixArrayMin = 0x90
  18. mpFixArrayMax = 0x9f
  19. mpFixStrMin = 0xa0
  20. mpFixStrMax = 0xbf
  21. mpNil = 0xc0
  22. _ = 0xc1
  23. mpFalse = 0xc2
  24. mpTrue = 0xc3
  25. mpFloat = 0xca
  26. mpDouble = 0xcb
  27. mpUint8 = 0xcc
  28. mpUint16 = 0xcd
  29. mpUint32 = 0xce
  30. mpUint64 = 0xcf
  31. mpInt8 = 0xd0
  32. mpInt16 = 0xd1
  33. mpInt32 = 0xd2
  34. mpInt64 = 0xd3
  35. // extensions below
  36. mpBin8 = 0xc4
  37. mpBin16 = 0xc5
  38. mpBin32 = 0xc6
  39. mpExt8 = 0xc7
  40. mpExt16 = 0xc8
  41. mpExt32 = 0xc9
  42. mpFixExt1 = 0xd4
  43. mpFixExt2 = 0xd5
  44. mpFixExt4 = 0xd6
  45. mpFixExt8 = 0xd7
  46. mpFixExt16 = 0xd8
  47. mpStr8 = 0xd9 // new
  48. mpStr16 = 0xda
  49. mpStr32 = 0xdb
  50. mpArray16 = 0xdc
  51. mpArray32 = 0xdd
  52. mpMap16 = 0xde
  53. mpMap32 = 0xdf
  54. mpNegFixNumMin = 0xe0
  55. mpNegFixNumMax = 0xff
  56. )
  57. // MsgpackSpecRpc implements Rpc using the communication protocol defined in
  58. // the msgpack spec at http://wiki.msgpack.org/display/MSGPACK/RPC+specification .
  59. // It's methods (ServerCodec and ClientCodec) return values that implement RpcCodecBuffered.
  60. var MsgpackSpecRpc msgpackSpecRpc
  61. // MsgpackSpecRpcMultiArgs is a special type which signifies to the MsgpackSpecRpcCodec
  62. // that the backend RPC service takes multiple arguments, which have been arranged
  63. // in sequence in the slice.
  64. //
  65. // The Codec then passes it AS-IS to the rpc service (without wrapping it in an
  66. // array of 1 element).
  67. type MsgpackSpecRpcMultiArgs []interface{}
  68. // A MsgpackContainer type specifies the different types of msgpackContainers.
  69. type msgpackContainerType struct {
  70. fixCutoff int
  71. bFixMin, b8, b16, b32 byte
  72. hasFixMin, has8, has8Always bool
  73. }
  74. var (
  75. msgpackContainerStr = msgpackContainerType{32, mpFixStrMin, mpStr8, mpStr16, mpStr32, true, true, false}
  76. msgpackContainerBin = msgpackContainerType{0, 0, mpBin8, mpBin16, mpBin32, false, true, true}
  77. msgpackContainerList = msgpackContainerType{16, mpFixArrayMin, 0, mpArray16, mpArray32, true, false, false}
  78. msgpackContainerMap = msgpackContainerType{16, mpFixMapMin, 0, mpMap16, mpMap32, true, false, false}
  79. )
  80. // msgpackSpecRpc is the implementation of Rpc that uses custom communication protocol
  81. // as defined in the msgpack spec at http://wiki.msgpack.org/display/MSGPACK/RPC+specification
  82. type msgpackSpecRpc struct{}
  83. type msgpackSpecRpcCodec struct {
  84. rpcCodec
  85. }
  86. //MsgpackHandle is a Handle for the Msgpack Schema-Free Encoding Format.
  87. type MsgpackHandle struct {
  88. // RawToString controls how raw bytes are decoded into a nil interface{}.
  89. RawToString bool
  90. // WriteExt flag supports encoding configured extensions with extension tags.
  91. // It also controls whether other elements of the new spec are encoded (ie Str8).
  92. //
  93. // With WriteExt=false, configured extensions are serialized as raw bytes
  94. // and Str8 is not encoded.
  95. //
  96. // A stream can still be decoded into a typed value, provided an appropriate value
  97. // is provided, but the type cannot be inferred from the stream. If no appropriate
  98. // type is provided (e.g. decoding into a nil interface{}), you get back
  99. // a []byte or string based on the setting of RawToString.
  100. WriteExt bool
  101. extHandle
  102. EncodeOptions
  103. DecodeOptions
  104. }
  105. type msgpackEncDriver struct {
  106. w encWriter
  107. h *MsgpackHandle
  108. }
  109. type msgpackDecDriver struct {
  110. r decReader
  111. h *MsgpackHandle
  112. bd byte
  113. bdRead bool
  114. bdType decodeEncodedType
  115. }
  116. func (e *msgpackEncDriver) isBuiltinType(rt uintptr) bool {
  117. //no builtin types. All encodings are based on kinds. Types supported as extensions.
  118. return false
  119. }
  120. func (e *msgpackEncDriver) encodeBuiltinType(rt uintptr, rv reflect.Value) {}
  121. func (e *msgpackEncDriver) encodeNil() {
  122. e.w.writen1(mpNil)
  123. }
  124. func (e *msgpackEncDriver) encodeInt(i int64) {
  125. switch {
  126. case i >= -32 && i <= math.MaxInt8:
  127. e.w.writen1(byte(i))
  128. case i < -32 && i >= math.MinInt8:
  129. e.w.writen2(mpInt8, byte(i))
  130. case i >= math.MinInt16 && i <= math.MaxInt16:
  131. e.w.writen1(mpInt16)
  132. e.w.writeUint16(uint16(i))
  133. case i >= math.MinInt32 && i <= math.MaxInt32:
  134. e.w.writen1(mpInt32)
  135. e.w.writeUint32(uint32(i))
  136. case i >= math.MinInt64 && i <= math.MaxInt64:
  137. e.w.writen1(mpInt64)
  138. e.w.writeUint64(uint64(i))
  139. default:
  140. encErr("encInt64: Unreachable block")
  141. }
  142. }
  143. func (e *msgpackEncDriver) encodeUint(i uint64) {
  144. // uints are not fixnums. fixnums are always signed.
  145. // case i <= math.MaxInt8:
  146. // e.w.writen1(byte(i))
  147. switch {
  148. case i <= math.MaxUint8:
  149. e.w.writen2(mpUint8, byte(i))
  150. case i <= math.MaxUint16:
  151. e.w.writen1(mpUint16)
  152. e.w.writeUint16(uint16(i))
  153. case i <= math.MaxUint32:
  154. e.w.writen1(mpUint32)
  155. e.w.writeUint32(uint32(i))
  156. default:
  157. e.w.writen1(mpUint64)
  158. e.w.writeUint64(uint64(i))
  159. }
  160. }
  161. func (e *msgpackEncDriver) encodeBool(b bool) {
  162. if b {
  163. e.w.writen1(mpTrue)
  164. } else {
  165. e.w.writen1(mpFalse)
  166. }
  167. }
  168. func (e *msgpackEncDriver) encodeFloat32(f float32) {
  169. e.w.writen1(mpFloat)
  170. e.w.writeUint32(math.Float32bits(f))
  171. }
  172. func (e *msgpackEncDriver) encodeFloat64(f float64) {
  173. e.w.writen1(mpDouble)
  174. e.w.writeUint64(math.Float64bits(f))
  175. }
  176. func (e *msgpackEncDriver) encodeExtPreamble(xtag byte, l int) {
  177. switch {
  178. case l == 1:
  179. e.w.writen2(mpFixExt1, xtag)
  180. case l == 2:
  181. e.w.writen2(mpFixExt2, xtag)
  182. case l == 4:
  183. e.w.writen2(mpFixExt4, xtag)
  184. case l == 8:
  185. e.w.writen2(mpFixExt8, xtag)
  186. case l == 16:
  187. e.w.writen2(mpFixExt16, xtag)
  188. case l < 256:
  189. e.w.writen2(mpExt8, byte(l))
  190. e.w.writen1(xtag)
  191. case l < 65536:
  192. e.w.writen1(mpExt16)
  193. e.w.writeUint16(uint16(l))
  194. e.w.writen1(xtag)
  195. default:
  196. e.w.writen1(mpExt32)
  197. e.w.writeUint32(uint32(l))
  198. e.w.writen1(xtag)
  199. }
  200. }
  201. func (e *msgpackEncDriver) encodeArrayPreamble(length int) {
  202. e.writeContainerLen(msgpackContainerList, length)
  203. }
  204. func (e *msgpackEncDriver) encodeMapPreamble(length int) {
  205. e.writeContainerLen(msgpackContainerMap, length)
  206. }
  207. func (e *msgpackEncDriver) encodeString(c charEncoding, s string) {
  208. if c == c_RAW && e.h.WriteExt {
  209. e.writeContainerLen(msgpackContainerBin, len(s))
  210. } else {
  211. e.writeContainerLen(msgpackContainerStr, len(s))
  212. }
  213. if len(s) > 0 {
  214. e.w.writestr(s)
  215. }
  216. }
  217. func (e *msgpackEncDriver) encodeSymbol(v string) {
  218. e.encodeString(c_UTF8, v)
  219. }
  220. func (e *msgpackEncDriver) encodeStringBytes(c charEncoding, bs []byte) {
  221. if c == c_RAW && e.h.WriteExt {
  222. e.writeContainerLen(msgpackContainerBin, len(bs))
  223. } else {
  224. e.writeContainerLen(msgpackContainerStr, len(bs))
  225. }
  226. if len(bs) > 0 {
  227. e.w.writeb(bs)
  228. }
  229. }
  230. func (e *msgpackEncDriver) writeContainerLen(ct msgpackContainerType, l int) {
  231. switch {
  232. case ct.hasFixMin && l < ct.fixCutoff:
  233. e.w.writen1(ct.bFixMin | byte(l))
  234. case ct.has8 && l < 256 && (ct.has8Always || e.h.WriteExt):
  235. e.w.writen2(ct.b8, uint8(l))
  236. case l < 65536:
  237. e.w.writen1(ct.b16)
  238. e.w.writeUint16(uint16(l))
  239. default:
  240. e.w.writen1(ct.b32)
  241. e.w.writeUint32(uint32(l))
  242. }
  243. }
  244. //---------------------------------------------
  245. func (d *msgpackDecDriver) isBuiltinType(rt uintptr) bool {
  246. //no builtin types. All encodings are based on kinds. Types supported as extensions.
  247. return false
  248. }
  249. func (d *msgpackDecDriver) decodeBuiltinType(rt uintptr, rv reflect.Value) {}
  250. // Note: This returns either a primitive (int, bool, etc) for non-containers,
  251. // or a containerType, or a specific type denoting nil or extension.
  252. // It is called when a nil interface{} is passed, leaving it up to the DecDriver
  253. // to introspect the stream and decide how best to decode.
  254. // It deciphers the value by looking at the stream first.
  255. func (d *msgpackDecDriver) decodeNaked() (rv reflect.Value, ctx decodeNakedContext) {
  256. d.initReadNext()
  257. bd := d.bd
  258. var v interface{}
  259. switch bd {
  260. case mpNil:
  261. ctx = dncNil
  262. d.bdRead = false
  263. case mpFalse:
  264. v = false
  265. case mpTrue:
  266. v = true
  267. case mpFloat:
  268. v = float64(math.Float32frombits(d.r.readUint32()))
  269. case mpDouble:
  270. v = math.Float64frombits(d.r.readUint64())
  271. case mpUint8:
  272. v = uint64(d.r.readn1())
  273. case mpUint16:
  274. v = uint64(d.r.readUint16())
  275. case mpUint32:
  276. v = uint64(d.r.readUint32())
  277. case mpUint64:
  278. v = uint64(d.r.readUint64())
  279. case mpInt8:
  280. v = int64(int8(d.r.readn1()))
  281. case mpInt16:
  282. v = int64(int16(d.r.readUint16()))
  283. case mpInt32:
  284. v = int64(int32(d.r.readUint32()))
  285. case mpInt64:
  286. v = int64(int64(d.r.readUint64()))
  287. default:
  288. switch {
  289. case bd >= mpPosFixNumMin && bd <= mpPosFixNumMax:
  290. // positive fixnum (always signed)
  291. v = int64(int8(bd))
  292. case bd >= mpNegFixNumMin && bd <= mpNegFixNumMax:
  293. // negative fixnum
  294. v = int64(int8(bd))
  295. case bd == mpStr8, bd == mpStr16, bd == mpStr32, bd >= mpFixStrMin && bd <= mpFixStrMax:
  296. ctx = dncContainer
  297. // v = containerRaw
  298. if d.h.RawToString {
  299. var rvm string
  300. rv = reflect.ValueOf(&rvm).Elem()
  301. } else {
  302. rvm := []byte{}
  303. rv = reflect.ValueOf(&rvm).Elem()
  304. //rv = reflect.New(byteSliceTyp).Elem() // Use New, not Zero, so it's settable
  305. }
  306. case bd == mpBin8, bd == mpBin16, bd == mpBin32:
  307. ctx = dncContainer
  308. rvm := []byte{}
  309. rv = reflect.ValueOf(&rvm).Elem()
  310. // rv = reflect.New(byteSliceTyp).Elem()
  311. case bd == mpArray16, bd == mpArray32, bd >= mpFixArrayMin && bd <= mpFixArrayMax:
  312. ctx = dncContainer
  313. // v = containerList
  314. if d.h.SliceType == nil {
  315. rv = reflect.New(intfSliceTyp).Elem()
  316. } else {
  317. rv = reflect.New(d.h.SliceType).Elem()
  318. }
  319. case bd == mpMap16, bd == mpMap32, bd >= mpFixMapMin && bd <= mpFixMapMax:
  320. ctx = dncContainer
  321. // v = containerMap
  322. if d.h.MapType == nil {
  323. rv = reflect.MakeMap(mapIntfIntfTyp)
  324. } else {
  325. rv = reflect.MakeMap(d.h.MapType)
  326. }
  327. case bd >= mpFixExt1 && bd <= mpFixExt16, bd >= mpExt8 && bd <= mpExt32:
  328. //ctx = dncExt
  329. clen := d.readExtLen()
  330. xtag := d.r.readn1()
  331. xbs := d.r.readn(clen)
  332. var bfn func(reflect.Value, []byte) error
  333. rv, bfn = d.h.getDecodeExtForTag(xtag)
  334. if bfn == nil {
  335. // decErr("Unable to find type mapped to extension tag: %v", xtag)
  336. re := RawExt { xtag, xbs }
  337. rv = reflect.ValueOf(&re).Elem()
  338. } else if fnerr := bfn(rv, xbs); fnerr != nil {
  339. panic(fnerr)
  340. }
  341. default:
  342. decErr("Nil-Deciphered DecodeValue: %s: hex: %x, dec: %d", msgBadDesc, bd, bd)
  343. }
  344. }
  345. if ctx == dncHandled {
  346. d.bdRead = false
  347. if v != nil {
  348. rv = reflect.ValueOf(v)
  349. }
  350. }
  351. return
  352. }
  353. // int can be decoded from msgpack type: intXXX or uintXXX
  354. func (d *msgpackDecDriver) decodeInt(bitsize uint8) (i int64) {
  355. switch d.bd {
  356. case mpUint8:
  357. i = int64(uint64(d.r.readn1()))
  358. case mpUint16:
  359. i = int64(uint64(d.r.readUint16()))
  360. case mpUint32:
  361. i = int64(uint64(d.r.readUint32()))
  362. case mpUint64:
  363. i = int64(d.r.readUint64())
  364. case mpInt8:
  365. i = int64(int8(d.r.readn1()))
  366. case mpInt16:
  367. i = int64(int16(d.r.readUint16()))
  368. case mpInt32:
  369. i = int64(int32(d.r.readUint32()))
  370. case mpInt64:
  371. i = int64(d.r.readUint64())
  372. default:
  373. switch {
  374. case d.bd >= mpPosFixNumMin && d.bd <= mpPosFixNumMax:
  375. i = int64(int8(d.bd))
  376. case d.bd >= mpNegFixNumMin && d.bd <= mpNegFixNumMax:
  377. i = int64(int8(d.bd))
  378. default:
  379. decErr("Unhandled single-byte unsigned integer value: %s: %x", msgBadDesc, d.bd)
  380. }
  381. }
  382. // check overflow (logic adapted from std pkg reflect/value.go OverflowUint()
  383. if bitsize > 0 {
  384. if trunc := (i << (64 - bitsize)) >> (64 - bitsize); i != trunc {
  385. decErr("Overflow int value: %v", i)
  386. }
  387. }
  388. d.bdRead = false
  389. return
  390. }
  391. // uint can be decoded from msgpack type: intXXX or uintXXX
  392. func (d *msgpackDecDriver) decodeUint(bitsize uint8) (ui uint64) {
  393. switch d.bd {
  394. case mpUint8:
  395. ui = uint64(d.r.readn1())
  396. case mpUint16:
  397. ui = uint64(d.r.readUint16())
  398. case mpUint32:
  399. ui = uint64(d.r.readUint32())
  400. case mpUint64:
  401. ui = d.r.readUint64()
  402. case mpInt8:
  403. if i := int64(int8(d.r.readn1())); i >= 0 {
  404. ui = uint64(i)
  405. } else {
  406. decErr("Assigning negative signed value: %v, to unsigned type", i)
  407. }
  408. case mpInt16:
  409. if i := int64(int16(d.r.readUint16())); i >= 0 {
  410. ui = uint64(i)
  411. } else {
  412. decErr("Assigning negative signed value: %v, to unsigned type", i)
  413. }
  414. case mpInt32:
  415. if i := int64(int32(d.r.readUint32())); i >= 0 {
  416. ui = uint64(i)
  417. } else {
  418. decErr("Assigning negative signed value: %v, to unsigned type", i)
  419. }
  420. case mpInt64:
  421. if i := int64(d.r.readUint64()); i >= 0 {
  422. ui = uint64(i)
  423. } else {
  424. decErr("Assigning negative signed value: %v, to unsigned type", i)
  425. }
  426. default:
  427. switch {
  428. case d.bd >= mpPosFixNumMin && d.bd <= mpPosFixNumMax:
  429. ui = uint64(d.bd)
  430. case d.bd >= mpNegFixNumMin && d.bd <= mpNegFixNumMax:
  431. decErr("Assigning negative signed value: %v, to unsigned type", int(d.bd))
  432. default:
  433. decErr("Unhandled single-byte unsigned integer value: %s: %x", msgBadDesc, d.bd)
  434. }
  435. }
  436. // check overflow (logic adapted from std pkg reflect/value.go OverflowUint()
  437. if bitsize > 0 {
  438. if trunc := (ui << (64 - bitsize)) >> (64 - bitsize); ui != trunc {
  439. decErr("Overflow uint value: %v", ui)
  440. }
  441. }
  442. d.bdRead = false
  443. return
  444. }
  445. // float can either be decoded from msgpack type: float, double or intX
  446. func (d *msgpackDecDriver) decodeFloat(chkOverflow32 bool) (f float64) {
  447. switch d.bd {
  448. case mpFloat:
  449. f = float64(math.Float32frombits(d.r.readUint32()))
  450. case mpDouble:
  451. f = math.Float64frombits(d.r.readUint64())
  452. default:
  453. f = float64(d.decodeInt(0))
  454. }
  455. // check overflow (logic adapted from std pkg reflect/value.go OverflowFloat()
  456. if chkOverflow32 {
  457. f2 := f
  458. if f2 < 0 {
  459. f2 = -f
  460. }
  461. if math.MaxFloat32 < f2 && f2 <= math.MaxFloat64 {
  462. decErr("Overflow float32 value: %v", f2)
  463. }
  464. }
  465. d.bdRead = false
  466. return
  467. }
  468. // bool can be decoded from bool, fixnum 0 or 1.
  469. func (d *msgpackDecDriver) decodeBool() (b bool) {
  470. switch d.bd {
  471. case mpFalse, 0:
  472. // b = false
  473. case mpTrue, 1:
  474. b = true
  475. default:
  476. decErr("Invalid single-byte value for bool: %s: %x", msgBadDesc, d.bd)
  477. }
  478. d.bdRead = false
  479. return
  480. }
  481. func (d *msgpackDecDriver) decodeString() (s string) {
  482. clen := d.readContainerLen(msgpackContainerStr)
  483. if clen > 0 {
  484. s = string(d.r.readn(clen))
  485. }
  486. d.bdRead = false
  487. return
  488. }
  489. // Callers must check if changed=true (to decide whether to replace the one they have)
  490. func (d *msgpackDecDriver) decodeBytes(bs []byte) (bsOut []byte, changed bool) {
  491. // bytes can be decoded from msgpackContainerStr or msgpackContainerBin
  492. var clen int
  493. switch d.bd {
  494. case mpBin8, mpBin16, mpBin32:
  495. clen = d.readContainerLen(msgpackContainerBin)
  496. default:
  497. clen = d.readContainerLen(msgpackContainerStr)
  498. }
  499. // if clen < 0 {
  500. // changed = true
  501. // panic("length cannot be zero. this cannot be nil.")
  502. // }
  503. if clen > 0 {
  504. // if no contents in stream, don't update the passed byteslice
  505. if len(bs) != clen {
  506. // Return changed=true if length of passed slice diff from length of bytes in stream
  507. if len(bs) > clen {
  508. bs = bs[:clen]
  509. } else {
  510. bs = make([]byte, clen)
  511. }
  512. bsOut = bs
  513. changed = true
  514. }
  515. d.r.readb(bs)
  516. }
  517. d.bdRead = false
  518. return
  519. }
  520. // Every top-level decode funcs (i.e. decodeValue, decode) must call this first.
  521. func (d *msgpackDecDriver) initReadNext() {
  522. if d.bdRead {
  523. return
  524. }
  525. d.bd = d.r.readn1()
  526. d.bdRead = true
  527. d.bdType = detUnset
  528. }
  529. func (d *msgpackDecDriver) currentEncodedType() decodeEncodedType {
  530. if d.bdType == detUnset {
  531. bd := d.bd
  532. switch bd {
  533. case mpNil:
  534. d.bdType = detNil
  535. case mpFalse, mpTrue:
  536. d.bdType = detBool
  537. case mpFloat, mpDouble:
  538. d.bdType = detFloat
  539. case mpUint8, mpUint16, mpUint32, mpUint64:
  540. d.bdType = detUint
  541. case mpInt8, mpInt16, mpInt32, mpInt64:
  542. d.bdType = detInt
  543. default:
  544. switch {
  545. case bd >= mpPosFixNumMin && bd <= mpPosFixNumMax:
  546. d.bdType = detInt
  547. case bd >= mpNegFixNumMin && bd <= mpNegFixNumMax:
  548. d.bdType = detInt
  549. case bd == mpStr8, bd == mpStr16, bd == mpStr32, bd >= mpFixStrMin && bd <= mpFixStrMax:
  550. if d.h.RawToString {
  551. d.bdType = detString
  552. } else {
  553. d.bdType = detBytes
  554. }
  555. case bd == mpBin8, bd == mpBin16, bd == mpBin32:
  556. d.bdType = detBytes
  557. case bd == mpArray16, bd == mpArray32, bd >= mpFixArrayMin && bd <= mpFixArrayMax:
  558. d.bdType = detArray
  559. case bd == mpMap16, bd == mpMap32, bd >= mpFixMapMin && bd <= mpFixMapMax:
  560. d.bdType = detMap
  561. case bd >= mpFixExt1 && bd <= mpFixExt16, bd >= mpExt8 && bd <= mpExt32:
  562. d.bdType = detExt
  563. default:
  564. decErr("currentEncodedType: Undeciphered descriptor: %s: hex: %x, dec: %d", msgBadDesc, bd, bd)
  565. }
  566. }
  567. }
  568. return d.bdType
  569. }
  570. func (d *msgpackDecDriver) tryDecodeAsNil() bool {
  571. if d.bd == mpNil {
  572. d.bdRead = false
  573. return true
  574. }
  575. return false
  576. }
  577. func (d *msgpackDecDriver) readContainerLen(ct msgpackContainerType) (clen int) {
  578. bd := d.bd
  579. switch {
  580. case bd == mpNil:
  581. clen = -1 // to represent nil
  582. case bd == ct.b8:
  583. clen = int(d.r.readn1())
  584. case bd == ct.b16:
  585. clen = int(d.r.readUint16())
  586. case bd == ct.b32:
  587. clen = int(d.r.readUint32())
  588. case (ct.bFixMin & bd) == ct.bFixMin:
  589. clen = int(ct.bFixMin ^ bd)
  590. default:
  591. decErr("readContainerLen: %s: hex: %x, dec: %d", msgBadDesc, bd, bd)
  592. }
  593. d.bdRead = false
  594. return
  595. }
  596. func (d *msgpackDecDriver) readMapLen() int {
  597. return d.readContainerLen(msgpackContainerMap)
  598. }
  599. func (d *msgpackDecDriver) readArrayLen() int {
  600. return d.readContainerLen(msgpackContainerList)
  601. }
  602. func (d *msgpackDecDriver) readExtLen() (clen int) {
  603. switch d.bd {
  604. case mpNil:
  605. clen = -1 // to represent nil
  606. case mpFixExt1:
  607. clen = 1
  608. case mpFixExt2:
  609. clen = 2
  610. case mpFixExt4:
  611. clen = 4
  612. case mpFixExt8:
  613. clen = 8
  614. case mpFixExt16:
  615. clen = 16
  616. case mpExt8:
  617. clen = int(d.r.readn1())
  618. case mpExt16:
  619. clen = int(d.r.readUint16())
  620. case mpExt32:
  621. clen = int(d.r.readUint32())
  622. default:
  623. decErr("decoding ext bytes: found unexpected byte: %x", d.bd)
  624. }
  625. return
  626. }
  627. func (d *msgpackDecDriver) decodeExt(verifyTag bool, tag byte) (xtag byte, xbs []byte) {
  628. xbd := d.bd
  629. switch {
  630. case xbd == mpBin8, xbd == mpBin16, xbd == mpBin32:
  631. xbs, _ = d.decodeBytes(nil)
  632. case xbd == mpStr8, xbd == mpStr16, xbd == mpStr32,
  633. xbd >= mpFixStrMin && xbd <= mpFixStrMax:
  634. xbs = []byte(d.decodeString())
  635. default:
  636. clen := d.readExtLen()
  637. xtag = d.r.readn1()
  638. if verifyTag && xtag != tag {
  639. decErr("Wrong extension tag. Got %b. Expecting: %v", xtag, tag)
  640. }
  641. xbs = d.r.readn(clen)
  642. }
  643. d.bdRead = false
  644. return
  645. }
  646. //--------------------------------------------------
  647. // TimeEncodeExt encodes a time.Time as a byte slice.
  648. // Configure this to support the Time Extension, e.g. using tag 1.
  649. func (_ *MsgpackHandle) TimeEncodeExt(rv reflect.Value) (bs []byte, err error) {
  650. rvi := rv.Interface()
  651. switch iv := rvi.(type) {
  652. case time.Time:
  653. bs = encodeTime(iv)
  654. default:
  655. err = fmt.Errorf("codec/msgpack: TimeEncodeExt expects a time.Time. Received %T", rvi)
  656. }
  657. return
  658. }
  659. // TimeDecodeExt decodes a time.Time from the byte slice parameter, and sets it into the reflect value.
  660. // Configure this to support the Time Extension, e.g. using tag 1.
  661. func (_ *MsgpackHandle) TimeDecodeExt(rv reflect.Value, bs []byte) (err error) {
  662. tt, err := decodeTime(bs)
  663. if err == nil {
  664. rv.Set(reflect.ValueOf(tt))
  665. }
  666. return
  667. }
  668. func (h *MsgpackHandle) newEncDriver(w encWriter) encDriver {
  669. return &msgpackEncDriver{w: w, h: h}
  670. }
  671. func (h *MsgpackHandle) newDecDriver(r decReader) decDriver {
  672. return &msgpackDecDriver{r: r, h: h}
  673. }
  674. func (h *MsgpackHandle) writeExt() bool {
  675. return h.WriteExt
  676. }
  677. //--------------------------------------------------
  678. func (x msgpackSpecRpc) ServerCodec(conn io.ReadWriteCloser, h Handle) rpc.ServerCodec {
  679. return &msgpackSpecRpcCodec{newRPCCodec(conn, h)}
  680. }
  681. func (x msgpackSpecRpc) ClientCodec(conn io.ReadWriteCloser, h Handle) rpc.ClientCodec {
  682. return &msgpackSpecRpcCodec{newRPCCodec(conn, h)}
  683. }
  684. // /////////////// Spec RPC Codec ///////////////////
  685. func (c *msgpackSpecRpcCodec) WriteRequest(r *rpc.Request, body interface{}) error {
  686. // WriteRequest can write to both a Go service, and other services that do
  687. // not abide by the 1 argument rule of a Go service.
  688. // We discriminate based on if the body is a MsgpackSpecRpcMultiArgs
  689. var bodyArr []interface{}
  690. if m, ok := body.(MsgpackSpecRpcMultiArgs); ok {
  691. bodyArr = ([]interface{})(m)
  692. } else {
  693. bodyArr = []interface{}{body}
  694. }
  695. r2 := []interface{}{ 0, uint32(r.Seq), r.ServiceMethod, bodyArr }
  696. return c.write(r2, nil, false, true)
  697. }
  698. func (c *msgpackSpecRpcCodec) WriteResponse(r *rpc.Response, body interface{}) error {
  699. var moe interface{}
  700. if r.Error != "" {
  701. moe = r.Error
  702. }
  703. if moe != nil && body != nil {
  704. body = nil
  705. }
  706. r2 := []interface{}{ 1, uint32(r.Seq), moe, body }
  707. return c.write(r2, nil, false, true)
  708. }
  709. func (c *msgpackSpecRpcCodec) ReadResponseHeader(r *rpc.Response) error {
  710. return c.parseCustomHeader(1, &r.Seq, &r.Error)
  711. }
  712. func (c *msgpackSpecRpcCodec) ReadRequestHeader(r *rpc.Request) error {
  713. return c.parseCustomHeader(0, &r.Seq, &r.ServiceMethod)
  714. }
  715. func (c *msgpackSpecRpcCodec) ReadRequestBody(body interface{}) error {
  716. if body == nil { // read and discard
  717. return c.read(nil)
  718. }
  719. bodyArr := []interface{}{body}
  720. return c.read(&bodyArr)
  721. }
  722. func (c *msgpackSpecRpcCodec) parseCustomHeader(expectTypeByte byte, msgid *uint64, methodOrError *string) (err error) {
  723. // We read the response header by hand
  724. // so that the body can be decoded on its own from the stream at a later time.
  725. bs := make([]byte, 1)
  726. n, err := c.rwc.Read(bs)
  727. if err != nil {
  728. return
  729. }
  730. if n != 1 {
  731. err = fmt.Errorf("Couldn't read array descriptor: No bytes read")
  732. return
  733. }
  734. const fia byte = 0x94 //four item array descriptor value
  735. if bs[0] != fia {
  736. err = fmt.Errorf("Unexpected value for array descriptor: Expecting %v. Received %v", fia, bs[0])
  737. return
  738. }
  739. var b byte
  740. if err = c.read(&b); err != nil {
  741. return
  742. }
  743. if b != expectTypeByte {
  744. err = fmt.Errorf("Unexpected byte descriptor in header. Expecting %v. Received %v", expectTypeByte, b)
  745. return
  746. }
  747. if err = c.read(msgid); err != nil {
  748. return
  749. }
  750. if err = c.read(methodOrError); err != nil {
  751. return
  752. }
  753. return
  754. }