From: Satoru Takeuchi <satoru.takeuchi@gmail.com>
To: ceph-devel@vger.kernel.org
Cc: Satoru Takeuchi <satoru.takeuchi@gmail.com>
Subject: [PATCH] ceph: print fsid with mon id and osd id
Date: Thu, 29 Jul 2021 07:18:51 +0000 [thread overview]
Message-ID: <20210729071851.1244874-1-satoru.takeuchi@gmail.com> (raw)
Print fsid in libceph log messages to distinct from which each message come.
Signed-off-by: Satoru Takeuchi <satoru.takeuchi@gmail.com>
---
net/ceph/mon_client.c | 26 +++++----
net/ceph/osd_client.c | 129 ++++++++++++++++++++++++------------------
net/ceph/osdmap.c | 16 +++---
3 files changed, 98 insertions(+), 73 deletions(-)
diff --git a/net/ceph/mon_client.c b/net/ceph/mon_client.c
index 013cbdb6cfe2..c5db73da1c3d 100644
--- a/net/ceph/mon_client.c
+++ b/net/ceph/mon_client.c
@@ -141,7 +141,8 @@ static struct ceph_monmap *ceph_monmap_decode(void **p, void *end, bool msgr2)
if (ret)
goto fail;
- dout("%s mon%d addr %s\n", __func__, i,
+ dout("%s mon%d(fsid=%pU) addr %s\n", __func__,
+ i, &monmap->fsid,
ceph_pr_addr(&inst->addr));
}
@@ -187,7 +188,8 @@ static void __send_prepared_auth_request(struct ceph_mon_client *monc, int len)
*/
static void __close_session(struct ceph_mon_client *monc)
{
- dout("__close_session closing mon%d\n", monc->cur_mon);
+ dout("__close_session closing mon%d(fsid=%pU)\n", monc->cur_mon,
+ &monc->client->fsid);
ceph_msg_revoke(monc->m_auth);
ceph_msg_revoke_incoming(monc->m_auth_reply);
ceph_msg_revoke(monc->m_subscribe);
@@ -229,8 +231,8 @@ static void pick_new_mon(struct ceph_mon_client *monc)
monc->cur_mon = n;
}
- dout("%s mon%d -> mon%d out of %d mons\n", __func__, old_mon,
- monc->cur_mon, monc->monmap->num_mon);
+ dout("%s mon%d(fsid=%pU) -> mon%d out of %d mons\n", __func__, old_mon,
+ &monc->client->fsid, monc->cur_mon, monc->monmap->num_mon);
}
/*
@@ -252,7 +254,8 @@ static void __open_session(struct ceph_mon_client *monc)
monc->sub_renew_after = jiffies; /* i.e., expired */
monc->sub_renew_sent = 0;
- dout("%s opening mon%d\n", __func__, monc->cur_mon);
+ dout("%s opening mon%d(fsid=%pU)\n", __func__,
+ monc->cur_mon, &monc->client->fsid);
ceph_con_open(&monc->con, CEPH_ENTITY_TYPE_MON, monc->cur_mon,
&monc->monmap->mon_inst[monc->cur_mon].addr);
@@ -279,8 +282,8 @@ static void __open_session(struct ceph_mon_client *monc)
static void reopen_session(struct ceph_mon_client *monc)
{
if (!monc->hunting)
- pr_info("mon%d %s session lost, hunting for new mon\n",
- monc->cur_mon, ceph_pr_addr(&monc->con.peer_addr));
+ pr_info("mon%d(fsid=%pU) %s session lost, hunting for new mon\n",
+ monc->cur_mon, &monc->client->fsid, ceph_pr_addr(&monc->con.peer_addr));
__close_session(monc);
__open_session(monc);
@@ -1264,7 +1267,8 @@ EXPORT_SYMBOL(ceph_monc_stop);
static void finish_hunting(struct ceph_mon_client *monc)
{
if (monc->hunting) {
- dout("%s found mon%d\n", __func__, monc->cur_mon);
+ dout("%s found mon%d(fsid=%pU)\n", __func__,
+ monc->cur_mon, &monc->client->fsid);
monc->hunting = false;
monc->had_a_connection = true;
un_backoff(monc);
@@ -1296,7 +1300,8 @@ static void finish_auth(struct ceph_mon_client *monc, int auth_err,
__send_subscribe(monc);
__resend_generic_request(monc);
- pr_info("mon%d %s session established\n", monc->cur_mon,
+ pr_info("mon%d(fsid=%pU) %s session established\n", monc->cur_mon,
+ monc->client->fsid,
ceph_pr_addr(&monc->con.peer_addr));
}
}
@@ -1547,7 +1552,8 @@ static void mon_fault(struct ceph_connection *con)
struct ceph_mon_client *monc = con->private;
mutex_lock(&monc->mutex);
- dout("%s mon%d\n", __func__, monc->cur_mon);
+ dout("%s mon%d(fsid=%pU)\n", __func__, monc->cur_mon,
+ &monc->client->fsid);
if (monc->cur_mon >= 0) {
if (!monc->hunting) {
dout("%s hunting for new mon\n", __func__);
diff --git a/net/ceph/osd_client.c b/net/ceph/osd_client.c
index ff8624a7c964..5bb47b20f288 100644
--- a/net/ceph/osd_client.c
+++ b/net/ceph/osd_client.c
@@ -1271,7 +1271,8 @@ static void __move_osd_to_lru(struct ceph_osd *osd)
{
struct ceph_osd_client *osdc = osd->o_osdc;
- dout("%s osd %p osd%d\n", __func__, osd, osd->o_osd);
+ dout("%s osd %p osd%d(fsid=%pU)\n", __func__, osd, osd->o_osd,
+ &osd->o_osdc->client->fsid);
BUG_ON(!list_empty(&osd->o_osd_lru));
spin_lock(&osdc->osd_lru_lock);
@@ -1292,7 +1293,8 @@ static void __remove_osd_from_lru(struct ceph_osd *osd)
{
struct ceph_osd_client *osdc = osd->o_osdc;
- dout("%s osd %p osd%d\n", __func__, osd, osd->o_osd);
+ dout("%s osd %p osd%d(fsid=%pU)\n", __func__, osd, osd->o_osd,
+ &osd->o_osdc->client->fsid);
spin_lock(&osdc->osd_lru_lock);
if (!list_empty(&osd->o_osd_lru))
@@ -1310,7 +1312,8 @@ static void close_osd(struct ceph_osd *osd)
struct rb_node *n;
verify_osdc_wrlocked(osdc);
- dout("%s osd %p osd%d\n", __func__, osd, osd->o_osd);
+ dout("%s osd %p osd%d(fsid=%pU)\n", __func__, osd, osd->o_osd,
+ &osdc->client->fsid);
ceph_con_close(&osd->o_con);
@@ -1349,7 +1352,8 @@ static int reopen_osd(struct ceph_osd *osd)
{
struct ceph_entity_addr *peer_addr;
- dout("%s osd %p osd%d\n", __func__, osd, osd->o_osd);
+ dout("%s osd %p osd%d(fsid=%pU)\n", __func__, osd, osd->o_osd,
+ &osd->o_osdc->client->fsid);
if (RB_EMPTY_ROOT(&osd->o_requests) &&
RB_EMPTY_ROOT(&osd->o_linger_requests)) {
@@ -1405,7 +1409,8 @@ static struct ceph_osd *lookup_create_osd(struct ceph_osd_client *osdc, int o,
&osdc->osdmap->osd_addr[osd->o_osd]);
}
- dout("%s osdc %p osd%d -> osd %p\n", __func__, osdc, o, osd);
+ dout("%s osdc %p osd%d(fsid=%pU) -> osd %p\n", __func__, osdc, o,
+ &osdc->client->fsid, osd);
return osd;
}
@@ -1418,8 +1423,8 @@ static void link_request(struct ceph_osd *osd, struct ceph_osd_request *req)
{
verify_osd_locked(osd);
WARN_ON(!req->r_tid || req->r_osd);
- dout("%s osd %p osd%d req %p tid %llu\n", __func__, osd, osd->o_osd,
- req, req->r_tid);
+ dout("%s osd %p osd%d(fsid=%pU) req %p tid %llu\n", __func__, osd,
+ osd->o_osd, &osd->o_osdc->client->fsid, req, req->r_tid);
if (!osd_homeless(osd))
__remove_osd_from_lru(osd);
@@ -1435,8 +1440,8 @@ static void unlink_request(struct ceph_osd *osd, struct ceph_osd_request *req)
{
verify_osd_locked(osd);
WARN_ON(req->r_osd != osd);
- dout("%s osd %p osd%d req %p tid %llu\n", __func__, osd, osd->o_osd,
- req, req->r_tid);
+ dout("%s osd %p osd%d(fsid=%pU) req %p tid %llu\n", __func__, osd,
+ osd->o_osd, &osd->o_osdc->client->fsid, req, req->r_tid);
req->r_osd = NULL;
erase_request(&osd->o_requests, req);
@@ -1498,12 +1503,12 @@ static bool target_should_be_paused(struct ceph_osd_client *osdc,
(osdc->osdmap->epoch < osdc->epoch_barrier);
}
-static int pick_random_replica(const struct ceph_osds *acting)
+static int pick_random_replica(struct ceph_osd_client *osdc, const struct ceph_osds *acting)
{
int i = prandom_u32() % acting->size;
- dout("%s picked osd%d, primary osd%d\n", __func__,
- acting->osds[i], acting->primary);
+ dout("%s picked osd%d(fsid=%pU), primary osd%d\n", __func__,
+ acting->osds[i], &osdc->client->fsid, acting->primary);
return i;
}
@@ -1532,8 +1537,9 @@ static int pick_closest_replica(struct ceph_osd_client *osdc,
}
} while (++i < acting->size);
- dout("%s picked osd%d with locality %d, primary osd%d\n", __func__,
- acting->osds[best_i], best_locality, acting->primary);
+ dout("%s picked osd%d(fsid=%pU) with locality %d, primary osd%d\n", __func__,
+ acting->osds[best_i], &osdc->client->fsid,
+ best_locality, acting->primary);
return best_i;
}
@@ -1648,7 +1654,7 @@ static enum calc_target_result calc_target(struct ceph_osd_client *osdc,
WARN_ON(!is_read || acting.osds[0] != acting.primary);
if (t->flags & CEPH_OSD_FLAG_BALANCE_READS) {
- pos = pick_random_replica(&acting);
+ pos = pick_random_replica(osdc, &acting);
} else {
pos = pick_closest_replica(osdc, &acting);
}
@@ -1666,8 +1672,8 @@ static enum calc_target_result calc_target(struct ceph_osd_client *osdc,
ct_res = CALC_TARGET_NO_ACTION;
out:
- dout("%s t %p -> %d%d%d%d ct_res %d osd%d\n", __func__, t, unpaused,
- legacy_change, force_resend, split, ct_res, t->osd);
+ dout("%s t %p -> %d%d%d%d ct_res %d osd%d(fsid=%pU)\n", __func__, t, unpaused,
+ legacy_change, force_resend, split, ct_res, t->osd, &osdc->client->fsid);
return ct_res;
}
@@ -1987,9 +1993,10 @@ static bool should_plug_request(struct ceph_osd_request *req)
if (!backoff)
return false;
- dout("%s req %p tid %llu backoff osd%d spgid %llu.%xs%d id %llu\n",
- __func__, req, req->r_tid, osd->o_osd, backoff->spgid.pgid.pool,
- backoff->spgid.pgid.seed, backoff->spgid.shard, backoff->id);
+ dout("%s req %p tid %llu backoff osd%d(fsid=%pU) spgid %llu.%xs%d id %llu\n",
+ __func__, req, req->r_tid, osd->o_osd, &osd->o_osdc->client->fsid,
+ backoff->spgid.pgid.pool, backoff->spgid.pgid.seed, backoff->spgid.shard,
+ backoff->id);
return true;
}
@@ -2296,11 +2303,11 @@ static void send_request(struct ceph_osd_request *req)
encode_request_partial(req, req->r_request);
- dout("%s req %p tid %llu to pgid %llu.%x spgid %llu.%xs%d osd%d e%u flags 0x%x attempt %d\n",
+ dout("%s req %p tid %llu to pgid %llu.%x spgid %llu.%xs%d osd%d(fsid=%pU) e%u flags 0x%x attempt %d\n",
__func__, req, req->r_tid, req->r_t.pgid.pool, req->r_t.pgid.seed,
req->r_t.spgid.pgid.pool, req->r_t.spgid.pgid.seed,
- req->r_t.spgid.shard, osd->o_osd, req->r_t.epoch, req->r_flags,
- req->r_attempts);
+ req->r_t.spgid.shard, osd->o_osd, &osd->o_osdc->client->fsid,
+ req->r_t.epoch, req->r_flags, req->r_attempts);
req->r_t.paused = false;
req->r_stamp = jiffies;
@@ -2788,8 +2795,8 @@ static void link_linger(struct ceph_osd *osd,
{
verify_osd_locked(osd);
WARN_ON(!lreq->linger_id || lreq->osd);
- dout("%s osd %p osd%d lreq %p linger_id %llu\n", __func__, osd,
- osd->o_osd, lreq, lreq->linger_id);
+ dout("%s osd %p osd%d(fsid=%pU) lreq %p linger_id %llu\n", __func__, osd,
+ osd->o_osd, &osd->o_osdc->client->fsid, lreq, lreq->linger_id);
if (!osd_homeless(osd))
__remove_osd_from_lru(osd);
@@ -2806,8 +2813,8 @@ static void unlink_linger(struct ceph_osd *osd,
{
verify_osd_locked(osd);
WARN_ON(lreq->osd != osd);
- dout("%s osd %p osd%d lreq %p linger_id %llu\n", __func__, osd,
- osd->o_osd, lreq, lreq->linger_id);
+ dout("%s osd %p osd%d(fsid=%pU) lreq %p linger_id %llu\n", __func__, osd,
+ osd->o_osd, &osd->o_osdc->client->fsid, lreq, lreq->linger_id);
lreq->osd = NULL;
erase_linger(&osd->o_linger_requests, lreq);
@@ -3357,14 +3364,14 @@ static void handle_timeout(struct work_struct *work)
p = rb_next(p); /* abort_request() */
if (time_before(req->r_stamp, cutoff)) {
- dout(" req %p tid %llu on osd%d is laggy\n",
- req, req->r_tid, osd->o_osd);
+ dout(" req %p tid %llu on osd%d(fsid=%pU) is laggy\n",
+ req, req->r_tid, osd->o_osd, &osdc->client->fsid);
found = true;
}
if (opts->osd_request_timeout &&
time_before(req->r_start_stamp, expiry_cutoff)) {
- pr_err_ratelimited("tid %llu on osd%d timeout\n",
- req->r_tid, osd->o_osd);
+ pr_err_ratelimited("tid %llu on osd%d(fsid=%pU) timeout\n",
+ req->r_tid, osd->o_osd, &osdc->client->fsid);
abort_request(req, -ETIMEDOUT);
}
}
@@ -3372,8 +3379,8 @@ static void handle_timeout(struct work_struct *work)
struct ceph_osd_linger_request *lreq =
rb_entry(p, struct ceph_osd_linger_request, node);
- dout(" lreq %p linger_id %llu is served by osd%d\n",
- lreq, lreq->linger_id, osd->o_osd);
+ dout(" lreq %p linger_id %llu is served by osd%d(fsid=%pU)\n",
+ lreq, lreq->linger_id, osd->o_osd, osdc->client->fsid);
found = true;
mutex_lock(&lreq->lock);
@@ -3394,8 +3401,9 @@ static void handle_timeout(struct work_struct *work)
p = rb_next(p); /* abort_request() */
if (time_before(req->r_start_stamp, expiry_cutoff)) {
- pr_err_ratelimited("tid %llu on osd%d timeout\n",
- req->r_tid, osdc->homeless_osd.o_osd);
+ pr_err_ratelimited("tid %llu on osd%d(fsid=%pU) timeout\n",
+ req->r_tid, osdc->homeless_osd.o_osd,
+ &osdc->client->fsid);
abort_request(req, -ETIMEDOUT);
}
}
@@ -3662,7 +3670,8 @@ static void handle_reply(struct ceph_osd *osd, struct ceph_msg *msg)
down_read(&osdc->lock);
if (!osd_registered(osd)) {
- dout("%s osd%d unknown\n", __func__, osd->o_osd);
+ dout("%s osd%d(fsid=%pU) unknown\n", __func__, osd->o_osd,
+ &osd->o_osdc->client->fsid);
goto out_unlock_osdc;
}
WARN_ON(osd->o_osd != le64_to_cpu(msg->hdr.src.num));
@@ -3670,7 +3679,8 @@ static void handle_reply(struct ceph_osd *osd, struct ceph_msg *msg)
mutex_lock(&osd->lock);
req = lookup_request(&osd->o_requests, tid);
if (!req) {
- dout("%s osd%d tid %llu unknown\n", __func__, osd->o_osd, tid);
+ dout("%s osd%d(fsid=%pU) tid %llu unknown\n", __func__,
+ osd->o_osd, &osd->o_osdc->client->fsid, &tid);
goto out_unlock_session;
}
@@ -4180,11 +4190,13 @@ static void osd_fault(struct ceph_connection *con)
struct ceph_osd *osd = con->private;
struct ceph_osd_client *osdc = osd->o_osdc;
- dout("%s osd %p osd%d\n", __func__, osd, osd->o_osd);
+ dout("%s osd %p osd%d(fsid=%pU)\n", __func__, osd,
+ &osdc->client->fsid, osd->o_osd);
down_write(&osdc->lock);
if (!osd_registered(osd)) {
- dout("%s osd%d unknown\n", __func__, osd->o_osd);
+ dout("%s osd%d(fsid=%pU) unknown\n", __func__,
+ osd->o_osd, &osdc->client->fsid);
goto out_unlock;
}
@@ -4299,7 +4311,8 @@ static void handle_backoff_block(struct ceph_osd *osd, struct MOSDBackoff *m)
struct ceph_osd_backoff *backoff;
struct ceph_msg *msg;
- dout("%s osd%d spgid %llu.%xs%d id %llu\n", __func__, osd->o_osd,
+ dout("%s osd%d(fsid=%pU) spgid %llu.%xs%d id %llu\n", __func__,
+ osd->o_osd, &osd->o_osdc->client->fsid,
m->spgid.pgid.pool, m->spgid.pgid.seed, m->spgid.shard, m->id);
spg = lookup_spg_mapping(&osd->o_backoff_mappings, &m->spgid);
@@ -4359,21 +4372,22 @@ static void handle_backoff_unblock(struct ceph_osd *osd,
struct ceph_osd_backoff *backoff;
struct rb_node *n;
- dout("%s osd%d spgid %llu.%xs%d id %llu\n", __func__, osd->o_osd,
+ dout("%s osd%d(fsid=%pU) spgid %llu.%xs%d id %llu\n", __func__,
+ osd->o_osd, &osd->o_osdc->client->fsid,
m->spgid.pgid.pool, m->spgid.pgid.seed, m->spgid.shard, m->id);
backoff = lookup_backoff_by_id(&osd->o_backoffs_by_id, m->id);
if (!backoff) {
- pr_err("%s osd%d spgid %llu.%xs%d id %llu backoff dne\n",
- __func__, osd->o_osd, m->spgid.pgid.pool,
+ pr_err("%s osd%d(fsid=%pU) spgid %llu.%xs%d id %llu backoff dne\n",
+ __func__, osd->o_osd, &osd->o_osdc->client->fsid, m->spgid.pgid.pool,
m->spgid.pgid.seed, m->spgid.shard, m->id);
return;
}
if (hoid_compare(backoff->begin, m->begin) &&
hoid_compare(backoff->end, m->end)) {
- pr_err("%s osd%d spgid %llu.%xs%d id %llu bad range?\n",
- __func__, osd->o_osd, m->spgid.pgid.pool,
+ pr_err("%s osd%d(fsid=%pU) spgid %llu.%xs%d id %llu bad range?\n",
+ __func__, osd->o_osd, osd->o_osdc->client->fsid, m->spgid.pgid.pool,
m->spgid.pgid.seed, m->spgid.shard, m->id);
/* unblock it anyway... */
}
@@ -4418,7 +4432,8 @@ static void handle_backoff(struct ceph_osd *osd, struct ceph_msg *msg)
down_read(&osdc->lock);
if (!osd_registered(osd)) {
- dout("%s osd%d unknown\n", __func__, osd->o_osd);
+ dout("%s osd%d(fsid=%pU) unknown\n", __func__,
+ osd->o_osd, &osd->o_osdc->client->fsid);
up_read(&osdc->lock);
return;
}
@@ -4440,7 +4455,8 @@ static void handle_backoff(struct ceph_osd *osd, struct ceph_msg *msg)
handle_backoff_unblock(osd, &m);
break;
default:
- pr_err("%s osd%d unknown op %d\n", __func__, osd->o_osd, m.op);
+ pr_err("%s osd%d(fsid=%pU) unknown op %d\n", __func__,
+ osd->o_osd, &osd->o_osdc->client->fsid, m.op);
}
free_hoid(m.begin);
@@ -5459,7 +5475,8 @@ static struct ceph_msg *get_reply(struct ceph_connection *con,
down_read(&osdc->lock);
if (!osd_registered(osd)) {
- dout("%s osd%d unknown, skipping\n", __func__, osd->o_osd);
+ dout("%s osd%d(fsid=%pU) unknown, skipping\n", __func__,
+ osd->o_osd, &osdc->client->fsid);
*skip = 1;
goto out_unlock_osdc;
}
@@ -5468,8 +5485,8 @@ static struct ceph_msg *get_reply(struct ceph_connection *con,
mutex_lock(&osd->lock);
req = lookup_request(&osd->o_requests, tid);
if (!req) {
- dout("%s osd%d tid %llu unknown, skipping\n", __func__,
- osd->o_osd, tid);
+ dout("%s osd%d(fsid=%pU) tid %llu unknown, skipping\n", __func__,
+ osd->o_osd, &osdc->client->fsid, tid);
*skip = 1;
goto out_unlock_session;
}
@@ -5477,8 +5494,8 @@ static struct ceph_msg *get_reply(struct ceph_connection *con,
ceph_msg_revoke_incoming(req->r_reply);
if (front_len > req->r_reply->front_alloc_len) {
- pr_warn("%s osd%d tid %llu front %d > preallocated %d\n",
- __func__, osd->o_osd, req->r_tid, front_len,
+ pr_warn("%s osd%d(fsid=%pU) tid %llu front %d > preallocated %d\n",
+ __func__, osd->o_osd, &osdc->client->fsid, req->r_tid, front_len,
req->r_reply->front_alloc_len);
m = ceph_msg_new(CEPH_MSG_OSD_OPREPLY, front_len, GFP_NOFS,
false);
@@ -5489,8 +5506,8 @@ static struct ceph_msg *get_reply(struct ceph_connection *con,
}
if (data_len > req->r_reply->data_length) {
- pr_warn("%s osd%d tid %llu data %d > preallocated %zu, skipping\n",
- __func__, osd->o_osd, req->r_tid, data_len,
+ pr_warn("%s osd%d(fsid=%pU) tid %llu data %d > preallocated %zu, skipping\n",
+ __func__, osd->o_osd, &osdc->client->fsid, req->r_tid, data_len,
req->r_reply->data_length);
m = NULL;
*skip = 1;
@@ -5550,8 +5567,8 @@ static struct ceph_msg *osd_alloc_msg(struct ceph_connection *con,
case CEPH_MSG_OSD_OPREPLY:
return get_reply(con, hdr, skip);
default:
- pr_warn("%s osd%d unknown msg type %d, skipping\n", __func__,
- osd->o_osd, type);
+ pr_warn("%s osd%d(fsid=%pU) unknown msg type %d, skipping\n", __func__,
+ osd->o_osd, &osd->o_osdc->client->fsid, type);
*skip = 1;
return NULL;
}
diff --git a/net/ceph/osdmap.c b/net/ceph/osdmap.c
index 75b738083523..24b70bc7225c 100644
--- a/net/ceph/osdmap.c
+++ b/net/ceph/osdmap.c
@@ -1566,7 +1566,7 @@ static int decode_new_primary_affinity(void **p, void *end,
if (ret)
return ret;
- pr_info("osd%d primary-affinity 0x%x\n", osd, aff);
+ pr_info("osd%d(fsid=%pU) primary-affinity 0x%x\n", osd, &map->fsid, aff);
}
return 0;
@@ -1728,7 +1728,8 @@ static int osdmap_decode(void **p, void *end, bool msgr2,
if (err)
goto bad;
- dout("%s osd%d addr %s\n", __func__, i, ceph_pr_addr(addr));
+ dout("%s osd%d(fsid=%pU) addr %s\n",
+ __func__, i, &map->fsid, ceph_pr_addr(addr));
}
/* pg_temp */
@@ -1864,7 +1865,7 @@ static int decode_new_up_state_weight(void **p, void *end, u8 struct_v,
osd = ceph_decode_32(p);
w = ceph_decode_32(p);
BUG_ON(osd >= map->max_osd);
- pr_info("osd%d weight 0x%x %s\n", osd, w,
+ pr_info("osd%d(fsid=%pU) weight 0x%x %s\n", osd, &map->fsid, w,
w == CEPH_OSD_IN ? "(in)" :
(w == CEPH_OSD_OUT ? "(out)" : ""));
map->osd_weight[osd] = w;
@@ -1898,10 +1899,10 @@ static int decode_new_up_state_weight(void **p, void *end, u8 struct_v,
BUG_ON(osd >= map->max_osd);
if ((map->osd_state[osd] & CEPH_OSD_UP) &&
(xorstate & CEPH_OSD_UP))
- pr_info("osd%d down\n", osd);
+ pr_info("osd%d(fsid=%pU) down\n", osd, &map->fsid);
if ((map->osd_state[osd] & CEPH_OSD_EXISTS) &&
(xorstate & CEPH_OSD_EXISTS)) {
- pr_info("osd%d does not exist\n", osd);
+ pr_info("osd%d(fsid=%pU) does not exist\n", osd, &map->fsid);
ret = set_primary_affinity(map, osd,
CEPH_OSD_DEFAULT_PRIMARY_AFFINITY);
if (ret)
@@ -1929,9 +1930,10 @@ static int decode_new_up_state_weight(void **p, void *end, u8 struct_v,
if (ret)
return ret;
- dout("%s osd%d addr %s\n", __func__, osd, ceph_pr_addr(&addr));
+ dout("%s osd%d(fsid=%pU) addr %s\n",
+ __func__, osd, &map->fsid, ceph_pr_addr(&addr));
- pr_info("osd%d up\n", osd);
+ pr_info("osd%d(fsid=%pU) up\n", osd, &map->fsid);
map->osd_state[osd] |= CEPH_OSD_EXISTS | CEPH_OSD_UP;
map->osd_addr[osd] = addr;
}
--
2.25.1
next reply other threads:[~2021-07-29 7:19 UTC|newest]
Thread overview: 3+ messages / expand[flat|nested] mbox.gz Atom feed top
2021-07-29 7:18 Satoru Takeuchi [this message]
2021-08-04 7:17 ` [PATCH] ceph: print fsid with mon id and osd id Ilya Dryomov
2021-08-05 12:43 ` Satoru Takeuchi
Reply instructions:
You may reply publicly to this message via plain-text email
using any one of the following methods:
* Save the following mbox file, import it into your mail client,
and reply-to-all from there: mbox
Avoid top-posting and favor interleaved quoting:
https://en.wikipedia.org/wiki/Posting_style#Interleaved_style
* Reply using the --to, --cc, and --in-reply-to
switches of git-send-email(1):
git send-email \
--in-reply-to=20210729071851.1244874-1-satoru.takeuchi@gmail.com \
--to=satoru.takeuchi@gmail.com \
--cc=ceph-devel@vger.kernel.org \
/path/to/YOUR_REPLY
https://kernel.org/pub/software/scm/git/docs/git-send-email.html
* If your mail client supports setting the In-Reply-To header
via mailto: links, try the mailto: link
Be sure your reply has a Subject: header at the top and a blank line
before the message body.
This is an external index of several public inboxes,
see mirroring instructions on how to clone and mirror
all data and code used by this external index.