Commit ad5255c1 authored by Xiubo Li's avatar Xiubo Li Committed by Ilya Dryomov

ceph: misc fix for code style and logs

To make the logs more readable such as for log likes:

ceph: will move 00000000a42b796b to split realm 100000003ed 000000007146df45

With this it will always show the inode numbers instead the inode
addresses.
Signed-off-by: default avatarXiubo Li <xiubli@redhat.com>
Reviewed-by: default avatarJeff Layton <jlayton@kernel.org>
Signed-off-by: default avatarIlya Dryomov <idryomov@gmail.com>
parent 1ab36c9d
...@@ -137,7 +137,7 @@ static struct ceph_snap_realm *ceph_create_snap_realm( ...@@ -137,7 +137,7 @@ static struct ceph_snap_realm *ceph_create_snap_realm(
__insert_snap_realm(&mdsc->snap_realms, realm); __insert_snap_realm(&mdsc->snap_realms, realm);
mdsc->num_snap_realms++; mdsc->num_snap_realms++;
dout("create_snap_realm %llx %p\n", realm->ino, realm); dout("%s %llx %p\n", __func__, realm->ino, realm);
return realm; return realm;
} }
...@@ -161,7 +161,7 @@ static struct ceph_snap_realm *__lookup_snap_realm(struct ceph_mds_client *mdsc, ...@@ -161,7 +161,7 @@ static struct ceph_snap_realm *__lookup_snap_realm(struct ceph_mds_client *mdsc,
else if (ino > r->ino) else if (ino > r->ino)
n = n->rb_right; n = n->rb_right;
else { else {
dout("lookup_snap_realm %llx %p\n", r->ino, r); dout("%s %llx %p\n", __func__, r->ino, r);
return r; return r;
} }
} }
...@@ -189,7 +189,7 @@ static void __destroy_snap_realm(struct ceph_mds_client *mdsc, ...@@ -189,7 +189,7 @@ static void __destroy_snap_realm(struct ceph_mds_client *mdsc,
{ {
lockdep_assert_held_write(&mdsc->snap_rwsem); lockdep_assert_held_write(&mdsc->snap_rwsem);
dout("__destroy_snap_realm %p %llx\n", realm, realm->ino); dout("%s %p %llx\n", __func__, realm, realm->ino);
rb_erase(&realm->node, &mdsc->snap_realms); rb_erase(&realm->node, &mdsc->snap_realms);
mdsc->num_snap_realms--; mdsc->num_snap_realms--;
...@@ -302,9 +302,8 @@ static int adjust_snap_realm_parent(struct ceph_mds_client *mdsc, ...@@ -302,9 +302,8 @@ static int adjust_snap_realm_parent(struct ceph_mds_client *mdsc,
if (IS_ERR(parent)) if (IS_ERR(parent))
return PTR_ERR(parent); return PTR_ERR(parent);
} }
dout("adjust_snap_realm_parent %llx %p: %llx %p -> %llx %p\n", dout("%s %llx %p: %llx %p -> %llx %p\n", __func__, realm->ino,
realm->ino, realm, realm->parent_ino, realm->parent, realm, realm->parent_ino, realm->parent, parentino, parent);
parentino, parent);
if (realm->parent) { if (realm->parent) {
list_del_init(&realm->child_item); list_del_init(&realm->child_item);
ceph_put_snap_realm(mdsc, realm->parent); ceph_put_snap_realm(mdsc, realm->parent);
...@@ -360,9 +359,8 @@ static int build_snap_context(struct ceph_snap_realm *realm, ...@@ -360,9 +359,8 @@ static int build_snap_context(struct ceph_snap_realm *realm,
realm->cached_context->seq == realm->seq && realm->cached_context->seq == realm->seq &&
(!parent || (!parent ||
realm->cached_context->seq >= parent->cached_context->seq)) { realm->cached_context->seq >= parent->cached_context->seq)) {
dout("build_snap_context %llx %p: %p seq %lld (%u snaps)" dout("%s %llx %p: %p seq %lld (%u snaps) (unchanged)\n",
" (unchanged)\n", __func__, realm->ino, realm, realm->cached_context,
realm->ino, realm, realm->cached_context,
realm->cached_context->seq, realm->cached_context->seq,
(unsigned int)realm->cached_context->num_snaps); (unsigned int)realm->cached_context->num_snaps);
return 0; return 0;
...@@ -401,9 +399,8 @@ static int build_snap_context(struct ceph_snap_realm *realm, ...@@ -401,9 +399,8 @@ static int build_snap_context(struct ceph_snap_realm *realm,
sort(snapc->snaps, num, sizeof(u64), cmpu64_rev, NULL); sort(snapc->snaps, num, sizeof(u64), cmpu64_rev, NULL);
snapc->num_snaps = num; snapc->num_snaps = num;
dout("build_snap_context %llx %p: %p seq %lld (%u snaps)\n", dout("%s %llx %p: %p seq %lld (%u snaps)\n", __func__, realm->ino,
realm->ino, realm, snapc, snapc->seq, realm, snapc, snapc->seq, (unsigned int) snapc->num_snaps);
(unsigned int) snapc->num_snaps);
ceph_put_snap_context(realm->cached_context); ceph_put_snap_context(realm->cached_context);
realm->cached_context = snapc; realm->cached_context = snapc;
...@@ -420,8 +417,7 @@ static int build_snap_context(struct ceph_snap_realm *realm, ...@@ -420,8 +417,7 @@ static int build_snap_context(struct ceph_snap_realm *realm,
ceph_put_snap_context(realm->cached_context); ceph_put_snap_context(realm->cached_context);
realm->cached_context = NULL; realm->cached_context = NULL;
} }
pr_err("build_snap_context %llx %p fail %d\n", realm->ino, pr_err("%s %llx %p fail %d\n", __func__, realm->ino, realm, err);
realm, err);
return err; return err;
} }
...@@ -455,7 +451,7 @@ static void rebuild_snap_realms(struct ceph_snap_realm *realm, ...@@ -455,7 +451,7 @@ static void rebuild_snap_realms(struct ceph_snap_realm *realm,
} }
last = build_snap_context(_realm, &realm_queue, dirty_realms); last = build_snap_context(_realm, &realm_queue, dirty_realms);
dout("rebuild_snap_realms %llx %p, %s\n", _realm->ino, _realm, dout("%s %llx %p, %s\n", __func__, _realm->ino, _realm,
last > 0 ? "is deferred" : !last ? "succeeded" : "failed"); last > 0 ? "is deferred" : !last ? "succeeded" : "failed");
/* is any child in the list ? */ /* is any child in the list ? */
...@@ -551,12 +547,14 @@ static void ceph_queue_cap_snap(struct ceph_inode_info *ci, ...@@ -551,12 +547,14 @@ static void ceph_queue_cap_snap(struct ceph_inode_info *ci,
as no new writes are allowed to start when pending, so any as no new writes are allowed to start when pending, so any
writes in progress now were started before the previous writes in progress now were started before the previous
cap_snap. lucky us. */ cap_snap. lucky us. */
dout("queue_cap_snap %p already pending\n", inode); dout("%s %p %llx.%llx already pending\n",
__func__, inode, ceph_vinop(inode));
goto update_snapc; goto update_snapc;
} }
if (ci->i_wrbuffer_ref_head == 0 && if (ci->i_wrbuffer_ref_head == 0 &&
!(dirty & (CEPH_CAP_ANY_EXCL|CEPH_CAP_FILE_WR))) { !(dirty & (CEPH_CAP_ANY_EXCL|CEPH_CAP_FILE_WR))) {
dout("queue_cap_snap %p nothing dirty|writing\n", inode); dout("%s %p %llx.%llx nothing dirty|writing\n",
__func__, inode, ceph_vinop(inode));
goto update_snapc; goto update_snapc;
} }
...@@ -576,15 +574,15 @@ static void ceph_queue_cap_snap(struct ceph_inode_info *ci, ...@@ -576,15 +574,15 @@ static void ceph_queue_cap_snap(struct ceph_inode_info *ci,
} else { } else {
if (!(used & CEPH_CAP_FILE_WR) && if (!(used & CEPH_CAP_FILE_WR) &&
ci->i_wrbuffer_ref_head == 0) { ci->i_wrbuffer_ref_head == 0) {
dout("queue_cap_snap %p " dout("%s %p %llx.%llx no new_snap|dirty_page|writing\n",
"no new_snap|dirty_page|writing\n", inode); __func__, inode, ceph_vinop(inode));
goto update_snapc; goto update_snapc;
} }
} }
dout("queue_cap_snap %p cap_snap %p queuing under %p %s %s\n", dout("%s %p %llx.%llx cap_snap %p queuing under %p %s %s\n",
inode, capsnap, old_snapc, ceph_cap_string(dirty), __func__, inode, ceph_vinop(inode), capsnap, old_snapc,
capsnap->need_flush ? "" : "no_flush"); ceph_cap_string(dirty), capsnap->need_flush ? "" : "no_flush");
ihold(inode); ihold(inode);
capsnap->follows = old_snapc->seq; capsnap->follows = old_snapc->seq;
...@@ -616,8 +614,8 @@ static void ceph_queue_cap_snap(struct ceph_inode_info *ci, ...@@ -616,8 +614,8 @@ static void ceph_queue_cap_snap(struct ceph_inode_info *ci,
list_add_tail(&capsnap->ci_item, &ci->i_cap_snaps); list_add_tail(&capsnap->ci_item, &ci->i_cap_snaps);
if (used & CEPH_CAP_FILE_WR) { if (used & CEPH_CAP_FILE_WR) {
dout("queue_cap_snap %p cap_snap %p snapc %p" dout("%s %p %llx.%llx cap_snap %p snapc %p seq %llu used WR,"
" seq %llu used WR, now pending\n", inode, " now pending\n", __func__, inode, ceph_vinop(inode),
capsnap, old_snapc, old_snapc->seq); capsnap, old_snapc, old_snapc->seq);
capsnap->writing = 1; capsnap->writing = 1;
} else { } else {
...@@ -668,27 +666,28 @@ int __ceph_finish_cap_snap(struct ceph_inode_info *ci, ...@@ -668,27 +666,28 @@ int __ceph_finish_cap_snap(struct ceph_inode_info *ci,
capsnap->truncate_size = ci->i_truncate_size; capsnap->truncate_size = ci->i_truncate_size;
capsnap->truncate_seq = ci->i_truncate_seq; capsnap->truncate_seq = ci->i_truncate_seq;
if (capsnap->dirty_pages) { if (capsnap->dirty_pages) {
dout("finish_cap_snap %p cap_snap %p snapc %p %llu %s s=%llu " dout("%s %p %llx.%llx cap_snap %p snapc %p %llu %s s=%llu "
"still has %d dirty pages\n", inode, capsnap, "still has %d dirty pages\n", __func__, inode,
capsnap->context, capsnap->context->seq, ceph_vinop(inode), capsnap, capsnap->context,
ceph_cap_string(capsnap->dirty), capsnap->size, capsnap->context->seq, ceph_cap_string(capsnap->dirty),
capsnap->dirty_pages); capsnap->size, capsnap->dirty_pages);
return 0; return 0;
} }
/* Fb cap still in use, delay it */ /* Fb cap still in use, delay it */
if (ci->i_wb_ref) { if (ci->i_wb_ref) {
dout("finish_cap_snap %p cap_snap %p snapc %p %llu %s s=%llu " dout("%s %p %llx.%llx cap_snap %p snapc %p %llu %s s=%llu "
"used WRBUFFER, delaying\n", inode, capsnap, "used WRBUFFER, delaying\n", __func__, inode,
capsnap->context, capsnap->context->seq, ceph_vinop(inode), capsnap, capsnap->context,
ceph_cap_string(capsnap->dirty), capsnap->size); capsnap->context->seq, ceph_cap_string(capsnap->dirty),
capsnap->size);
capsnap->writing = 1; capsnap->writing = 1;
return 0; return 0;
} }
ci->i_ceph_flags |= CEPH_I_FLUSH_SNAPS; ci->i_ceph_flags |= CEPH_I_FLUSH_SNAPS;
dout("finish_cap_snap %p cap_snap %p snapc %p %llu %s s=%llu\n", dout("%s %p %llx.%llx cap_snap %p snapc %p %llu %s s=%llu\n",
inode, capsnap, capsnap->context, __func__, inode, ceph_vinop(inode), capsnap, capsnap->context,
capsnap->context->seq, ceph_cap_string(capsnap->dirty), capsnap->context->seq, ceph_cap_string(capsnap->dirty),
capsnap->size); capsnap->size);
...@@ -709,7 +708,7 @@ static void queue_realm_cap_snaps(struct ceph_snap_realm *realm) ...@@ -709,7 +708,7 @@ static void queue_realm_cap_snaps(struct ceph_snap_realm *realm)
struct inode *lastinode = NULL; struct inode *lastinode = NULL;
struct ceph_cap_snap *capsnap = NULL; struct ceph_cap_snap *capsnap = NULL;
dout("queue_realm_cap_snaps %p %llx inodes\n", realm, realm->ino); dout("%s %p %llx inode\n", __func__, realm, realm->ino);
spin_lock(&realm->inodes_with_caps_lock); spin_lock(&realm->inodes_with_caps_lock);
list_for_each_entry(ci, &realm->inodes_with_caps, i_snap_realm_item) { list_for_each_entry(ci, &realm->inodes_with_caps, i_snap_realm_item) {
...@@ -747,7 +746,7 @@ static void queue_realm_cap_snaps(struct ceph_snap_realm *realm) ...@@ -747,7 +746,7 @@ static void queue_realm_cap_snaps(struct ceph_snap_realm *realm)
if (capsnap) if (capsnap)
kmem_cache_free(ceph_cap_snap_cachep, capsnap); kmem_cache_free(ceph_cap_snap_cachep, capsnap);
dout("queue_realm_cap_snaps %p %llx done\n", realm, realm->ino); dout("%s %p %llx done\n", __func__, realm, realm->ino);
} }
/* /*
...@@ -773,7 +772,7 @@ int ceph_update_snap_trace(struct ceph_mds_client *mdsc, ...@@ -773,7 +772,7 @@ int ceph_update_snap_trace(struct ceph_mds_client *mdsc,
lockdep_assert_held_write(&mdsc->snap_rwsem); lockdep_assert_held_write(&mdsc->snap_rwsem);
dout("update_snap_trace deletion=%d\n", deletion); dout("%s deletion=%d\n", __func__, deletion);
more: more:
rebuild_snapcs = 0; rebuild_snapcs = 0;
ceph_decode_need(&p, e, sizeof(*ri), bad); ceph_decode_need(&p, e, sizeof(*ri), bad);
...@@ -802,7 +801,7 @@ int ceph_update_snap_trace(struct ceph_mds_client *mdsc, ...@@ -802,7 +801,7 @@ int ceph_update_snap_trace(struct ceph_mds_client *mdsc,
rebuild_snapcs += err; rebuild_snapcs += err;
if (le64_to_cpu(ri->seq) > realm->seq) { if (le64_to_cpu(ri->seq) > realm->seq) {
dout("update_snap_trace updating %llx %p %lld -> %lld\n", dout("%s updating %llx %p %lld -> %lld\n", __func__,
realm->ino, realm, realm->seq, le64_to_cpu(ri->seq)); realm->ino, realm, realm->seq, le64_to_cpu(ri->seq));
/* update realm parameters, snap lists */ /* update realm parameters, snap lists */
realm->seq = le64_to_cpu(ri->seq); realm->seq = le64_to_cpu(ri->seq);
...@@ -826,11 +825,11 @@ int ceph_update_snap_trace(struct ceph_mds_client *mdsc, ...@@ -826,11 +825,11 @@ int ceph_update_snap_trace(struct ceph_mds_client *mdsc,
rebuild_snapcs = 1; rebuild_snapcs = 1;
} else if (!realm->cached_context) { } else if (!realm->cached_context) {
dout("update_snap_trace %llx %p seq %lld new\n", dout("%s %llx %p seq %lld new\n", __func__,
realm->ino, realm, realm->seq); realm->ino, realm, realm->seq);
rebuild_snapcs = 1; rebuild_snapcs = 1;
} else { } else {
dout("update_snap_trace %llx %p seq %lld unchanged\n", dout("%s %llx %p seq %lld unchanged\n", __func__,
realm->ino, realm, realm->seq); realm->ino, realm, realm->seq);
} }
...@@ -883,7 +882,7 @@ int ceph_update_snap_trace(struct ceph_mds_client *mdsc, ...@@ -883,7 +882,7 @@ int ceph_update_snap_trace(struct ceph_mds_client *mdsc,
ceph_put_snap_realm(mdsc, realm); ceph_put_snap_realm(mdsc, realm);
if (first_realm) if (first_realm)
ceph_put_snap_realm(mdsc, first_realm); ceph_put_snap_realm(mdsc, first_realm);
pr_err("update_snap_trace error %d\n", err); pr_err("%s error %d\n", __func__, err);
return err; return err;
} }
...@@ -900,7 +899,7 @@ static void flush_snaps(struct ceph_mds_client *mdsc) ...@@ -900,7 +899,7 @@ static void flush_snaps(struct ceph_mds_client *mdsc)
struct inode *inode; struct inode *inode;
struct ceph_mds_session *session = NULL; struct ceph_mds_session *session = NULL;
dout("flush_snaps\n"); dout("%s\n", __func__);
spin_lock(&mdsc->snap_flush_lock); spin_lock(&mdsc->snap_flush_lock);
while (!list_empty(&mdsc->snap_flush_list)) { while (!list_empty(&mdsc->snap_flush_list)) {
ci = list_first_entry(&mdsc->snap_flush_list, ci = list_first_entry(&mdsc->snap_flush_list,
...@@ -915,7 +914,7 @@ static void flush_snaps(struct ceph_mds_client *mdsc) ...@@ -915,7 +914,7 @@ static void flush_snaps(struct ceph_mds_client *mdsc)
spin_unlock(&mdsc->snap_flush_lock); spin_unlock(&mdsc->snap_flush_lock);
ceph_put_mds_session(session); ceph_put_mds_session(session);
dout("flush_snaps done\n"); dout("%s done\n", __func__);
} }
/** /**
...@@ -997,8 +996,8 @@ void ceph_handle_snap(struct ceph_mds_client *mdsc, ...@@ -997,8 +996,8 @@ void ceph_handle_snap(struct ceph_mds_client *mdsc,
trace_len = le32_to_cpu(h->trace_len); trace_len = le32_to_cpu(h->trace_len);
p += sizeof(*h); p += sizeof(*h);
dout("handle_snap from mds%d op %s split %llx tracelen %d\n", mds, dout("%s from mds%d op %s split %llx tracelen %d\n", __func__,
ceph_snap_op_name(op), split, trace_len); mds, ceph_snap_op_name(op), split, trace_len);
mutex_lock(&session->s_mutex); mutex_lock(&session->s_mutex);
inc_session_sequence(session); inc_session_sequence(session);
...@@ -1058,13 +1057,13 @@ void ceph_handle_snap(struct ceph_mds_client *mdsc, ...@@ -1058,13 +1057,13 @@ void ceph_handle_snap(struct ceph_mds_client *mdsc,
*/ */
if (ci->i_snap_realm->created > if (ci->i_snap_realm->created >
le64_to_cpu(ri->created)) { le64_to_cpu(ri->created)) {
dout(" leaving %p in newer realm %llx %p\n", dout(" leaving %p %llx.%llx in newer realm %llx %p\n",
inode, ci->i_snap_realm->ino, inode, ceph_vinop(inode), ci->i_snap_realm->ino,
ci->i_snap_realm); ci->i_snap_realm);
goto skip_inode; goto skip_inode;
} }
dout(" will move %p to split realm %llx %p\n", dout(" will move %p %llx.%llx to split realm %llx %p\n",
inode, realm->ino, realm); inode, ceph_vinop(inode), realm->ino, realm);
ceph_get_snap_realm(mdsc, realm); ceph_get_snap_realm(mdsc, realm);
ceph_change_snap_realm(inode, realm); ceph_change_snap_realm(inode, realm);
...@@ -1107,7 +1106,7 @@ void ceph_handle_snap(struct ceph_mds_client *mdsc, ...@@ -1107,7 +1106,7 @@ void ceph_handle_snap(struct ceph_mds_client *mdsc,
return; return;
bad: bad:
pr_err("corrupt snap message from mds%d\n", mds); pr_err("%s corrupt snap message from mds%d\n", __func__, mds);
ceph_msg_dump(msg); ceph_msg_dump(msg);
out: out:
if (locked_rwsem) if (locked_rwsem)
...@@ -1140,7 +1139,8 @@ struct ceph_snapid_map* ceph_get_snapid_map(struct ceph_mds_client *mdsc, ...@@ -1140,7 +1139,8 @@ struct ceph_snapid_map* ceph_get_snapid_map(struct ceph_mds_client *mdsc,
} }
spin_unlock(&mdsc->snapid_map_lock); spin_unlock(&mdsc->snapid_map_lock);
if (exist) { if (exist) {
dout("found snapid map %llx -> %x\n", exist->snap, exist->dev); dout("%s found snapid map %llx -> %x\n", __func__,
exist->snap, exist->dev);
return exist; return exist;
} }
...@@ -1184,11 +1184,13 @@ struct ceph_snapid_map* ceph_get_snapid_map(struct ceph_mds_client *mdsc, ...@@ -1184,11 +1184,13 @@ struct ceph_snapid_map* ceph_get_snapid_map(struct ceph_mds_client *mdsc,
if (exist) { if (exist) {
free_anon_bdev(sm->dev); free_anon_bdev(sm->dev);
kfree(sm); kfree(sm);
dout("found snapid map %llx -> %x\n", exist->snap, exist->dev); dout("%s found snapid map %llx -> %x\n", __func__,
exist->snap, exist->dev);
return exist; return exist;
} }
dout("create snapid map %llx -> %x\n", sm->snap, sm->dev); dout("%s create snapid map %llx -> %x\n", __func__,
sm->snap, sm->dev);
return sm; return sm;
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment