17 #ifndef __XFS_DISK_ISOLATOR_HPP__ 18 #define __XFS_DISK_ISOLATOR_HPP__ 55 const std::vector<mesos::slave::ContainerState>& states,
59 const ContainerID& containerId,
60 const mesos::slave::ContainerConfig& containerConfig)
override;
63 const ContainerID& containerId)
override;
66 const ContainerID& containerId,
68 const google::protobuf::Map<
69 std::string, Value::Scalar>& resourceLimits = {})
override;
72 const ContainerID& containerId)
override;
75 const ContainerID& containerId)
override;
90 Info(
const std::string& directory, prid_t
projectId)
100 std::string deviceName;
107 const std::string& workDir,
122 void reclaimProjectIds();
125 prid_t projectId,
const std::string& rootDir);
128 const Duration projectWatchInterval;
130 const std::string workDir;
154 #endif // __XFS_DISK_ISOLATOR_HPP__ process::Future< mesos::slave::ContainerLimitation > watch(const ContainerID &containerId) override
void initialize() override
Invoked when a process gets spawned.
~XfsDiskIsolatorProcess() override
Definition: resources.hpp:83
std::string paths()
Definition: os.hpp:138
const prid_t projectId
Definition: disk.hpp:86
Definition: duration.hpp:32
process::Future< Option< mesos::slave::ContainerLaunchInfo > > prepare(const ContainerID &containerId, const mesos::slave::ContainerConfig &containerConfig) override
Definition: hashmap.hpp:38
const Option< Resource::DiskInfo > disk
Definition: disk.hpp:87
process::Future< Nothing > cleanup(const ContainerID &containerId) override
static Try< mesos::slave::Isolator * > create(const Flags &flags)
process::Future< ResourceStatistics > usage(const ContainerID &containerId) override
Definition: isolator.hpp:82
Bytes quota
Definition: disk.hpp:85
process::Future< Nothing > update(const ContainerID &containerId, const Resources &resourceRequests, const google::protobuf::Map< std::string, Value::Scalar > &resourceLimits={}) override
QuotaPolicy
Definition: utils.hpp:79
A "process identifier" used to uniquely identify a process when dispatching messages.
Definition: pid.hpp:289
Definition: attributes.hpp:24
process::Future< Nothing > recover(const std::vector< mesos::slave::ContainerState > &states, const hashset< ContainerID > &orphans) override
Definition: push_gauge.hpp:41