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

Function registerSlave

src/master/validation.cpp:327–351  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

325
326
327Option<Error> registerSlave(const RegisterSlaveMessage& message)
328{
329 const SlaveInfo& slaveInfo = message.slave();
330
331 Option<Error> error = validateSlaveInfo(slaveInfo);
332 if (error.isSome()) {
333 return error.get();
334 }
335
336 if (!message.checkpointed_resources().empty()) {
337 if (!slaveInfo.has_checkpoint() || !slaveInfo.checkpoint()) {
338 return Error(
339 "Checkpointed resources provided when checkpointing is not enabled");
340 }
341 }
342
343 foreach (const Resource& resource, message.checkpointed_resources()) {
344 error = Resources::validate(resource);
345 if (error.isSome()) {
346 return error.get();
347 }
348 }
349
350 return None();
351}
352
353
354Option<Error> reregisterSlave(const ReregisterSlaveMessage& message)

Callers 1

registerSlaveMethod · 0.85

Calls 7

validateSlaveInfoFunction · 0.85
NoneClass · 0.85
checkpointMethod · 0.80
ErrorFunction · 0.50
isSomeMethod · 0.45
getMethod · 0.45
emptyMethod · 0.45

Tested by

no test coverage detected