fix for switch connecting

Change-Id: If4e16a692f79f94289bd0df4a0ffbb3dd828e246

@@ -457,9 +457,17 @@ class OFChannelHandler extends IdleStateAwareChannelHandler {
                 // will never be called. We override processOFMessage
                 // will never be called. We override processOFMessage
             }
             }
 
 
+
+
             @Override
             @Override
             void processOFMessage(OFChannelHandler h, OFMessage m)
             void processOFMessage(OFChannelHandler h, OFMessage m)
                     throws IOException, SwitchStateException {
                     throws IOException, SwitchStateException {
+
+                if (h.sw.isDriverHandshakeComplete()) {
+                    moveToActive(h);
+
+                }
+
                 if (m.getType() == OFType.ECHO_REQUEST) {
                 if (m.getType() == OFType.ECHO_REQUEST) {
                     processOFEchoRequest(h, (OFEchoRequest) m);
                     processOFEchoRequest(h, (OFEchoRequest) m);
                 } else if (m.getType() == OFType.ECHO_REPLY) {
                 } else if (m.getType() == OFType.ECHO_REPLY) {
@@ -470,6 +478,7 @@ class OFChannelHandler extends IdleStateAwareChannelHandler {
                     if (!h.sw.handleRoleError((OFErrorMsg)m)) {
                     if (!h.sw.handleRoleError((OFErrorMsg)m)) {
                         h.sw.processDriverHandshakeMessage(m);
                         h.sw.processDriverHandshakeMessage(m);
                         if (h.sw.isDriverHandshakeComplete()) {
                         if (h.sw.isDriverHandshakeComplete()) {
+                            moveToActive(h);
                             h.setState(ACTIVE);
                             h.setState(ACTIVE);
                         }
                         }
                     }
                     }
@@ -481,13 +490,7 @@ class OFChannelHandler extends IdleStateAwareChannelHandler {
                     } else {
                     } else {
                         h.sw.processDriverHandshakeMessage(m);
                         h.sw.processDriverHandshakeMessage(m);
                         if (h.sw.isDriverHandshakeComplete()) {
                         if (h.sw.isDriverHandshakeComplete()) {
-                            boolean success = h.sw.connectSwitch();
-
-                            if (!success) {
-                                disconnectDuplicate(h);
-                                return;
-                            }
-                            h.setState(ACTIVE);
+                            moveToActive(h);
                         }
                         }
                     }
                     }
                 }
                 }
@@ -498,6 +501,16 @@ class OFChannelHandler extends IdleStateAwareChannelHandler {
                     throws IOException, SwitchStateException {
                     throws IOException, SwitchStateException {
                 h.pendingPortStatusMsg.add(m);
                 h.pendingPortStatusMsg.add(m);
             }
             }
+
+            private void moveToActive(OFChannelHandler h) {
+                boolean success = h.sw.connectSwitch();
+                h.setState(ACTIVE);
+                if (!success) {
+                    disconnectDuplicate(h);
+                    return;
+                }
+            }
+
         },
         },