TODO(bernd-mesos): Make this abstractions as generic and generally available for all testing as possible.
| 321 | // TODO(bernd-mesos): Make this abstractions as generic and generally |
| 322 | // available for all testing as possible. |
| 323 | void FetcherCacheTest::startSlave() |
| 324 | { |
| 325 | fetcherProcess = new MockFetcherProcess(flags); |
| 326 | fetcher.reset(new Fetcher(Owned<FetcherProcess>(fetcherProcess))); |
| 327 | |
| 328 | Try<MesosContainerizer*> create = MesosContainerizer::create( |
| 329 | flags, true, fetcher.get()); |
| 330 | |
| 331 | ASSERT_SOME(create); |
| 332 | containerizer.reset(create.get()); |
| 333 | |
| 334 | Future<SlaveRegisteredMessage> slaveRegisteredMessage = |
| 335 | FUTURE_PROTOBUF(SlaveRegisteredMessage(), _, _); |
| 336 | |
| 337 | detector = master->createDetector(); |
| 338 | |
| 339 | Try<Owned<cluster::Slave>> _slave = |
| 340 | StartSlave(detector.get(), containerizer.get(), flags); |
| 341 | ASSERT_SOME(_slave); |
| 342 | slave = _slave.get(); |
| 343 | |
| 344 | AWAIT_READY(slaveRegisteredMessage); |
| 345 | slaveId = slaveRegisteredMessage->slave_id(); |
| 346 | } |
| 347 | |
| 348 | |
| 349 | void FetcherCacheTest::setupCommandFileAsset() |
nothing calls this directly
no test coverage detected