MCPcopy Create free account
hub / github.com/apache/mesos / startSlave

Method startSlave

src/tests/fetcher_cache_tests.cpp:323–346  ·  view source on GitHub ↗

TODO(bernd-mesos): Make this abstractions as generic and generally available for all testing as possible.

Source from the content-addressed store, hash-verified

321// TODO(bernd-mesos): Make this abstractions as generic and generally
322// available for all testing as possible.
323void 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
349void FetcherCacheTest::setupCommandFileAsset()

Callers

nothing calls this directly

Calls 4

createDetectorMethod · 0.80
createFunction · 0.50
resetMethod · 0.45
getMethod · 0.45

Tested by

no test coverage detected