private static void startNetworkServices ( ) { // We've rebooted the JVM recently. Tell other Nodes they can ignore task // prior tasks by us. Do this before we receive any packets UDPRebooted . T . reboot . broadcast ( ) ; // Start the MultiReceiverThread, to listen for multi-cast requests from // other Cloud Nodes. There should be only 1 of these, and it never shuts // down. Started soon, so we can start parsing multi-cast UDP packets new MultiReceiverThread ( ) . start ( ) ; // Start the Persistent meta-data cleaner thread, which updates the K/V // mappings periodically to disk. There should be only 1 of these, and it // never shuts down. Needs to start BEFORE the HeartBeatThread to build // an initial histogram state. Cleaner . THE_CLEANER . start ( ) ; // Start the TCPReceiverThread, to listen for TCP requests from other Cloud // Nodes. There should be only 1 of these, and it never shuts down. new TCPReceiverThread ( NetworkInit . _tcpSocket ) . start ( ) ; }
Starts the worker threads receiver threads heartbeats and all other network related services .