<div><span style="color: rgb(160, 160, 168); ">On Tuesday, January 29, 2013 at 11:35 AM, Eric Windisch wrote:</span></div>
                <blockquote type="cite" style="border-left-style:solid;border-width:1px;margin-left:0px;padding-left:10px;">
                    <span><blockquote type="cite"><div><br></div><div>Russell did originally add a config option to allow enabling the new</div><div>format, but I said:</div><div><br></div><div>Why would a user choose to enable the new format now? Isn't there</div><div>basically no benefit until we start using the new format to do</div><div>something interesting in H?</div></blockquote><div><br></div><div><br></div><div><br></div><div>Perhaps my concern come late, but I do have an outstanding question if the new envelope format is really a good thing, as presently designed.</div><div><br></div><div>Message signing requires that the signed message is a string including at least some bits being serialized. That message will need to include the actual message_data, but also the topic, a timestamp, ttl, etc. These are pieces that will need to become part of the envelope. They need to be either serialized along with the message data or concatenated with the message data to be signed. Serializing these pieces together seems far more optimal. However, keep in mind that the message signature chain will need to be separate.</div><div><br></div><div>Furthermore, the code currently double-serializes all the content. Kombu serializes data with JSON transparently, unless told otherwise, and the same is done with ZeroMQ. At least with ZeroMQ, if the array is convertable via bytes(), then we can send it without the double serialization, but the envelope is currently a dict, so the double-serialization is still required... I'm not so certain if we can avoid it for Kombu, but I do know the default JSON serialization can be disabled.</div><div><br></div><div>Additionally, unless the envelope is an array that can be converted to bytes(), the ZeroMQ driver will continue to require a driver-specific envelope around the generic RPC envelope for purposes of performance.</div><div></div></span></blockquote><div><div><div><br></div><div>Upon further consideration, if the ZeroMQ driver will need to do its own serialization/deserialization anyway, then one viable option as part of that effort is to flatten the RPC envelope into an array (assuming it remains a dict). There could be issues if any values are introduced that are not byte() compatible, such as lists or dictionaries. However, this would avoid the ZeroMQ driver needing a separate envelope or doing a second json.dumps()/loads(), as the array zipping would be sufficient.  Performance wise, flattening and recombining an array is significantly faster than serializing/deserializing JSON.</div><div><br></div><div>This seems a legitimate (ab)use since the rpc drivers are left to do their own serialization/deserialization and they all do it at present, albeit to JSON.</div><div><br></div><div>This would be done with something like (pseudo-code):</div><div><div><div><br></div><div><span style="font-family: 'Courier New'; ">""" Sender """</span></div><div><font face="'Courier New'">rpc_envelope = rpc_common.serialize_msg(orig_msg)</font></div></div></div><div><font face="'Courier New'">zmq_msg = reduce(lambda x,y: x + y, zip(rpc_envelope.keys(), map(bytes, rpc_envelope.values()))</font></div><div><font face="'Courier New'">zmq.send(*zmq_msg)</font></div><div><font face="'Courier New'"><br></font></div><div><font face="'Courier New'">""" Receiver """</font></div><div><font face="'Courier New'">zmq_msg = zmq.recv()</font></div><div><font face="'Courier New'">rpc_envelope = zip([ zmq_msg[z] for z in range(len(zmq_msg)) if z % 2 == 0 ],</font></div><div><font face="'Courier New'">                   [ zmq_msg[z] for z in range(len(zmq_msg)) if z % 2 == 1 ])</font></div><div><div><font face="'Courier New'">orig_msg = rpc_common.deserialize_msg(rpc_envelope)</font></div></div><div><br></div><div><br></div><div>Regards,</div><div>Eric Windisch</div></div>
                </div>