#include "CDentry.h"
#include "CInode.h"
#include "CDir.h"
+#include "messages/MClientRequest.h"
+#include "messages/MMDSPeerRequest.h"
using namespace std;
// MDRequestImpl
+MDRequestImpl::Params::Params() = default;
+MDRequestImpl::Params::~Params() noexcept = default;
+
+MDRequestImpl::MDRequestImpl(const Params* params, OpTracker *tracker) :
+ MutationImpl(tracker, params->initiated,
+ params->reqid, params->attempt, params->peer_to),
+ item_session_request(this), client_request(params->client_req),
+ internal_op(params->internal_op) {}
+
MDRequestImpl::~MDRequestImpl()
{
delete _more;
#include "common/StackStringStream.h"
#include "common/TrackedOp.h"
-#include "messages/MClientRequest.h"
-#include "messages/MMDSPeerRequest.h"
class LogSegment;
class BatchOp;
class SimpleLock;
struct sr_t;
struct MDLockCache;
+class Message;
+class MClientRequest;
+class MMDSPeerRequest;
struct MutationImpl : public TrackedOp {
public:
// ---------------------------------------------------
struct Params {
// keep these default values synced to MutationImpl's
- Params() {}
+ Params();
+ ~Params() noexcept;
const utime_t& get_recv_stamp() const {
return initiated;
}
int internal_op = -1;
bool continuous = false;
};
- MDRequestImpl(const Params* params, OpTracker *tracker) :
- MutationImpl(tracker, params->initiated,
- params->reqid, params->attempt, params->peer_to),
- item_session_request(this), client_request(params->client_req),
- internal_op(params->internal_op) {}
+ MDRequestImpl(const Params* params, OpTracker *tracker);
~MDRequestImpl() override;
More* more();