Stowage/msgpack-python
2
0
Fork 0
mirror of https://github.com/msgpack/msgpack-python.git synced 2025-10-26 15:14:10 +00:00
Code Issues Projects Releases Packages Wiki Activity

free buffer when packer deleted.

Browse source
This commit is contained in:
Naoki INADA 2009-06-09 13:12:29 +09:00
parent a06a5ce46f
commit 85b68fbf8c
2 changed files with 437 additions and 225 deletions
Download patch file Download diff file Expand all files Collapse all files

653
msgpack.c
View file

File diff suppressed because it is too large Load diff

9
msgpack.pyx
View file

@ -59,6 +59,8 @@ cdef class Packer:
msgpack_packer_init(&self.pk, <void*>self, <msgpack_packer_write>_packer_write) msgpack_packer_init(&self.pk, <void*>self, <msgpack_packer_write>_packer_write)
def __del__(self):
free(self.buff);
def flush(self): def flush(self):
"""Flash local buffer and output stream if it has 'flush()' method.""" """Flash local buffer and output stream if it has 'flush()' method."""
@ -98,7 +100,7 @@ cdef class Packer:
""" """
msgpack_pack_map(&self.pk, len) msgpack_pack_map(&self.pk, len)
def pack(self, object o): cdef __pack(self, object o):
cdef long long intval cdef long long intval
cdef double fval cdef double fval
cdef char* rawval cdef char* rawval
@ -140,6 +142,11 @@ cdef class Packer:
# TODO: Serialize with defalt() like simplejson. # TODO: Serialize with defalt() like simplejson.
raise TypeError, "can't serialize %r" % (o,) raise TypeError, "can't serialize %r" % (o,)
def pack(self, obj, flush=True):
self.__pack(obj)
if flush:
self.flush()
cdef int _packer_write(Packer packer, const_char_ptr b, unsigned int l): cdef int _packer_write(Packer packer, const_char_ptr b, unsigned int l):
if packer.length + l > packer.allocated: if packer.length + l > packer.allocated:
if packer.length > 0: if packer.length > 0: