void triggerControlTask ( ) { migrationQueue . clear ( ) ; if ( ! node . getClusterService ( ) . isJoined ( ) ) { logger . fine ( "Node is not joined, will not trigger ControlTask" ) ; return ; } if ( ! node . isMaster ( ) ) { logger . fine ( "Node is not master, will not trigger ControlTask" ) ; return ; } migrationQueue . add ( new ControlTask ( ) ) ; if ( logger . isFinestEnabled ( ) ) { logger . finest ( "Migration queue is cleared and control task is scheduled" ) ; } }
Clears the migration queue and triggers the control task . Called on the master node .