X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=chunk_queue.h;h=9959b74cdf8a33f3bddc4bdad04bb49b2f6001b2;hp=a902ee059c3dbc215932b40b9bcc46129ad9ade5;hb=8ec331c7d880185b4931ac46e2c5c34dd36a8f84;hpb=c8862b9e246b4ef6ff1fe103946e18cf2537ecde diff --git a/chunk_queue.h b/chunk_queue.h index a902ee05..9959b74c 100644 --- a/chunk_queue.h +++ b/chunk_queue.h @@ -9,10 +9,10 @@ struct chunk_queue; struct queued_chunk; -int cq_enqueue(struct chunk_queue *cq, long unsigned chunk_num, size_t sent); +int cq_enqueue(struct chunk_queue *cq, const char *buf, size_t num_bytes); struct queued_chunk *cq_peek(struct chunk_queue *cq); void cq_dequeue(struct chunk_queue *cq); void cq_update(struct chunk_queue *cq, size_t sent); -int cq_get(struct queued_chunk *qc, char **buf, size_t *len); +int cq_get(struct queued_chunk *qc, const char **buf, size_t *len); struct chunk_queue *cq_new(size_t max_pending); void cq_destroy(struct chunk_queue *cq);