ivampiresp/Spdk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

blob: add _spdk_bs_allocate_cluster function

Browse Source 
Signed-off-by: Maciej Szwed <maciej.szwed@intel.com>
Change-Id: I35779dc547e0c084086ec6d9bf44f86850cb7f05
Reviewed-on: https://review.gerrithub.io/393780
Reviewed-by: Jim Harris <james.r.harris@intel.com>
Tested-by: SPDK Automated Test System <sys_sgsw@intel.com>
Reviewed-by: Ben Walker <benjamin.walker@intel.com>
This commit is contained in:
Maciej Szwed 2018-01-05 13:23:31 +01:00 committed by Jim Harris
parent bd4c63b317
commit bf2d02b6ef
1 changed files with 19 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
lib/blob/blobstore.c
View File

@ -70,6 +70,24 @@ _spdk_bs_claim_cluster(struct spdk_blob_store *bs, uint32_t cluster_num)
bs->num_free_clusters--; bs->num_free_clusters--;
} }
static int
_spdk_bs_allocate_cluster(struct spdk_blob_data *blob, uint32_t cluster_num,
uint64_t *lowest_free_cluster)
{
*lowest_free_cluster = spdk_bit_array_find_first_clear(blob->bs->used_clusters,
*lowest_free_cluster);
if (*lowest_free_cluster >= blob->bs->total_clusters) {
/* No more free clusters. Cannot satisfy the request */
return -ENOSPC;
}
SPDK_DEBUGLOG(SPDK_LOG_BLOB, "Claiming cluster %lu for blob %lu\n", *lowest_free_cluster, blob->id);
_spdk_bs_claim_cluster(blob->bs, *lowest_free_cluster);
blob->active.clusters[cluster_num] = _spdk_bs_cluster_to_lba(blob->bs, *lowest_free_cluster);
return 0;
}
static void static void
_spdk_bs_release_cluster(struct spdk_blob_store *bs, uint32_t cluster_num) _spdk_bs_release_cluster(struct spdk_blob_store *bs, uint32_t cluster_num)
{ {
@ -1068,10 +1086,7 @@ _spdk_resize_blob(struct spdk_blob_data *blob, uint64_t sz)
if (spdk_blob_is_thin_provisioned(blob) == false) { if (spdk_blob_is_thin_provisioned(blob) == false) {
lfc = 0; lfc = 0;
for (i = num_clusters; i < sz; i++) { for (i = num_clusters; i < sz; i++) {
lfc = spdk_bit_array_find_first_clear(bs->used_clusters, lfc); _spdk_bs_allocate_cluster(blob, i, &lfc);
SPDK_DEBUGLOG(SPDK_LOG_BLOB, "Claiming cluster %lu for blob %lu\n", lfc, blob->id);
_spdk_bs_claim_cluster(bs, lfc);
blob->active.clusters[i] = _spdk_bs_cluster_to_lba(bs, lfc);
lfc++; lfc++;
} }
} }