5 ### (c) 2005 Straylight/Edgeware
8 ###----- Licensing notice ---------------------------------------------------
10 ### This file is part of the Python interface to mLib.
12 ### mLib/Python is free software; you can redistribute it and/or modify
13 ### it under the terms of the GNU General Public License as published by
14 ### the Free Software Foundation; either version 2 of the License, or
15 ### (at your option) any later version.
17 ### mLib/Python is distributed in the hope that it will be useful,
18 ### but WITHOUT ANY WARRANTY; without even the implied warranty of
19 ### MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
20 ### GNU General Public License for more details.
22 ### You should have received a copy of the GNU General Public License
23 ### along with mLib/Python; if not, write to the Free Software Foundation,
24 ### Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
26 cdef class PacketBuffer:
30 def __cinit__(me, packetproc = None, eofproc = None, *hunoz, **hukairz):
31 pkbuf_init(&me.pk, _pkfunc, <void *>me)
32 me._packet = _checkcallable(packetproc, 'packet proc')
33 me._eof = _checkcallable(eofproc, 'eof proc')
38 return _tobool(me.pk.f & PKBUF_ENABLE)
42 def __set__(me, want):
44 raise TypeError, 'want must be positive'
45 pkbuf_want(&me.pk, pk)
49 def __set__(me, proc):
50 me._line = _checkcallable(proc, 'packet proc')
56 def __set__(me, proc):
57 me._eof = _checkcallable(proc, 'eof proc')
61 if me.pk.f & PKBUF_ENABLE:
62 raise ValueError, 'already enabled'
63 me.pk.f = me.pk.f | PKBUF_ENABLE
67 if not (me.pk.f & PKBUF_ENABLE):
68 raise ValueError, 'already disabled'
69 me.pk.f = me.pk.f & ~PKBUF_ENABLE
73 if not (me.pk.f & PKBUF_ENABLE):
74 raise ValueError, 'buffer disabled'
80 return pkbuf_free(&me.pk, &p)
86 PyObject_AsReadBuffer(str, <cvp *>&p, &len)
88 n = pkbuf_free(&me.pk, &q)
94 if not (me.pk.f & PKBUF_ENABLE):
96 pkbuf_flush(&me.pk, q, n)
97 return PyString_FromStringAndSize(<char *>p, len)
103 return _maybecall(me._packet, (pk,))
105 return _maybecall(me._eof, ())
107 cdef void _pkfunc(unsigned char *p, size_t n, pkbuf *pk,
108 size_t *keep, void *arg):
112 pb = <PacketBuffer>arg
116 r = pb.packet(PyString_FromStringAndSize(<char *>p, n))
118 PyObject_AsReadBuffer(r, <cvp *>&rp, &rn)
120 raise ValueError, 'remaining buffer too large'
122 memcpy(p + n - rn, rp, rn)
125 ###----- That's all, folks --------------------------------------------------