Some more lifecycle related to setting up and shutting down a host.

Now one can join their own hosted game as well as termining the hosting.

Author: pspeed42

sim-eth-basic/src/main/java/example/ConnectState.java

@@ -205,7 +205,7 @@ public void execute( Button source ) {
 
     private class ConnectionObserver implements ClientStateListener, ErrorListener<Client> {
         public void clientConnected( final Client c ) {
-            log.trace("clientConnected(" + c + ")");
+            log.info("clientConnected(" + c + ")");
             getApplication().enqueue(new Callable() {
                     public Object call() {
                         connected();
@@ -215,7 +215,7 @@ public Object call() {
         }
 
         public void clientDisconnected( final Client c, final DisconnectInfo info ) {
-            log.trace("clientDisconnected(" + c + ", " + info + ")");        
+            log.info("clientDisconnected(" + c + ", " + info + ")");        
             getApplication().enqueue(new Callable() {
                     public Object call() {
                         disconnected(info);

sim-eth-basic/src/main/java/example/HostState.java

@@ -45,8 +45,11 @@
 import com.jme3.network.ConnectionListener;
 import com.jme3.network.HostedConnection;
 import com.jme3.network.Server;
+import com.jme3.scene.Node;
 
+import com.simsilica.lemur.*;
 import com.simsilica.lemur.core.VersionedHolder;
+import com.simsilica.lemur.style.ElementId;
 import com.simsilica.state.DebugHudState;
 import com.simsilica.state.DebugHudState.Location;
 
@@ -62,21 +65,49 @@ public class HostState extends BaseAppState {
     static Logger log = LoggerFactory.getLogger(HostState.class);
 
     private GameServer gameServer;
+    private int port;
 
     private VersionedHolder<String> hostingState;
     private VersionedHolder<String> connectionCount;
 
     private ConnectionListener connectionListener = new ConnectionObserver();
 
+    private Container hostWindow;
+    
     public HostState( int port, String description ) {
         try {
+            this.port = port;
             this.gameServer = new GameServer(port, description);
             gameServer.getServer().addConnectionListener(connectionListener);
         } catch( IOException e ) {
             throw new RuntimeException("Error creating server", e);
         }       
     }
 
+    protected void joinGame() {
+        log.info("joinGame()");
+        getStateManager().attach(new ConnectState("127.0.0.1", port));
+        setEnabled(false); // hide our window        
+    }
+
+    protected void stopHosting() {
+        log.info("stopHosting()");        
+        if( gameServer.getServer().isRunning() && !gameServer.getServer().getConnections().isEmpty() ) {
+            String msg = "Really kick all " + gameServer.getServer().getConnections().size() + " connections?"; 
+            getState(OptionPanelState.class).show("Disconnect", msg,
+                                                  new CallMethodAction("Yes", this, "detach"),
+                                                  new EmptyAction("No"),
+                                                  new EmptyAction("Cancel"));            
+        } else {
+            // Just detach
+            detach();
+        } 
+    }
+    
+    protected void detach() {
+        getStateManager().detach(this);
+    }
+
     @Override   
     protected void initialize( Application app ) {
         // We'll manage the server itself as part of the app state
@@ -91,24 +122,40 @@ protected void initialize( Application app ) {
 
         connectionCount = getState(DebugHudState.class).createDebugValue("Connections", Location.Right);
         resetConnectionCount();
+        
+        hostWindow = new Container();
+        
+        // For now just something simple
+        hostWindow.addChild(new Label("Hosting Control", new ElementId("title")));
+        hostWindow.addChild(new ActionButton(new CallMethodAction("Join Game", this, "joinGame")));
+        hostWindow.addChild(new ActionButton(new CallMethodAction("Stop Hosting", this, "stopHosting")));       
     }    
 
     @Override   
     protected void cleanup( Application app ) {
-        gameServer.close();
+        gameServer.close("Shutting down.");
         hostingState.setObject("Offline");
 
         // And remove the debug messages anyway
         getState(DebugHudState.class).removeDebugValue("Hosting");
         getState(DebugHudState.class).removeDebugValue("Connections");
+        
+        // And re-enable the main menu
+        getState(MainMenuState.class).setEnabled(true);
     }
 
     @Override   
     protected void onEnable() {
+        Node gui = ((Main)getApplication()).getGuiNode();
+ 
+        int height = getApplication().getCamera().getHeight();
+        hostWindow.setLocalTranslation(10, height - 10, 0);       
+        gui.attachChild(hostWindow);    
     }
 
     @Override   
     protected void onDisable() {
+        hostWindow.removeFromParent();
     }
 
     protected void resetConnectionCount() {

sim-eth-basic/src/main/java/example/net/server/GameServer.java

@@ -40,6 +40,7 @@
 
 import org.slf4j.*;
 
+import com.jme3.network.HostedConnection;
 import com.jme3.network.Network;
 import com.jme3.network.Server;
 import com.jme3.network.service.rmi.RmiHostedService;
@@ -111,12 +112,18 @@ public void start() {
     }
 
     /**
-     *  Closes the network host, stops all systems, and finally terminates
-     *  them.  The GameServer is not restartable at this point.
+     *  Kicks all current connection, closes the network host, stops all systems, and 
+     *  finally terminates them.  The GameServer is not restartable at this point.
      */   
-    public void close() {
-        log.info("Stopping game server...");
+    public void close( String kickMessage ) {
+        log.info("Stopping game server..." + kickMessage);
         loop.stop();
+        
+        if( kickMessage != null ) {
+            for( HostedConnection conn : server.getConnections() ) {
+                conn.close(kickMessage);
+            }
+        }
         server.close();
 
         // The GameLoop dying should have already stopped the game systems
@@ -127,6 +134,14 @@ public void close() {
         log.info("Game server stopped.");
     }
 
+    /**
+     *  Closes the network host, stops all systems, and finally terminates
+     *  them.  The GameServer is not restartable at this point.
+     */   
+    public void close() {
+        close(null);
+    }
+    
     /**
      *  Allow running a basic dedicated server from the command line using
      *  the default port.  If we want something more advanced then we should