lib/tenaciousd/queue.c

24   STORAGE_VSIC_ROUND(queue->vsic, sizeof(struct queue_header))
27   STORAGE_VSIC_ROUND(queue->vsic, sizeof(struct tenaciousd_queue_element))
47       storage_malloc(queue->vsic, sizeof(struct tenaciousd_queue_element));
51     errval_t err = queue->vsic->ops.read(queue->vsic, queue->vsa, offset,
54     err = queue->vsic->ops.wait(queue->vsic);
76     element = storage_realloc(queue->vsic, element,
79     err = queue->vsic->ops.read(queue->vsic, queue->vsa,
84     err = queue->vsic->ops.wait(queue->vsic);
101   storage_free(queue->vsic, element);
106 					  struct storage_vsic *vsic)
109   assert(vsic != NULL);
116   queue->vsic = vsic;
119   struct queue_header *header = storage_alloca(vsic, sizeof(struct queue_header));
121   errval_t err = vsic->ops.read(vsic, vsa, 0,
124   err = vsic->ops.wait(vsic);
129     assert(header->blocksize == vsic->blocksize);
131     queue->end = STORAGE_VSIC_ROUND(vsic, sizeof(struct queue_header));
147 	//     queue->end += STORAGE_VSIC_ROUND(log->vsic, element->size + sizeof(struct tenaciousd_queue_element));
157     header->blocksize = vsic->blocksize;
158     header->end = STORAGE_VSIC_ROUND(vsic, sizeof(struct queue_header));
163   err = vsic->ops.write(vsic, vsa, 0, sizeof(struct queue_header), header);
165   err = vsic->ops.flush(vsic, vsa);
167   err = vsic->ops.wait(vsic);
180   errval_t err = queue->vsic->ops.flush(queue->vsic, queue->vsa);
185       storage_alloca(queue->vsic, sizeof(struct queue_header));
192   header->blocksize = queue->vsic->blocksize;
196   err = queue->vsic->ops.write(queue->vsic, queue->vsa, 0, sizeof(struct queue_header), header);
198   err = queue->vsic->ops.flush(queue->vsic, queue->vsa);
200   err = queue->vsic->ops.wait(queue->vsic);
213     struct tenaciousd_queue_element *element = storage_malloc(queue->vsic, *size);
216     //    *size = STORAGE_VSIC_ROUND(queue->vsic, *size)
227   struct storage_vsic *vsic = queue->vsic;
233     STORAGE_VSIC_ROUND(vsic, element->size + sizeof(struct tenaciousd_queue_element));
238   return queue->vsic->ops.
239     write(vsic, queue->vsa, end,
255   queue->end -= STORAGE_VSIC_ROUND(queue->vsic, element->size + sizeof(struct tenaciousd_queue_element));
258   queue->vsic->ops.write(queue->vsic, queue->vsa, last, sizeof(struct tenaciousd_queue_element), element);