113 #define GETBYTE(pf, dst) \
116 int __res = pullf_read_fixed(pf, 1, &__b); \
static void PGresult * res
MBuf * mbuf_create_from_data(uint8 *data, int len)
int pullf_read_fixed(PullFilter *src, int len, uint8 *dst)
int pullf_create(PullFilter **pf_p, const PullFilterOps *op, void *init_arg, PullFilter *src)
int pushf_write(PushFilter *mp, const uint8 *data, int len)
int mbuf_avail(MBuf *mbuf)
int pushf_create(PushFilter **mp_p, const PushFilterOps *op, void *init_arg, PushFilter *next)
int pullf_read_max(PullFilter *pf, int len, uint8 **data_p, uint8 *tmpbuf)
int mbuf_free(MBuf *mbuf)
int pullf_create_mbuf_reader(PullFilter **mp_p, MBuf *src)
int mbuf_append(MBuf *dst, const uint8 *buf, int len)
int pullf_read(PullFilter *pf, int len, uint8 **data_p)
int pushf_create_mbuf_writer(PushFilter **res, MBuf *dst)
int mbuf_steal_data(MBuf *mbuf, uint8 **data_p)
void pushf_free_all(PushFilter *mp)
int pushf_flush(PushFilter *mp)
int mbuf_size(MBuf *mbuf)
int mbuf_grab(MBuf *mbuf, int len, uint8 **data_p)
void pushf_free(PushFilter *mp)
void pullf_free(PullFilter *pf)
MBuf * mbuf_create(int len)
int(* init)(void **priv_p, void *init_arg, PullFilter *src)
int(* pull)(void *priv, PullFilter *src, int len, uint8 **data_p, uint8 *buf, int buflen)
int(* flush)(PushFilter *next, void *priv)
int(* init)(PushFilter *next, void *init_arg, void **priv_p)
int(* push)(PushFilter *next, void *priv, const uint8 *src, int len)
static StringInfoData tmpbuf