[v3,4/5] ceph: register map callback to handle ENOSPC conditions

Commit Message

Jeff Layton Feb. 7, 2017, 12:28 p.m. UTC

Signed-off-by: Jeff Layton <[e-mail]>
---
 fs/ceph/mds_client.c | 13 +++++++++++++
 1 file changed, 13 insertions(+)

Patch

diff --git a/fs/ceph/mds_client.c b/fs/ceph/mds_client.c
index 93fc893e1930..fcf1e5313c16 100644
--- a/fs/ceph/mds_client.c
+++ b/fs/ceph/mds_client.c
@@ -433,6 +433,18 @@  static int __verify_registered_session(struct ceph_mds_client *mdsc,
 	return 0;
 }
 
+static void handle_osd_map(struct ceph_osd_client *osdc)
+{
+	u32 cancelled_epoch;
+
+	lockdep_assert_held(&osdc->lock);
+
+	cancelled_epoch = ceph_osdc_abort_on_full(osdc);
+	if (cancelled_epoch)
+		osdc->epoch_barrier = max(cancelled_epoch + 1,
+					  osdc->epoch_barrier);
+}
+
 /*
  * create+register a new session for given mds.
  * called under mdsc->mutex.
@@ -3485,6 +3497,7 @@  int ceph_mdsc_init(struct ceph_fs_client *fsc)
 
 	ceph_caps_init(mdsc);
 	ceph_adjust_min_caps(mdsc, fsc->min_caps);
+	fsc->client->osdc.map_cb = handle_osd_map;
 
 	init_rwsem(&mdsc->pool_perm_rwsem);
 	mdsc->pool_perm_tree = RB_ROOT;