X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=chunk_queue.h;h=bcd43f8e98c0b8368c60b706ad66f6ce49cd7a7a;hp=a902ee059c3dbc215932b40b9bcc46129ad9ade5;hb=3150a0caa27a34d44556fb77f4a5aebc3d978580;hpb=c8862b9e246b4ef6ff1fe103946e18cf2537ecde diff --git a/chunk_queue.h b/chunk_queue.h index a902ee05..bcd43f8e 100644 --- a/chunk_queue.h +++ b/chunk_queue.h @@ -1,5 +1,5 @@ /* - * Copyright (C) 2007-2008 Andre Noll + * Copyright (C) 2007-2011 Andre Noll * * Licensed under the GPL v2. For licencing details see COPYING. */ @@ -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);