cleanup and minor fixes...

Signed-off-by: Alex A. Naanou <alex.nanou@gmail.com>
This commit is contained in:
Alex A. Naanou 2019-07-25 18:22:37 +03:00
parent 058e88aa57
commit 2cb9a0706e

View File

@ -458,24 +458,32 @@ var LifeCycleActions = actions.Actions({
// ready timeout -> force ready... // ready timeout -> force ready...
this.config['declare-ready-timeout'] > 0 this.config['declare-ready-timeout'] > 0
&& setTimeout(function(){ && !this.__ready_announce_timeout
&& (this.__ready_announce_timeout =
setTimeout(function(){
// cleanup... // cleanup...
if((that.__ready_announce_requests || new Set()).size == 0){ delete this.__ready_announce_timeout
delete that.__ready_announce_requests if((this.__ready_announce_requests || new Set()).size == 0){
delete this.__ready_announce_requests
} }
// force start... // force start...
if(!that.isReady()){ if(!this.isReady()){
that.ready()
// report... // report...
that.logger this.logger
&& that.logger.psuh('start') && this.logger.push('start')
.emit('forced ready.') .emit('forcing ready.')
.emit('stalled:', .emit('stalled:',
this.__ready_announce_requested, this.__ready_announce_requested,
...[this.__ready_announce_requests || []]) ...(this.__ready_announce_requests || []))
// force ready...
this.__ready = !!this.ready()
// cleanup...
delete this.__ready_announce_requested
delete this.__ready_announce_requests
} }
}, this.config['declare-ready-timeout']) }.bind(this), this.config['declare-ready-timeout']))
// trigger the started event... // trigger the started event...
this.started() this.started()