-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
+// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
/*
* Ceph - scalable distributed file system
*
* This is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
- * License version 2.1, as published by the Free Software
+ * License version 2.1, as published by the Free Software
* Foundation. See file COPYING.
- *
+ *
*/
#include <sys/stat.h>
#include "global/signal_handler.h"
#include "common/Preforker.h"
#include "common/safe_io.h"
-
+
#include <sys/types.h>
#include <fcntl.h>
#include <fuse.h>
+#define dout_context g_ceph_context
+
static void fuse_usage()
{
const char **argv = (const char **) malloc((2) * sizeof(char *));
#include "include/assert.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
void usage()
#include "include/assert.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_osd
namespace {
#include "include/assert.h"
#include "include/cephfs/ceph_statx.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_client
#undef dout_prefix
#define dout_prefix *_dout << "client." << (whoami >= 0 ? whoami:client->get_nodeid()) << " "
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
+// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
/*
* Ceph - scalable distributed file system
*
* This is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
- * License version 2.1, as published by the Free Software
+ * License version 2.1, as published by the Free Software
* Foundation. See file COPYING.
- *
+ *
*/
#include <sys/file.h>
#include <fuse.h>
#include <fuse_lowlevel.h>
+#define dout_context g_ceph_context
+
#define FINO_INO(x) ((x) & ((1ull<<48)-1ull))
#define FINO_STAG(x) ((x) >> 48)
#define MAKE_FINO(i,s) ((i) | ((s) << 48))
#include "msg/Message.h"
#include "include/assert.h"
+#define dout_context cct
#define dout_subsys ceph_subsys_optracker
#undef dout_prefix
#define dout_prefix _prefix(_dout)
if (oldest_op_tmp < oldest_op) {
oldest_op = oldest_op_tmp;
}
- }
+ }
total_ops_in_flight += sdata->ops_in_flight_sharded.size();
}
-
+
if (0 == total_ops_in_flight)
return false;
/* Global version of the stuff in common/dout.h
*/
-#define dout(v) ldout((g_ceph_context), v)
+#define dout(v) ldout((dout_context), v)
-#define pdout(v, p) lpdout((g_ceph_context), v, p)
+#define pdout(v, p) lpdout((dout_context), v, p)
-#define dlog_p(sub, v) ldlog_p1((g_ceph_context), sub, v)
+#define dlog_p(sub, v) ldlog_p1((dout_context), sub, v)
-#define generic_dout(v) lgeneric_dout((g_ceph_context), v)
+#define generic_dout(v) lgeneric_dout((dout_context), v)
-#define derr lderr((g_ceph_context))
+#define derr lderr((dout_context))
-#define generic_derr lgeneric_derr((g_ceph_context))
+#define generic_derr lgeneric_derr((dout_context))
#endif
#include <zlib.h>
// -----------------------------------------------------------------------------
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_compressor
#undef dout_prefix
#define dout_prefix _prefix(_dout)
#include "isa-l/include/erasure_code.h"
}
// -----------------------------------------------------------------------------
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_osd
#undef dout_prefix
#define dout_prefix _prefix(_dout)
// -----------------------------------------------------------------------------
// -----------------------------------------------------------------------------
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_osd
#undef dout_prefix
#define dout_prefix _tc_prefix(_dout)
#define LARGEST_VECTOR_WORDSIZE 16
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_osd
#undef dout_prefix
#define dout_prefix _prefix(_dout)
#include "ErasureCodePluginJerasure.h"
#include "jerasure_init.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_osd
#undef dout_prefix
#define dout_prefix _prefix(_dout)
#include "galois.h"
}
+#define dout_context g_ceph_context
+
extern "C" int jerasure_init(int count, int *words)
{
for(int i = 0; i < count; i++) {
// re-include our assert to clobber boost's
#include "include/assert.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_osd
#undef dout_prefix
#define dout_prefix _prefix(_dout)
#include "ErasureCodeShec.h"
#include "jerasure_init.h"
+#define dout_context g_ceph_context
+
#define dout_subsys ceph_subsys_osd
#undef dout_prefix
#define dout_prefix _prefix(_dout)
extern int* reed_sol_vandermonde_coding_matrix(int k, int m, int w);
}
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_osd
#undef dout_prefix
#define dout_prefix _prefix(_dout)
// -----------------------------------------------------------------------------
// -----------------------------------------------------------------------------
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_osd
#undef dout_prefix
#define dout_prefix _tc_prefix(_dout)
#include <sys/prctl.h>
#endif
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_
static void global_init_set_globals(CephContext *cct)
// logging is not functional when it is called. cerr output is lost
// when the caller is daemonized but it will show if not (-f)
//
+#define dout_context g_ceph_context
#define dout_prefix *_dout
#define dout_subsys ceph_subsys_
extern char *sys_siglist[];
#endif
+#define dout_context g_ceph_context
+
void install_sighandler(int signum, signal_handler_t handler, int flags)
{
int ret;
#include "common/debug.h"
#include "common/perf_counters.h"
+#define dout_context cct
#define dout_subsys ceph_subsys_leveldb
#undef dout_prefix
#define dout_prefix *_dout << "leveldb: "
#include "common/errno.h"
#include "include/compat.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_memdb
#undef dout_prefix
#define dout_prefix *_dout << "memdb: "
#include "common/debug.h"
+#define dout_context cct
#define dout_subsys ceph_subsys_rocksdb
#undef dout_prefix
#define dout_prefix *_dout << "rocksdb: "
#include "Beacon.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef dout_prefix
#define dout_prefix *_dout << "mds.beacon." << name << ' '
#include "messages/MLock.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef dout_prefix
#define dout_prefix *_dout << "mds." << dir->cache->mds->get_nodeid() << ".cache.den(" << dir->dirfrag() << " " << name << ") "
-ostream& CDentry::print_db_line_prefix(ostream& out)
+ostream& CDentry::print_db_line_prefix(ostream& out)
{
return out << ceph_clock_now() << " mds." << dir->cache->mds->get_nodeid() << ".cache.den(" << dir->ino() << " " << name << ") ";
}
#include "include/assert.h"
#include "include/compat.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef dout_prefix
#define dout_prefix *_dout << "mds." << cache->mds->get_nodeid() << ".cache.dir(" << this->dirfrag() << ") "
#include "mds/MDSContinuation.h"
#include "mds/InoTable.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef dout_prefix
#define dout_prefix *_dout << "mds." << mdcache->mds->get_nodeid() << ".cache.ino(" << inode.ino << ") "
#include <set>
#include <map>
+#define dout_context g_ceph_context
+
class Context;
class CDentry;
class CDir;
ostream& operator<<(ostream& out, const CInode::scrub_stamp_info_t& si);
+#undef dout_context
#endif
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
+// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
/*
* Ceph - scalable distributed file system
*
* This is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
- * License version 2.1, as published by the Free Software
+ * License version 2.1, as published by the Free Software
* Foundation. See file COPYING.
- *
+ *
*/
#include "common/debug.h"
#include "DamageTable.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef dout_prefix
#define dout_prefix *_dout << "mds." << rank << ".damage " << __func__ << " "
#include "common/config.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef dout_prefix
#define dout_prefix *_dout << "mds." << rank << "." << table_name << ": "
#include "mds/JournalPointer.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_journaler
#undef dout_prefix
#define dout_prefix *_dout << objecter->messenger->get_myname() << ".journalpointer "
#undef dout_prefix
#undef DOUT_COND
#define DOUT_COND(cct, l) l<=cct->_conf->debug_mds || l <= cct->_conf->debug_mds_locker
+#define dout_context g_ceph_context
#define dout_prefix _prefix(_dout, mds)
static ostream& _prefix(std::ostream *_dout, MDSRank *mds) {
return *_dout << "mds." << mds->get_nodeid() << ".locker ";
<< " on " << *lock->get_parent() << dendl;
scatter_nudge(lock, 0, true);
mds->mdlog->flush();
- }
+ }
break;
default:
#include "events/ENoOp.h"
+#define dout_context g_ceph_context
+
LogEvent *LogEvent::decode(bufferlist& bl)
{
#include "common/config.h"
#include "common/errno.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef DOUT_COND
#define DOUT_COND(cct, l) l<=cct->_conf->debug_mds || l <= cct->_conf->debug_mds_balancer
#include "common/config.h"
#include "include/assert.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef dout_prefix
#define dout_prefix _prefix(_dout, mds)
}
-//
+//
bool MDCache::shutdown()
{
#include "common/errno.h"
#include "include/assert.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef DOUT_COND
#define DOUT_COND(cct, l) l<=cct->_conf->debug_mds || l <= cct->_conf->debug_mds_log
#include "MDSContext.h"
#include "common/dout.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
-
void MDSInternalContextBase::complete(int r) {
MDSRank *mds = get_mds();
#include "perfglue/cpu_profiler.h"
#include "perfglue/heap_profiler.h"
-
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef dout_prefix
#define dout_prefix *_dout << "mds." << name << ' '
#include "MDSRank.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef dout_prefix
#define dout_prefix *_dout << "mds." << whoami << '.' << incarnation << ' '
#include "include/assert.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef dout_prefix
#define dout_prefix *_dout << "mds." << rank << "." << table_name << ": "
#include "common/config.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef dout_prefix
#define dout_prefix *_dout << "mds." << mds->get_nodeid() << ".tableclient(" << get_mdstable_name(table) << ") "
#include "messages/MMDSTableRequest.h"
#include "events/ETableServer.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef dout_prefix
#define dout_prefix *_dout << "mds." << rank << ".tableserver(" << get_mdstable_name(table) << ") "
#include <fstream>
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds_balancer
#undef DOUT_COND
#define DOUT_COND(cct, l) l<=cct->_conf->debug_mds || l <= cct->_conf->debug_mds_balancer
#include "common/config.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef DOUT_COND
#define DOUT_COND(cct, l) (l <= cct->_conf->debug_mds || l <= cct->_conf->debug_mds_migrator)
#include "RecoveryQueue.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef dout_prefix
#define dout_prefix *_dout << "mds." << mds->get_nodeid() << " RecoveryQueue::" << __func__ << " "
#include "mds/MDCache.h"
#include "mds/MDSContinuation.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef dout_prefix
#define dout_prefix _prefix(_dout, scrubstack->mdcache->mds)
#include "common/config.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef dout_prefix
#define dout_prefix *_dout << "mds." << mds->get_nodeid() << ".server "
}
// active?
- if (!mds->is_active() &&
+ if (!mds->is_active() &&
!(mds->is_stopping() && m->get_source().is_mds())) {
if (m->get_type() == CEPH_MSG_CLIENT_REQUEST &&
(mds->is_reconnect() || mds->get_want_state() == CEPH_MDS_STATE_RECONNECT)) {
#include "include/assert.h"
#include "include/stringify.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef dout_prefix
#define dout_prefix *_dout << "mds." << rank << ".sessionmap "
* SnapRealm
*/
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef dout_prefix
#define dout_prefix _prefix(_dout, mdcache->mds->get_nodeid(), inode, srnode.seq, this)
#include "common/config.h"
#include "include/assert.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef dout_prefix
#define dout_prefix *_dout << "mds." << rank << ".snap "
#include "StrayManager.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef dout_prefix
#define dout_prefix _prefix(_dout, mds)
#include "Locker.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef DOUT_COND
#define DOUT_COND(cct, l) (l<=cct->_conf->debug_mds || l <= cct->_conf->debug_mds_log \
#include "mgr/ClusterState.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mgr
#undef dout_prefix
#define dout_prefix *_dout << "mgr " << __func__ << " "
#include "messages/MCommandReply.h"
#include "messages/MPGStats.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mgr
#undef dout_prefix
#define dout_prefix *_dout << "mgr.server " << __func__ << " "
#include "DaemonState.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mgr
#undef dout_prefix
#define dout_prefix *_dout << "mgr " << __func__ << " "
#include "Mgr.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mgr
#undef dout_prefix
#define dout_prefix *_dout << "mgr " << __func__ << " "
#include "MgrPyModule.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mgr
#undef dout_prefix
#define dout_prefix *_dout << "mgr " << __func__ << " "
#include "MgrStandby.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mgr
#undef dout_prefix
#define dout_prefix *_dout << "mgr " << __func__ << " "
#include "PyModules.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mgr
#undef dout_prefix
#define dout_prefix *_dout << "mgr " << __func__ << " "
#include "PyState.h"
+#define dout_context g_ceph_context
+
PyModules *global_handle = NULL;
#include "common/debug.h"
#include "common/safe_io.h"
+#define dout_context g_ceph_context
+
class MonitorDBStore
{
string path;
#include "osd/osd_types.h"
#include "osd/OSDMap.h"
+#define dout_context g_ceph_context
+
// --
void PGMap::Incremental::encode(bufferlist &bl, uint64_t features) const
static ClassHandler *ch;
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_objclass
void cls_initialize(ClassHandler *h)
#include <sys/mount.h>
#endif
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_fuse
#include "common/debug.h"
#undef dout_prefix
#include "BitMapAllocator.h"
#include "common/debug.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_bluestore
Allocator *Allocator::create(string type,
#include "common/debug.h"
#include <math.h>
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_bluestore
#undef dout_prefix
#define dout_prefix *_dout << "bitalloc:"
#include "bluestore_types.h"
#include "common/debug.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_bluestore
#undef dout_prefix
#define dout_prefix *_dout << "bitmapalloc:"
#include "common/debug.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_bluestore
#undef dout_prefix
#define dout_prefix *_dout << "freelist "
#include "common/debug.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_bdev
#undef dout_prefix
#define dout_prefix *_dout << "bdev "
#include "BlockDevice.h"
#include "Allocator.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_bluefs
#undef dout_prefix
#define dout_prefix *_dout << "bluefs "
#include "BlueRocksEnv.h"
#include "auth/Crypto.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_bluestore
// bluestore_meta_onode
#include "common/debug.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_bluestore
#undef dout_prefix
#define dout_prefix *_dout << "freelist "
#include "common/blkdev.h"
#include "common/align.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_bdev
#undef dout_prefix
#define dout_prefix *_dout << "bdev(" << path << ") "
#include "bluestore_types.h"
#include "common/debug.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_bluestore
#undef dout_prefix
#define dout_prefix *_dout << "stupidalloc "
#if defined(__linux__)
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_filestore
#undef dout_prefix
#define dout_prefix *_dout << "btrfsfilestorebackend(" << get_basedir_path() << ") "
#include "common/config.h"
#include "include/assert.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_filestore
#undef dout_prefix
#define dout_prefix *_dout << "filestore "
#define O_DSYNC O_SYNC
#endif
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_journal
#undef dout_prefix
#define dout_prefix *_dout << "journal "
# include <libaio.h>
#endif
+#define dout_context g_ceph_context
+
+
/**
* Implements journaling on top of block device or file.
*
WRITE_CLASS_ENCODER(FileJournal::header_t)
+#undef dout_context
#endif
#define tracepoint(...)
#endif
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_filestore
#undef dout_prefix
#define dout_prefix *_dout << "filestore(" << basedir << ") "
#define SLOPPY_CRC_XATTR "user.cephos.scrc"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_filestore
#undef dout_prefix
#define dout_prefix *_dout << "genericfilestorebackend(" << get_basedir_path() << ") "
#include "common/errno.h"
#include "common/debug.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_filestore
const string HashIndex::SUBDIR_ATTR = "contents";
#include "common/errno.h"
#include "common/debug.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_journal
#undef dout_prefix
#define dout_prefix *_dout << "journal "
#include "LFNIndex.h"
using ceph::crypto::SHA1;
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_filestore
#undef dout_prefix
#define dout_prefix *_dout << "LFNIndex(" << get_base_path() << ") "
#include "include/assert.h"
#include "include/compat.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_filestore
#undef dout_prefix
#define dout_prefix *_dout << "xfsfilestorebackend(" << get_basedir_path() << ") "
#include "common/Formatter.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_kstore
/*
#include "MemStore.h"
#include "include/compat.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_filestore
#undef dout_prefix
#define dout_prefix *_dout << "memstore(" << path << ") "
#include "common/config.h"
#include "common/debug.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_osd
#undef dout_prefix
#define dout_prefix *_dout
#include "PrimaryLogPG.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_osd
#define DOUT_PREFIX_ARGS this
#undef dout_prefix
#define tracepoint(...)
#endif
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_osd
#undef dout_prefix
#define dout_prefix _prefix(_dout, whoami, get_osdmap_epoch())
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
+// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
/*
* Ceph - scalable distributed file system
*
* This is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
- * License version 2.1, as published by the Free Software
+ * License version 2.1, as published by the Free Software
* Foundation. See file COPYING.
- *
+ *
*/
#include "PG.h"
#include <sstream>
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_osd
#undef dout_prefix
#define dout_prefix _prefix(_dout, this)
#include "PGLog.h"
#include "common/LogClient.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_osd
#define DOUT_PREFIX_ARGS this
#undef dout_prefix
#include "include/unordered_map.h"
#include "common/ceph_context.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_osd
#undef dout_prefix
#define dout_prefix _prefix(_dout, this)
#define PGLOG_INDEXED_EXTRA_CALLER_OPS (1 << 2)
#define PGLOG_INDEXED_ALL (PGLOG_INDEXED_OBJECTS | PGLOG_INDEXED_CALLER_OPS | PGLOG_INDEXED_EXTRA_CALLER_OPS)
+#define dout_context g_ceph_context
+
class CephContext;
struct PGLog : DoutPrefixProvider {
PGLog(CephContext *cct, DoutPrefixProvider *dpp = 0) :
prefix_provider(dpp),
dirty_from(eversion_t::max()),
- writeout_from(eversion_t::max()),
- cct(cct),
+ writeout_from(eversion_t::max()),
+ cct(cct),
pg_log_debug(!(cct && !(cct->_conf->osd_debug_pg_log_writeout))),
touched_log(false),
clear_divergent_priors(false) {}
ldpp_dout(dpp, 10) << "read_log_and_missing done" << dendl;
}
};
-
+
+#undef dout_context
+
#endif // CEPH_PG_LOG_H
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
+// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
/*
* Ceph - scalable distributed file system
*
* This is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
- * License version 2.1, as published by the Free Software
+ * License version 2.1, as published by the Free Software
* Foundation. See file COPYING.
- *
+ *
*/
#include "boost/tuple/tuple.hpp"
#define tracepoint(...)
#endif
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_osd
#define DOUT_PREFIX_ARGS this, osd->whoami, get_osdmap()
#undef dout_prefix
#include "messages/MOSDPGPull.h"
#include "messages/MOSDPGPushReply.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_osd
#define DOUT_PREFIX_ARGS this
#undef dout_prefix
#include "SnapMapper.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_osd
#undef dout_prefix
#define dout_prefix *_dout << "snap_mapper."
virtual void cancel() = 0;
};
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_osd
#undef dout_prefix
#define dout_prefix _prefix(_dout, this)
#include "global/global_context.h"
#include "common/debug.h"
+#define dout_context g_ceph_context
+
bool ceph_using_tcmalloc()
{
return true;
#include "PendingIO.hpp"
#include "rbd_replay_debug.hpp"
+#define dout_context g_ceph_context
using namespace std;
using namespace rbd_replay;
#include "global/global_context.h"
#include "rbd_replay_debug.hpp"
+#define dout_context g_ceph_context
using namespace std;
using namespace rbd_replay;
#include "PendingIO.hpp"
#include "rbd_replay_debug.hpp"
+#define dout_context g_ceph_context
using namespace rbd_replay;
using namespace std;
using namespace std;
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
#define SECRET_KEY_LEN 40
#include "rgw_asio_client.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
#undef dout_prefix
#include "include/str_list.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
#include "rgw_client_io.h"
#include "rgw_rest.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
static const char *signed_subresources[] = {
#include "cls/user/cls_user_types.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
#define BUCKET_TAG_TIMEOUT 30
#define dout_subsys ceph_subsys_civetweb
+#define dout_context g_ceph_context
int rgw_civetweb_log_callback(const struct mg_connection *conn, const char *buf) {
dout(0) << "civetweb: " << (void *)conn << ": " << buf << dendl;
return 0;
#include <sstream>
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
PerfCounters *perfcounter = NULL;
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
+// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
/*
* Ceph - scalable distributed file system
#include <iostream>
#include <map>
-#include <boost/algorithm/string.hpp>
+#include <boost/algorithm/string.hpp>
#include "include/types.h"
#include "common/debug.h"
#include "rgw_cors.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
using namespace std;
#include "rgw_cors_s3.h"
#include "rgw_user.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
using namespace std;
#include "cls/lock/cls_lock_client.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
bool RGWAsyncRadosProcessor::RGWWQ::_enqueue(RGWAsyncRadosRequest *req) {
#include <string>
#include <map>
-
#include "include/assert.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
void RGWEnv::init(CephContext *cct)
#include "include/assert.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
int RGWFrontendConfig::parse_config(const string& config,
#include "rgw_civetweb_log.h"
#include "civetweb/civetweb.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
class RGWFrontendConfig {
#include <list>
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
using namespace std;
#include "rgw_coroutine.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
struct rgw_http_req_data : public RefCountedObject {
#include "common/ceph_json.h"
#include "common/Formatter.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
void encode_json(const char *name, const obj_version& v, Formatter *f)
#include "common/armor.h"
#include "common/Cond.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
int rgw_open_cms_envelope(CephContext * const cct,
#include "rgw_lc_s3.h"
-
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
const char* LC_STATUS[] = {
#include "cls/lock/cls_lock_client.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
static string objexp_lock_name = "gc_process";
#include "compressor/Compressor.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
using namespace std;
#include "rgw_common.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
class RGWPolicyCondition {
#define def_dout_subsys
#endif
+#define dout_context g_ceph_context
extern void signal_shutdown();
#undef def_dout_subsys
#undef dout_subsys
#endif
+#undef dout_context
#endif /* RGW_PROCESS_H */
#include "rgw_bucket.h"
#include "rgw_user.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
#include "compressor/Compressor.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
using namespace std;
#include "rgw_op.h"
#include "rgw_request.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
/* XXX */
#include "common/strtol.h"
#include "include/str_list.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
int RGWRESTSimpleRequest::get_status()
#include "common/errno.h"
#include "include/assert.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
void RGWOp_ZoneGroupMap_Get::execute() {
#include "common/errno.h"
#include "include/assert.h"
+#define dout_context g_ceph_context
#define LOG_CLASS_LIST_MAX_ENTRIES (1000)
#define dout_subsys ceph_subsys_rgw
#include "common/strtol.h"
#include "include/assert.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
const string RGWOp_Metadata_Get::name() {
#include "common/errno.h"
#include "include/assert.h"
+#define dout_context g_ceph_context
#define OPSTATE_LIST_MAX_ENTRIES 1000
#define dout_subsys ceph_subsys_rgw
#include "common/errno.h"
#include "include/assert.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
#define REPLICA_INPUT_MAX_LEN (512*1024)
#include "rgw_token.h"
#include "include/assert.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
using namespace rgw;
#include <boost/utility/string_ref.hpp>
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
int RGWListBuckets_ObjStore_SWIFT::get_params()
#include "rgw_http_client.h"
#include "include/str_list.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
#define DEFAULT_SWIFT_PREFIX "/swift"
#include <sstream>
#include <string>
+#define dout_context g_ceph_context
using std::string;
// avoid compiler warning about dereferencing NULL pointer
#include "common/ceph_argparse.h"
#include "global/global_init.h"
+#define dout_context g_ceph_context
+
struct T : public Thread {
int num;
set<int> myset;
#include "include/assert.h"
#include "include/compat.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rados
namespace {
#include "common/debug.h"
#include "include/assert.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rados
namespace librados {
-// -*- mode:C; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
+// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
#include "test/librbd/test_mock_fixture.h"
#include <list>
#include <boost/scope_exit.hpp>
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd
namespace librbd {
#include "common/debug.h"
#include "global/global_init.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
namespace {
#include "common/debug.h"
#include "global/global_init.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rgw
namespace {
#include "messages/MGenericMessage.h"
#include "messages/MMonJoin.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_
#undef dout_prefix
#define dout_prefix *_dout << "test-mon-msg "
using namespace std;
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_
#undef dout_prefix
#define dout_prefix _prefix(_dout, get_name())
#include "common/config.h"
#include "include/assert.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_filestore
#undef dout_prefix
#define dout_prefix *_dout << "deterministic_seq "
#include "FileStoreDiff.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_filestore
#undef dout_prefix
#define dout_prefix *_dout << "filestore_diff "
#include "TestObjectStoreState.h"
#include "include/assert.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_filestore
#undef dout_prefix
#define dout_prefix *_dout << "ceph_test_objectstore_state "
#include "common/config.h"
#include "include/assert.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_
#undef dout_prefix
#define dout_prefix *_dout << "test_idempotent_sequence "
#include "common/errno.h"
#include "store_test_fixture.h"
+#define dout_context g_ceph_context
+
namespace {
const coll_t cid;
#include "TestObjectStoreState.h"
+#define dout_context g_ceph_context
+
static const char *our_name = NULL;
void usage();
#include "common/strtol.h"
#include "common/ceph_argparse.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_filestore
static void usage()
#include "MemWriteback.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_objectcacher
#undef dout_prefix
#define dout_prefix *_dout << "MemWriteback(" << this << ") "
#include <string>
#include <vector>
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
#define dout_prefix *_dout << "random-write: "
#include "include/assert.h"
+#define dout_context g_ceph_context
static volatile sig_atomic_t got_sigusr1 = 0;
static void handle_sigusr1(int signo)
#include "global/global_init.h"
#include "include/assert.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_filestore
#undef dout_prefix
#define dout_prefix *_dout
#define AES_KEY_LEN 16
+#define dout_context g_ceph_context
+
int main(int argc, char *argv[])
{
char aes_key[AES_KEY_LEN];
#include "common/config.h"
#include "common/debug.h"
+#define dout_context g_ceph_context
+
#define AES_KEY_LEN 16
int main(int argc, const char **argv)
#include "client/Dir.h"
#include "include/cephfs/libcephfs.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_client
void usage()
#include "DataScan.h"
#include "include/compat.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef dout_prefix
#define dout_prefix *_dout << "datascan." << __func__ << ": "
#include "Dumper.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#define HEADER_LEN 4096
#include "mds/events/ESession.h"
#include "mds/events/EUpdate.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#include "JournalScanner.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
/**
#include "JournalTool.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef dout_prefix
#define dout_prefix *_dout << __func__ << ": "
#include "MDSUtility.h"
#include "mon/MonClient.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#include "PgFiles.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef dout_prefix
#define dout_prefix *_dout << "pgeffects." << __func__ << ": "
#include "Resetter.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
int Resetter::reset(mds_role_t role)
#include "TableTool.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#undef dout_prefix
#define dout_prefix *_dout << __func__ << ": "
#include "crush/CrushTester.h"
#include "include/assert.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_crush
using namespace std;
using namespace librados;
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rados
/**
#include "osd/PGLog.h"
#include "RadosImport.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rados
int RadosImport::import(std::string pool, bool no_overwrite)
#include <iostream>
#include <boost/program_options.hpp>
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd
namespace rbd {
#include <iostream>
#include <boost/program_options.hpp>
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd
namespace rbd {
#include "ClusterWatcher.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
#define dout_prefix *_dout << "rbd::mirror::ClusterWatcher:" << this << " " \
#include "librbd/Utils.h"
#include "ImageDeleter.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
#define dout_prefix *_dout << "rbd::mirror::ImageDeleter: " << this << " " \
#include "tools/rbd_mirror/image_replayer/EventPreprocessor.h"
#include "tools/rbd_mirror/image_replayer/ReplayStatusFormatter.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
#define dout_prefix *_dout << "rbd::mirror::" << *this << " " \
#include "tools/rbd_mirror/image_sync/SyncPointCreateRequest.h"
#include "tools/rbd_mirror/image_sync/SyncPointPruneRequest.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
#define dout_prefix *_dout << "rbd::mirror::ImageSync: " \
#include "ImageSync.h"
#include "common/ceph_context.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
#define dout_prefix *_dout << "rbd::mirror::ImageSyncThrottler:: " << this \
#include "Threads.h"
#include "ImageSync.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
#define dout_prefix *_dout << "rbd::mirror::Mirror: " << this << " " \
#include "PoolWatcher.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
#define dout_prefix *_dout << "rbd::mirror::PoolWatcher: " << this << " " \
#include "Replayer.h"
#include "Threads.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
#define dout_prefix *_dout << "rbd::mirror::Replayer: " \
#include "tools/rbd_mirror/ProgressContext.h"
#include "tools/rbd_mirror/ImageSyncThrottler.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
#define dout_prefix *_dout << "rbd::mirror::image_replayer::BootstrapRequest: " \
#include "librbd/ImageState.h"
#include "librbd/Utils.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
#define dout_prefix *_dout << "rbd::mirror::image_replayer::CloseImageRequest: " \
#include "librbd/Utils.h"
#include "librbd/image/CreateRequest.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
#define dout_prefix *_dout << "rbd::mirror::image_replayer::CreateImageRequest: " \
#include "librbd/journal/Types.h"
#include <boost/variant.hpp>
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
#include "librbd/Utils.h"
#include <type_traits>
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
#define dout_prefix *_dout << "rbd::mirror::image_replayer::OpenImageRequest: " \
#include "librbd/journal/Policy.h"
#include <type_traits>
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
#define dout_prefix *_dout << "rbd::mirror::image_replayer::OpenLocalImageRequest: " \
#include "librbd/Journal.h"
#include "librbd/Utils.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
#define dout_prefix *_dout << "rbd::mirror::image_replayer::ReplayStatusFormatter: " \
#include "librbd/Utils.h"
#include "tools/rbd_mirror/ProgressContext.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
#define dout_prefix *_dout << "rbd::mirror::image_sync::ImageCopyRequest: " \
#include "librbd/Utils.h"
#include "common/errno.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
#define dout_prefix *_dout << "rbd::mirror::image_sync::ObjectCopyRequest: " \
#include "librbd/Utils.h"
#include "librbd/journal/Types.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
#define dout_prefix *_dout << "rbd::mirror::image_sync::SnapshotCopyRequest: " \
#include "librbd/Utils.h"
#include "osdc/Striper.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
#define dout_prefix *_dout << "rbd::mirror::image_sync::SnapshotCreateRequest: " \
#include "librbd/Operations.h"
#include "librbd/Utils.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
#define dout_prefix *_dout << "rbd::mirror::image_sync::SyncPointCreateRequest: " \
#include "librbd/Utils.h"
#include <set>
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
#define dout_prefix *_dout << "rbd::mirror::image_sync::SyncPointPruneRequest: " \
#include "include/rbd/librbd.hpp"
#include "include/xlist.h"
+#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd
#undef dout_prefix
#define dout_prefix *_dout << "rbd-nbd: "