#pragma once #include #include #include #include #include #include #include class HardlinkMsgEx : public MirroredMessage> { public: typedef ErrorCodeResponseState ResponseState; virtual bool processIncoming(ResponseContext& ctx) override; std::tuple lock(EntryLockStore& store) override; bool isMirrored() override { return getFromInfo()->getIsBuddyMirrored(); } private: std::unique_ptr executeLocally(ResponseContext& ctx, bool isSecondary) override; void forwardToSecondary(ResponseContext& ctx) override; FhgfsOpsErr processSecondaryResponse(NetMessage& resp) override { return (FhgfsOpsErr) static_cast(resp).getValue(); } FhgfsOpsErr incDecRemoteLinkCount(NumNodeID const& ownerNodeID, bool increment); const char* mirrorLogContext() const override { return "HardlinkMsgEx/forward"; } };