#include "pstream.h"
#include "queue.h"
#include "xmalloc.h"
+#include "log.h"
enum pa_pstream_descriptor_index {
PA_PSTREAM_DESCRIPTOR_LENGTH,
struct item_info *i;
assert(p && packet);
- /*fprintf(stderr, "push-packet %p\n", packet);*/
+ /*pa_log(__FILE__": push-packet %p\n", packet);*/
i = pa_xmalloc(sizeof(struct item_info));
i->type = PA_PSTREAM_ITEM_PACKET;
p->write.index = 0;
if (p->write.current->type == PA_PSTREAM_ITEM_PACKET) {
- /*fprintf(stderr, "pop-packet %p\n", p->write.current->packet);*/
+ /*pa_log(__FILE__": pop-packet %p\n", p->write.current->packet);*/
assert(p->write.current->packet);
p->write.data = p->write.current->packet->data;
/* Frame size too large */
if (ntohl(p->read.descriptor[PA_PSTREAM_DESCRIPTOR_LENGTH]) > FRAME_SIZE_MAX) {
- fprintf(stderr, "frame size too large\n");
+ pa_log(__FILE__": Frame size too large\n");
goto die;
}