/*
- * Copyright (C) 2007 Andre Noll <maan@systemlinux.org>
+ * Copyright (C) 2007-2008 Andre Noll <maan@systemlinux.org>
*
* Licensed under the GPL v2. For licencing details see COPYING.
*/
#include "para.h"
#include "list.h"
+#include "afh.h"
#include "vss.h"
#include "string.h"
#include "error.h"
* allows them to enqueue chunks if they can not be sent out immediately.
*
* Chunk queues are "cheap" in the sense that only reference to the audio file
- * data is stored, but not the data itsself.
+ * data is stored, but not the data itself.
*/
struct chunk_queue {
/** The list of pending chunks for this client. */
struct list_head q;
/** The number of pending bytes for this client. */
unsigned long num_pending;
- /** Enqueueing more than that many bytes is an error. */
+ /** More than that many bytes in the queue is considered an error. */
unsigned long max_pending;
};
if (ret < 0)
return ret;
} else
- buf = vss_get_header(&len);
+ vss_get_header(&buf, &len);
if (cq->num_pending + len > cq->max_pending)
return -E_QUEUE;
qc = para_malloc(sizeof(struct queued_chunk));
*
* \param cq The chunk queue.
*
- * \return The next queued chunk, or \p NULL if there is no chunk awailable.
+ * \return The next queued chunk, or \p NULL if there is no chunk available.
*/
struct queued_chunk *cq_peek(struct chunk_queue *cq)
{
}
/**
- * Change the number of bytes send for the current queued chunk.
+ * Change the number of bytes sent for the current queued chunk.
*
* \param cq The chunk queue.
* \param sent Number of bytes successfully sent.
if (ret < 0)
return ret;
} else
- *buf = vss_get_header(len);
+ vss_get_header(buf, len);
assert(*len > qc->sent);
*buf += qc->sent;
*len -= qc->sent;