Commit 8c692c11 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent bbdcf0b0
...@@ -63,14 +63,15 @@ func pktEncodeZ(m msg) *pktBuf { ...@@ -63,14 +63,15 @@ func pktEncodeZ(m msg) *pktBuf {
pkb := allocPkb() pkb := allocPkb()
p := pickle.NewEncoder(pkb) p := pickle.NewEncoder(pkb)
// tuple -> pickle.Tuple /*
// tuple -> pickle.Tuple XXX needed? (should be produced by enc.Tuple)
arg := m.arg arg := m.arg
tup, ok := arg.(tuple) tup, ok := arg.(tuple)
if ok { if ok {
arg = pickle.Tuple(tup) arg = pickle.Tuple(tup)
} }
*/
err := p.Encode(pickle.Tuple{m.msgid, m.flags, m.method, arg}) err := p.Encode(pickle.Tuple{m.msgid, m.flags, m.method, m.arg})
if err != nil { if err != nil {
panic(err) // all our types are expected to be supported by pickle panic(err) // all our types are expected to be supported by pickle
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment