Archipelago

		if (bucket_readable(ce->status[i]))

			continue;

		if (ce->status[i] != LOADING){

			start_bucket = i;

			end_bucket = __get_next_invalid(ce, start_bucket, limit);

			i = end_bucket;

	}

	if (pending_buckets) {

		/* Do not put cache entry yet */

		cio->work.job_fn = handle_read;

		cio->work.job = pr;

	 * In this context we hold a reference to the cache entry and

	 * the assocciated lock

	 */

	struct req_completion *rc = (struct req_completion *)arg;

	struct peer_req *pr = rc->pr;

	for (i = start; i <= end; i++) {

		if (ce->status[i] == LOADING){

			if (success){

				memcpy(ce->data+(i*cached->bucket_size), data,

						cached->bucket_size);

				ce->status[i] = VALID;

			}

			else {

				//reset status

				XSEGLOG2(&lc, E, "Before ce %p, i %lu, ce->status[i] %u", ce, i, ce->status[i]);

				ce->status[i] = INVALID;

		}

	}

	free(rc);

}

void complete_write(void *arg)

static int handle_receive_read(struct peerd *peer, struct peer_req *pr,

			struct xseg_request *req)

{

	/*

	 * Should be rentrant

	 */

		free(rc);

		//TODO WHAT?

	}

	return 0;

}