| 1616 | |
| 1617 | |
| 1618 | Future<Nothing> MesosContainerizerProcess::fetch( |
| 1619 | const ContainerID& containerId) |
| 1620 | { |
| 1621 | if (!containers_.contains(containerId)) { |
| 1622 | return Failure("Container destroyed during isolating"); |
| 1623 | } |
| 1624 | |
| 1625 | const Owned<Container>& container = containers_.at(containerId); |
| 1626 | |
| 1627 | if (container->state == DESTROYING) { |
| 1628 | return Failure("Container is being destroyed during isolating"); |
| 1629 | } |
| 1630 | |
| 1631 | CHECK_EQ(container->state, ISOLATING); |
| 1632 | |
| 1633 | transition(containerId, FETCHING); |
| 1634 | |
| 1635 | CHECK_SOME(container->config); |
| 1636 | |
| 1637 | const string directory = container->config->directory(); |
| 1638 | |
| 1639 | return fetcher->fetch( |
| 1640 | containerId, |
| 1641 | container->config->command_info(), |
| 1642 | directory, |
| 1643 | container->config->has_user() |
| 1644 | ? container->config->user() |
| 1645 | : Option<string>::none()) |
| 1646 | .then([=]() -> Future<Nothing> { |
| 1647 | if (HookManager::hooksAvailable()) { |
| 1648 | HookManager::slavePostFetchHook(containerId, directory); |
| 1649 | } |
| 1650 | return Nothing(); |
| 1651 | }); |
| 1652 | } |
| 1653 | |
| 1654 | |
| 1655 | Future<Containerizer::LaunchResult> MesosContainerizerProcess::_launch( |