if (osd_stat_updated || !pg_stat_queue.empty()) {
osd_stat_updated = false;
- dout(1) << "send_pg_stats - " << pg_stat_queue.size() << " pgs updated" << dendl;
+ dout(10) << "send_pg_stats - " << pg_stat_queue.size() << " pgs updated" << dendl;
utime_t had_for = g_clock.now();
had_for -= had_map_since;
int err = -EPERM;
if (op->may_read() && !(perm & OSD_POOL_CAP_R)) {
- dout(0) << "no READ permission to access pool " << pg->pool->name << dendl;
+ dout(10) << "no READ permission to access pool " << pg->pool->name << dendl;
} else if (op->may_write() && !(perm & OSD_POOL_CAP_W)) {
- dout(0) << "no WRITE permission to access pool " << pg->pool->name << dendl;
+ dout(10) << "no WRITE permission to access pool " << pg->pool->name << dendl;
} else if (op->require_exec_caps() && !(perm & OSD_POOL_CAP_X)) {
- dout(0) << "no EXEC permission to access pool " << pg->pool->name << dendl;
+ dout(10) << "no EXEC permission to access pool " << pg->pool->name << dendl;
} else {
err = 0;
}
case ClassHandler::ClassData::CLASS_LOADED:
return 0;
case ClassHandler::ClassData::CLASS_INVALID:
- dout(0) << "class not supported" << dendl;
+ dout(1) << "class " << cname << " not supported" << dendl;
return -EOPNOTSUPP;
default:
assert(0);
return;
Mutex::Locker l(class_lock);
- dout(0) << "handle_class action=" << m->action << dendl;
+ dout(10) << "handle_class action=" << m->action << dendl;
switch (m->action) {
case CLASS_RESPONSE:
is_write = flags & CLS_METHOD_WR;
is_public = flags & CLS_METHOD_PUBLIC;
- dout(0) << "class " << cname << " method " << mname
+ dout(10) << "class " << cname << " method " << mname
<< " flags=" << (is_read ? "r" : "") << (is_write ? "w" : "") << dendl;
if (is_read)
op->rmw_flags |= CEPH_OSD_FLAG_READ;
void ReplicatedPG::do_pg_op(MOSDOp *op)
{
- dout(0) << "do_pg_op " << *op << dendl;
+ dout(10) << "do_pg_op " << *op << dendl;
bufferlist outdata;
int result = 0;
case CEPH_OSD_OP_READ:
{
- dout(0) << "CEPH_OSD_OP_READ" << dendl;
// read into a buffer
bufferlist bl;
int r = osd->store->read(coll_t::build_pg_coll(info.pgid), soid, op.extent.offset, op.extent.length, bl);
}
info.stats.num_rd_kb += SHIFT_ROUND_UP(op.extent.length, 10);
info.stats.num_rd++;
- dout(0) << " read got " << r << " / " << op.extent.length << " bytes from obj " << soid << dendl;
+ dout(10) << " read got " << r << " / " << op.extent.length << " bytes from obj " << soid << dendl;
__u32 seq = oi.truncate_seq;
// are we beyond truncate_size?
bufferlist keep;
// keep first part of odata; trim at truncation point
- dout(0) << " obj " << soid << " seq " << seq
+ dout(10) << " obj " << soid << " seq " << seq
<< ": trimming overlap " << from << "~" << trim << dendl;
keep.substr_of(odata, 0, odata.length() - trim);
odata.claim(keep);
case CEPH_OSD_OP_CMPXATTR:
{
- dout(0) << "CEPH_OSD_OP_CMPXATTR" << dendl;
string aname;
bp.copy(op.xattr.name_len, aname);
string name = "_" + aname;
}
if (!result) {
- dout(0) << "comparison returned false" << dendl;
+ dout(10) << "comparison returned false" << dendl;
result = -ECANCELED;
break;
}
if (result < 0) {
- dout(0) << "comparison returned " << result << " " << strerror(-result) << dendl;
+ dout(10) << "comparison returned " << result << " " << strerror(-result) << dendl;
break;
}
- dout(0) << "comparison returned true" << dendl;
+ dout(10) << "comparison returned true" << dendl;
info.stats.num_rd++;
}
break;
dout(10) << "sub_op_push need " << data_needed << ", got " << data_subset << dendl;
if (!data_needed.subset_of(data_subset)) {
- dout(0) << " we did not get enough of " << soid << " object data" << dendl;
+ dout(0) << "sub_op_push we did not get enough of " << soid << " object data" << dendl;
op->put();
return;
}