| 770 | |
| 771 | |
| 772 | Try<Nothing> DockerContainerizerProcess::checkpoint( |
| 773 | const ContainerID& containerId, |
| 774 | pid_t pid) |
| 775 | { |
| 776 | CHECK(containers_.contains(containerId)); |
| 777 | |
| 778 | Container* container = containers_.at(containerId); |
| 779 | |
| 780 | container->executorPid = pid; |
| 781 | |
| 782 | if (container->pidCheckpointPath.isSome()) { |
| 783 | LOG(INFO) << "Checkpointing pid " << pid |
| 784 | << " to '" << container->pidCheckpointPath.get() << "'"; |
| 785 | |
| 786 | return slave::state::checkpoint( |
| 787 | container->pidCheckpointPath.get(), stringify(pid)); |
| 788 | } |
| 789 | |
| 790 | return Nothing(); |
| 791 | } |
| 792 | |
| 793 | |
| 794 | Future<Nothing> DockerContainerizer::recover( |