Calling 'stop(true)' will still stop the driver (we need to invoke 'terminate(self())'), but it won't send an unregister to the master. Hope that helps.
On Sun, Jun 29, 2014 at 7:52 AM, Vladimir Vivien <[email protected]> wrote: > Looking at the code in SchedulerProcess.Stop(failover) in sched.cpp, it > looks like the framework is unregistered only when when failover = false. > Is it the case when failover = true that the stop command is ignored ? > > ==== sched.cpp ==== > void stop(bool failover) > { > LOG(INFO) << "Stopping framework '" << framework.id() << "'"; > > // Whether or not we send an unregister message, we want to > // terminate this process. > terminate(self()); > > if (connected && !failover) { > UnregisterFrameworkMessage message; > message.mutable_framework_id()->MergeFrom(framework.id()); > CHECK_SOME(master); > send(master.get(), message); > } > > Lock lock(mutex); > pthread_cond_signal(cond); > } > > -- > Vladimir Vivien >
