harshana05 / epzilla Goto Github PK

java.lang.NullPointerException
        at org.epzilla.clusterNode.dataManager.ClusterIPManager.getNodeStatus(ClusterIPManager.java:59)
        at org.epzilla.clusterNode.nodeControler.WakeNode.wake(WakeNode.java:36)
        at org.epzilla.clusterNode.userInterface.NodeUI.actionPerformed(NodeUI.java:329)
        at javax.swing.AbstractButton.fireActionPerformed(Unknown Source)
        at javax.swing.AbstractButton$Handler.actionPerformed(Unknown Source)
        at javax.swing.DefaultButtonModel.fireActionPerformed(Unknown Source)
        at javax.swing.DefaultButtonModel.setPressed(Unknown Source)
        at javax.swing.plaf.basic.BasicButtonListener.mouseReleased(Unknown Source)
        at java.awt.Component.processMouseEvent(Unknown Source)
        at javax.swing.JComponent.processMouseEvent(Unknown Source)
        at java.awt.Component.processEvent(Unknown Source)
        at java.awt.Container.processEvent(Unknown Source)
        at java.awt.Component.dispatchEventImpl(Unknown Source)
        at java.awt.Container.dispatchEventImpl(Unknown Source)
        at java.awt.Component.dispatchEvent(Unknown Source)
        at java.awt.LightweightDispatcher.retargetMouseEvent(Unknown Source)
        at java.awt.LightweightDispatcher.processMouseEvent(Unknown Source)
        at java.awt.LightweightDispatcher.dispatchEvent(Unknown Source)
        at java.awt.Container.dispatchEventImpl(Unknown Source)
        at java.awt.Window.dispatchEventImpl(Unknown Source)
        at java.awt.Component.dispatchEvent(Unknown Source)
        at java.awt.EventQueue.dispatchEvent(Unknown Source)
        at java.awt.EventDispatchThread.pumpOneEventForFilters(Unknown Source)
        at java.awt.EventDispatchThread.pumpEventsForFilter(Unknown Source)
        at java.awt.EventDispatchThread.pumpEventsForHierarchy(Unknown Source)
        at java.awt.EventDispatchThread.pumpEvents(Unknown Source)
        at java.awt.EventDispatchThread.pumpEvents(Unknown Source)
        at java.awt.EventDispatchThread.run(Unknown Source)

Code segment is:

 public static boolean getNodeStatus(String nodeIP) {
        boolean status = false;
        if (getIpList() != null) {
                for (int i = 0; i < getIpList().size(); i++) {
                    if (getIpList().get(i).getIP().equals(nodeIP)) {
                        status = getIpList().get(i).getIsActive();
                        break;
                    }
                }           
        }
        return status;
    }

To be Exact:
    status = getIpList().get(i).getIsActive();

When running the dispatcher, every thing works fine and Leader election is also 
running and leader get started and then it should start the UI. But UI does not 
comeup.

Since we show the details of the cluster nodes and dispatchers in their UIs, 
when nodes/dispatchers are down, we need to update it. But there is no 
mechanism of identifying the dead nodes/dispatchers currently. So this is 
blocked till that happens.

Initial Work is done. 

This feature is already implemented in the Cluster Node but we sent to 
default addresses. Need to send these messages to the Dispatcher we have 
discovered. Discover is also implemented and they discover and register with 
existing dispatchers in the Dynamic Discovery component. We just need to get 
that list and send RMI messages to them. The list of dispatchers can be 
retrieved from the Cluster Nodes.

java.lang.NullPointerException
        at net.epzilla.stratification.dynamic.SystemVariables.getClusters(SystemVariables.java:133)
        at net.epzilla.stratification.restruct.SystemRestructure.redistribute(SystemRestructure.java:202)
        at net.epzilla.stratification.restruct.SystemRestructure.restructureSystem(SystemRestructure.java:76)
        at net.epzilla.stratification.restruct.RestructuringDaemon$1.run(RestructuringDaemon.java:114)

We need to show the clients of the cluster in the Leader's UI.

We need to integrate the LE for dispatchers and it is being developed in the 
Leader Election component.

It is better if we can integrate the Esper for our demo. This enhancement 
request will track the improvement of that work.

Initial system configuration using an XML definition.

Event Processing Engine Logic Development

We have currently working version assuming that the non-leader 
nodes/dispatcher do not die. If they die, we don't have a mechanism of 
identifying and updating the node list/dispatcher list. So we need to 
implement a mechanism to do this.

After the completion of feature 11, we need to integrate this with the nodes 
and/or dispatchers. 

Since we use dynamic load balancing we need to invoke and sleep the nodes. So 
we need to implement the infrastructure for that. The load balancing and 
measuring is currently implemented.

java.rmi.ConnectException: Connection refused to host: 192.168.1.251; nested 
exception is:
        java.net.ConnectException: Connection timed out: connect
        at sun.rmi.transport.tcp.TCPEndpoint.newSocket(Unknown Source)
        at sun.rmi.transport.tcp.TCPChannel.createConnection(Unknown Source)
        at sun.rmi.transport.tcp.TCPChannel.newConnection(Unknown Source)
        at sun.rmi.server.UnicastRef.invoke(Unknown Source)
        at java.rmi.server.RemoteObjectInvocationHandler.invokeRemoteMethod(Unknown Source)
        at java.rmi.server.RemoteObjectInvocationHandler.invoke(Unknown Source)
        at $Proxy7.restructuringStarted(Unknown Source)
        at net.epzilla.stratification.restruct.RestructuringDaemon$1.run(RestructuringDaemon.java:106)
Caused by: java.net.ConnectException: Connection timed out: connect
        at java.net.PlainSocketImpl.socketConnect(Native Method)
        at java.net.PlainSocketImpl.doConnect(Unknown Source)
        at java.net.PlainSocketImpl.connectToAddress(Unknown Source)
        at java.net.PlainSocketImpl.connect(Unknown Source)
        at java.net.SocksSocketImpl.connect(Unknown Source)
        at java.net.Socket.connect(Unknown Source)
        at java.net.Socket.connect(Unknown Source)
        at java.net.Socket.<init>(Unknown Source)
        at java.net.Socket.<init>(Unknown Source)
        at sun.rmi.transport.proxy.RMIDirectSocketFactory.createSocket(Unknown Source)
        at sun.rmi.transport.proxy.RMIMasterSocketFactory.createSocket(Unknown Source)
        ... 8 more
Error: invalid syntax?
java.util.ConcurrentModificationException
        at java.util.HashMap$HashIterator.nextEntry(Unknown Source)
        at java.util.HashMap$KeyIterator.next(Unknown Source)
        at net.epzilla.stratification.restruct.RestructuringDaemon$1.run(RestructuringDaemon.java:99)
SystemRestructure ended.....42000 ms


Need to handle the exception.

Currently we have completely fixed the issue of displaying the client ip list 
in the leader's window. But we have to show the other cluster nodes in cluster 
node windows. Currently we are not displaying those information. So we need to 
display that information. We have the required information in the Dynamic 
Discovery component and they are exposed to outside via Leader Election 
component. 

LeaderElectionInitiator.getNodes()will return the list of discovered node list. 

What steps will reproduce the problem?
1. Let the process to start without the default leader.
2. After starting up, it gives the error from JSTM


What is the expected output? What do you see instead?
Nothing. Expected to see empty or our messages. But I get a NPE.

Please use labels and text to provide additional information.
Exception in thread "Timer-2" java.lang.NullPointerException
        at org.epzilla.clusterNode.leaderReg.Main.sendInfo(Main.java:66)
        at 
org.epzilla.clusterNode.sharedMemory.NodeAsLeader$5.run(NodeAsLeader.
java:189)
        at java.util.TimerThread.mainLoop(Unknown Source)
        at java.util.TimerThread.run(Unknown Source)
Pulse sent to the non leader client:192.168.1.25

Need to display the information about dispatchers in the Dispatcher UIs.

Exception in thread "AWT-EventQueue-0" java.lang.NullPointerException
        at org.epzilla.clusterNode.nodeControler.SleepNode.getNodeDetails(SleepNode.java:38)
        at org.epzilla.clusterNode.nodeControler.SleepNode.sleep(SleepNode.java:25)
        at org.epzilla.clusterNode.userInterface.NodeUI.actionPerformed(NodeUI.java:332)
        at javax.swing.AbstractButton.fireActionPerformed(Unknown Source)
        at javax.swing.AbstractButton$Handler.actionPerformed(Unknown Source)
        at javax.swing.DefaultButtonModel.fireActionPerformed(Unknown Source)
        at javax.swing.DefaultButtonModel.setPressed(Unknown Source)
        at javax.swing.plaf.basic.BasicButtonListener.mouseReleased(Unknown Source)
        at java.awt.Component.processMouseEvent(Unknown Source)
        at javax.swing.JComponent.processMouseEvent(Unknown Source)
        at java.awt.Component.processEvent(Unknown Source)
        at java.awt.Container.processEvent(Unknown Source)
        at java.awt.Component.dispatchEventImpl(Unknown Source)
        at java.awt.Container.dispatchEventImpl(Unknown Source)
        at java.awt.Component.dispatchEvent(Unknown Source)
        at java.awt.LightweightDispatcher.retargetMouseEvent(Unknown Source)
        at java.awt.LightweightDispatcher.processMouseEvent(Unknown Source)
        at java.awt.LightweightDispatcher.dispatchEvent(Unknown Source)
        at java.awt.Container.dispatchEventImpl(Unknown Source)
        at java.awt.Window.dispatchEventImpl(Unknown Source)
        at java.awt.Component.dispatchEvent(Unknown Source)
        at java.awt.EventQueue.dispatchEvent(Unknown Source)
        at java.awt.EventDispatchThread.pumpOneEventForFilters(Unknown Source)
        at java.awt.EventDispatchThread.pumpEventsForFilter(Unknown Source)
        at java.awt.EventDispatchThread.pumpEventsForHierarchy(Unknown Source)
        at java.awt.EventDispatchThread.pumpEvents(Unknown Source)
        at java.awt.EventDispatchThread.pumpEvents(Unknown Source)
        at java.awt.EventDispatchThread.run(Unknown Source)
Exception in thread "AWT-EventQueue-0" java.lang.NullPointerException
        at org.epzilla.clusterNode.nodeControler.WakeNode.getNodeDetails(WakeNode.java:38)
        at org.epzilla.clusterNode.nodeControler.WakeNode.wake(WakeNode.java:25)
        at org.epzilla.clusterNode.userInterface.NodeUI.actionPerformed(NodeUI.java:329)
        at javax.swing.AbstractButton.fireActionPerformed(Unknown Source)
        at javax.swing.AbstractButton$Handler.actionPerformed(Unknown Source)
        at javax.swing.DefaultButtonModel.fireActionPerformed(Unknown Source)
        at javax.swing.DefaultButtonModel.setPressed(Unknown Source)
        at javax.swing.plaf.basic.BasicButtonListener.mouseReleased(Unknown Source)
        at java.awt.Component.processMouseEvent(Unknown Source)
        at javax.swing.JComponent.processMouseEvent(Unknown Source)
        at java.awt.Component.processEvent(Unknown Source)
        at java.awt.Container.processEvent(Unknown Source)
        at java.awt.Component.dispatchEventImpl(Unknown Source)
        at java.awt.Container.dispatchEventImpl(Unknown Source)
        at java.awt.Component.dispatchEvent(Unknown Source)
        at java.awt.LightweightDispatcher.retargetMouseEvent(Unknown Source)
        at java.awt.LightweightDispatcher.processMouseEvent(Unknown Source)
        at java.awt.LightweightDispatcher.dispatchEvent(Unknown Source)
        at java.awt.Container.dispatchEventImpl(Unknown Source)
        at java.awt.Window.dispatchEventImpl(Unknown Source)
        at java.awt.Component.dispatchEvent(Unknown Source)
        at java.awt.EventQueue.dispatchEvent(Unknown Source)
        at java.awt.EventDispatchThread.pumpOneEventForFilters(Unknown Source)
        at java.awt.EventDispatchThread.pumpEventsForFilter(Unknown Source)
        at java.awt.EventDispatchThread.pumpEventsForHierarchy(Unknown Source)
        at java.awt.EventDispatchThread.pumpEvents(Unknown Source)
        at java.awt.EventDispatchThread.pumpEvents(Unknown Source)
        at java.awt.EventDispatchThread.run(Unknown Source)