package bingo.player; import java.awt.*; import java.awt.event.*; import javax.swing.*; import java.io.*; import java.rmi.*; import java.net.*; import bingo.shared.*; public class Player extends JPanel implements ActionListener, ItemListener, BallListener { protected PlayerParameters params; protected static boolean DEBUG = false; protected ControlPane controlPane; protected GameStatusLabel gameStatusLabel; protected LightBoardPane lightBoardPane; protected JCheckBox beepButton; protected static int SMALLPAD = 5; protected static int BIGPAD = 20; static String register = "Join next game"; static char registerKey = 'j'; static String clear = "Reset"; static char clearKey = 'r'; static String beep = "Beep to announce new balls"; static char beepKey = 'b'; static String gameStatusTitle = "Game Status"; static String windowTitle = "BINGO Player"; private static Toolkit toolkit; Registrar registrar; int numCardWindows = 0; CardWindow[] cardWindows = new CardWindow[3]; protected Ticket ticket; protected PlayerQueue playerQueue; public Player() { super(false); params = new PlayerParameters(); playerQueue = new PlayerQueue(this); controlPane = new ControlPane(this); // status from the game JPanel statusPane = new JPanel(false); statusPane.setBorder( BorderFactory.createTitledBorder( gameStatusTitle)); statusPane.setLayout(new BoxLayout(statusPane, BoxLayout.Y_AXIS)); gameStatusLabel = new GameStatusLabel(); gameStatusLabel.setAlignmentX(0.0f); statusPane.add(gameStatusLabel); lightBoardPane = new LightBoardPane(0); lightBoardPane.setAlignmentX(0.0f); statusPane.add(lightBoardPane); //Choose where the app beeps whenever a ball arrives. beepButton = new JCheckBox(beep); beepButton.setSelected(params.getShouldBeep()); beepButton.setMnemonic(beepKey); beepButton.addItemListener(this); beepButton.setAlignmentX(0.0f); statusPane.add(beepButton); setLayout(new BoxLayout(this, BoxLayout.Y_AXIS)); controlPane.setAlignmentX(0.0f); //left align add(controlPane); statusPane.setAlignmentX(0.0f); //left align add(statusPane); //XXX hack to turn off old-style event handling: //XXX add any kind of listener to this component //XXX 1.1 only, I think addContainerListener(new ContainerAdapter(){}); // Get current status. playerQueue.postEvent(new StatusRequestEvent(this)); // Initialize the toolkit. toolkit = Toolkit.getDefaultToolkit(); } /* Called from AWT event dispatch thread. */ public void itemStateChanged(ItemEvent e) { if (e.getStateChange() == ItemEvent.SELECTED) { params.setShouldBeep(true); } else { params.setShouldBeep(false); } } /* Called from AWT event dispatch thread. */ public void actionPerformed(ActionEvent e) { String factoryName = null; String command = e.getActionCommand(); if (command == register) { params.setNames(controlPane.nameField.getText(), controlPane.hostField.getText()); //We didn't used to do the following, since seed isn't //a saved property, but the alternative (doing //invokeAndWait when you really need the value) //might be prone to deadlock. params.setSeed(Long.parseLong(controlPane.seedField.getText())); playerQueue.postEvent(new RegisterEvent(this)); } else if (command == clear) { clearGame(); } else { int numCards; try { numCards = Integer.parseInt(command); params.setNumCards(numCards); } catch (Throwable exc) { //Ignore the action since we don't understand it. } } } /* Can be invoked from any thread. */ public void showServerStatus(String message) { if (gameStatusLabel != null) { final String msg = message; //so we can access it in inner class SwingUtilities.invokeLater(new Runnable() { public void run() { gameStatusLabel.setText(msg); } }); } else { System.err.println("Player.gameStatusLabel is null, " + "so couldn't say: " + message); } if (DEBUG) { System.out.println("showServerStatus: " + message); } } /** * BallListener method. */ public void noMoreBalls() { controlPane.gameOver(); //safe from any thread showServerStatus("Game Over."); //safe from any thread } /** * BallListener method. */ public void ballCalled(BingoBall b) { final BingoBall ball = b; //for use in inner class if (ball.getNumber() != BingoBall.GAME_OVER) { SwingUtilities.invokeLater(new Runnable() { public void run() { lightBoardPane.displayNewBall(ball); if (params.getShouldBeep()) { toolkit.beep(); } } }); } } /* Called from action event handler (AWT event dispatch thread). */ private void clearGame() { ticket = null; for (int i = 0; i < numCardWindows; i++) { cardWindows[i].dispose(); } controlPane.reset(); lightBoardPane.clear(); } /* Called from player queue thread. */ void handleStatusRequestEvent(StatusRequestEvent event) { lookUpRegistrar(params.getHostname()); if (registrar != null) { String statusText = ""; try { statusText = registrar.whatsHappening(); } catch (java.rmi.ConnectException exc) { if (DEBUG) { System.err.println("Not connected to Bingo server."); System.err.println("registrar = " + registrar); } //XXX Update status? We aren't connected to the Bingo //XXX server, but rmiregistry is running. } catch (Exception exc) { System.err.println("Unexpected exception on status request."); exc.printStackTrace(); return; } showServerStatus(statusText); //safe from any thread } } /* Can be safely called from any thread. */ private void lookUpRegistrar(String host) { if (registrar != null) return; try { registrar = (Registrar)Naming.lookup("//" + host + "/Registrar"); } catch (java.rmi.NotBoundException exc) { if (DEBUG) { System.err.println("Couldn't find BINGO Server running on host " + host + "."); System.err.println("RMI seems to be running fine."); } //XXX Advise them to start up BINGO server. } catch (java.rmi.UnmarshalException exc) { System.err.println("Unmarshal exception on host " + host + "."); System.err.println("Try recompiling everything and starting over?"); System.err.println("registrar = " + registrar); //XXX Advise the user? Fatal error? } catch (java.rmi.ConnectException exc) { if (DEBUG) { System.err.println("RMI isn't running on " + host + "."); System.err.println("Or maybe it is, but it " + "started after this program."); } //XXX Update status? We aren't connected to the Bingo //XXX server, but rmiregistry is running. I think. } catch (java.rmi.UnknownHostException exc) { System.err.println("Unknown host: " + host); //XXX Update status? Ask user to enter another host and retry? } catch (java.rmi.ConnectIOException exc) { System.err.println("Couldn't get to host " + host + "."); //XXX Update status? We might have had a network glitch. } catch (Exception exc) { System.err.println("Unexpected exception when " + "trying to find registrar."); System.err.println("Exception type: " + exc.toString()); exc.printStackTrace(); } } /* Called from player queue thread. */ void handleRegisterEvent(RegisterEvent event) { if (registrar == null) { lookUpRegistrar(params.getHostname()); } if (registrar == null) { return; //XXX should do this with an exception instead. } if (ticket == null) { long seed = params.getSeed(); lookUpRegistrar(params.getHostname()); //Get the ticket. try { ticket = registrar.mayIPlay(params.getName(), params.getNumCards(), seed); } catch (java.rmi.ConnectException exc) { if (DEBUG) { System.err.println("Not connected to Bingo server."); System.err.println("registrar = " + registrar); } //XXX Update status? We aren't connected to the Bingo //XXX server, but rmiregistry is running. return; } catch (Exception exc) { System.err.println("Unexpected exception on register attempt."); exc.printStackTrace(); //XXX Update status? return; } //React to registration results. try { if (ticket.ID != Ticket.DENIED) { numCardWindows = ticket.cards.length; final Player player = this; SwingUtilities.invokeLater(new Runnable() { public void run() { controlPane.didRegister(); repaint(); //XXX Should delay the following //XXX (so there's feedback when you //XXX register)? for (int i = 0; i < numCardWindows; i++) { cardWindows[i] = new CardWindow(ticket.cards[i], player); cardWindows[i].pack(); cardWindows[i].setVisible(true); } } }); try { new BallListenerThread(this).start(); } catch (java.io.IOException e) { if (DEBUG) { System.err.println("IOException on " + "BallListenerThread " + "creation/startup."); } } } else { showServerStatus(ticket.message); ticket = null; } } catch (NullPointerException exc) { System.err.println("NullPointerException; probably " + "ticket was null"); } catch (Exception exc) { System.err.println("Unexpected exception on register attempt."); exc.printStackTrace(); } } } /* Called from player queue thread. */ void handleIWonEvent(IWonEvent event) { if (registrar == null) { showServerStatus("This player isn't connected to a server: " + "can't tell a server you won."); return; } try { Answer a = registrar.BINGO(ticket.ID, event.getCard()); if (a.didIWin) { showDialog(event.getCardWindow(), "You won!"); } else { showServerStatus(a.message); showDialog(event.getCardWindow(), "You didn't win."); } } catch (RemoteException e) { //...show status? System.err.println("RMI Exception when " + "informing server of win."); } } protected void showDialog(CardWindow cw, String status) { final String statusText = status; final CardWindow cardWindow = cw; SwingUtilities.invokeLater(new Runnable() { public void run() { cardWindow.showStatusDialog(statusText); } }); } /** * Requests that handleIWonEvent be called from * player queue thread. */ void IWon(CardWindow cw) { playerQueue.postEvent(new IWonEvent(this, cw)); } /* * Called from either player queue thread or AWT event dispatch * thread, as appropriate. * XXX Can be cleaner in 1.2. */ protected void processEvent(AWTEvent event) { if (event instanceof StatusRequestEvent) { if (DEBUG) { System.out.println("Player processEvent received StatusRequestEvent"); } handleStatusRequestEvent((StatusRequestEvent)event); } else if (event instanceof RegisterEvent) { if (DEBUG) { System.out.println("Player processEvent received RegisterEvent"); } handleRegisterEvent((RegisterEvent)event); } else if (event instanceof IWonEvent) { if (DEBUG) { System.out.println("Player processEvent received IWonEvent"); } handleIWonEvent((IWonEvent)event); } else { super.processEvent(event); } } public static void main(String[] args) { JFrame frame = new JFrame(windowTitle); frame.addWindowListener(new WindowAdapter() { public void windowClosing(WindowEvent e) { System.exit(0); //XXX } }); Player player = new Player(); frame.getContentPane().add("Center", player); frame.pack(); frame.setVisible(true); } public static void fatalError(String message, Exception e) { e.printStackTrace(); System.err.println(message); System.err.println("Exiting....."); System.exit(-1); } }