github/ocf
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Update metadata in passive mode

Browse Source 
Signed-off-by: Robert Baldyga <robert.baldyga@intel.com>
This commit is contained in:
Robert Baldyga 2021-09-03 14:51:51 +02:00
parent 9b3a0c968e
commit e23342cb0e
1 changed files with 34 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
src/ocf_cache.c
View File

@ -251,6 +251,7 @@ void *ocf_cache_get_priv(ocf_cache_t cache)
struct ocf_cache_volume_io_priv { struct ocf_cache_volume_io_priv {
struct ocf_io *io; struct ocf_io *io;
struct ctx_data_t *data; struct ctx_data_t *data;
env_atomic remaining;
}; };
struct ocf_cache_volume { struct ocf_cache_volume {
@ -266,8 +267,14 @@ static inline ocf_cache_t ocf_volume_to_cache(ocf_volume_t volume)
static void ocf_cache_volume_io_complete(struct ocf_io *vol_io, int error) static void ocf_cache_volume_io_complete(struct ocf_io *vol_io, int error)
{ {
struct ocf_cache_volume_io_priv *priv;
struct ocf_io *io = vol_io->priv1; struct ocf_io *io = vol_io->priv1;
priv = ocf_io_get_priv(io);
if (env_atomic_dec_return(&priv->remaining))
return;
ocf_io_put(vol_io); ocf_io_put(vol_io);
ocf_io_end(io, error); ocf_io_end(io, error);
} }
@ -306,9 +313,16 @@ static int ocf_cache_volume_prepare_vol_io(struct ocf_io *io,
static void ocf_cache_volume_submit_io(struct ocf_io *io) static void ocf_cache_volume_submit_io(struct ocf_io *io)
{ {
struct ocf_cache_volume_io_priv *priv;
struct ocf_io *vol_io; struct ocf_io *vol_io;
ocf_cache_t cache;
int result; int result;
cache = ocf_volume_to_cache(ocf_io_get_volume(io));
priv = ocf_io_get_priv(io);
env_atomic_set(&priv->remaining, 2);
result = ocf_cache_volume_prepare_vol_io(io, &vol_io); result = ocf_cache_volume_prepare_vol_io(io, &vol_io);
if (result) { if (result) {
ocf_io_end(io, result); ocf_io_end(io, result);
@ -316,14 +330,30 @@ static void ocf_cache_volume_submit_io(struct ocf_io *io)
} }
ocf_volume_submit_io(vol_io); ocf_volume_submit_io(vol_io);
result = ocf_metadata_passive_update(cache, io);
if (result) {
ocf_cache_log(cache, log_crit,
"Metadata update error (error=%d)!\n", result);
}
if (env_atomic_dec_return(&priv->remaining))
return;
ocf_io_put(vol_io);
ocf_io_end(io, 0);
} }
static void ocf_cache_volume_submit_flush(struct ocf_io *io) static void ocf_cache_volume_submit_flush(struct ocf_io *io)
{ {
struct ocf_cache_volume_io_priv *priv;
struct ocf_io *vol_io; struct ocf_io *vol_io;
int result; int result;
priv = ocf_io_get_priv(io);
env_atomic_set(&priv->remaining, 1);
result = ocf_cache_volume_prepare_vol_io(io, &vol_io); result = ocf_cache_volume_prepare_vol_io(io, &vol_io);
if (result) { if (result) {
ocf_io_end(io, result); ocf_io_end(io, result);
@ -336,9 +366,13 @@ static void ocf_cache_volume_submit_flush(struct ocf_io *io)
static void ocf_cache_volume_submit_discard(struct ocf_io *io) static void ocf_cache_volume_submit_discard(struct ocf_io *io)
{ {
struct ocf_cache_volume_io_priv *priv;
struct ocf_io *vol_io; struct ocf_io *vol_io;
int result; int result;
priv = ocf_io_get_priv(io);
env_atomic_set(&priv->remaining, 1);
result = ocf_cache_volume_prepare_vol_io(io, &vol_io); result = ocf_cache_volume_prepare_vol_io(io, &vol_io);
if (result) { if (result) {
ocf_io_end(io, result); ocf_io_end(io, result);