X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=chunk_queue.h;h=2bed999cec5ecadc17b791db4a6ae85da78158ce;hp=6d981a31be7c94228f2e1a35b84571325d5a8bb9;hb=1e89a35b86480c4bbcb143e88417707e15217f1a;hpb=2ecabb05dbeb0948e514cdad1bb811d9edf97e2e diff --git a/chunk_queue.h b/chunk_queue.h index 6d981a31..2bed999c 100644 --- a/chunk_queue.h +++ b/chunk_queue.h @@ -1,5 +1,5 @@ /* - * Copyright (C) 2007 Andre Noll + * Copyright (C) 2007-2009 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);