github/mage
1
0
Fork 0
mirror of https://github.com/correl/mage.git synced 2024-11-15 11:09:30 +00:00
Code Issues Projects Releases Packages Wiki Activity

more client fixes

Browse source
This commit is contained in:
BetaSteward 2011-06-02 23:09:21 -04:00
parent 3ef090b6f5
commit d6e239586b
5 changed files with 54 additions and 42 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
Mage.Client/src/main/java/mage/client/MageFrame.java
View file

@ -733,7 +733,8 @@ public class MageFrame extends javax.swing.JFrame implements Client {
private void btnConnectActionPerformed(java.awt.event.ActionEvent evt) {//GEN-FIRST:event_btnConnectActionPerformed
if (session.getState() == SessionState.CONNECTED) {
if (JOptionPane.showConfirmDialog(this, "Are you sure you want to disconnect?", "Confirm disconnect", JOptionPane.YES_NO_OPTION) == JOptionPane.YES_OPTION) {
session.disconnect(true);
session.disconnect(false);
showMessage("You have disconnected");
}
} else {
connectDialog.showDialog();
@ -747,7 +748,7 @@ public class MageFrame extends javax.swing.JFrame implements Client {
}//GEN-LAST:event_btnAboutActionPerformed
public void exitApp() {
session.disconnect(true);
session.disconnect(false);
Plugins.getInstance().shutdown();
dispose();
System.exit(0);
@ -915,12 +916,12 @@ public class MageFrame extends javax.swing.JFrame implements Client {
@Override
public void showMessage(String message) {
JOptionPane.showMessageDialog(desktopPane, message);
JOptionPane.showMessageDialog(this, message);
}
@Override
public void showError(String message) {
JOptionPane.showMessageDialog(desktopPane, message, "Error", JOptionPane.ERROR_MESSAGE);
JOptionPane.showMessageDialog(this, message, "Error", JOptionPane.ERROR_MESSAGE);
}
@Override

3
Mage.Client/src/main/java/mage/client/chat/ChatPanel.java
View file

@ -80,7 +80,8 @@ public class ChatPanel extends javax.swing.JPanel {
}
public void disconnect() {
session.leaveChat(chatId);
if (session != null)
session.leaveChat(chatId);
}
public void receiveMessage(String message, MessageColor color) {

27
Mage.Common/src/mage/interfaces/callback/CallbackClientDaemon.java
View file

@ -44,7 +44,7 @@ public class CallbackClientDaemon extends Thread {
private final static Logger logger = Logger.getLogger(CallbackClientDaemon.class);
private static ExecutorService callbackExecutor = Executors.newCachedThreadPool();
private ExecutorService callbackExecutor = Executors.newFixedThreadPool(1);
private final CallbackClient client;
private final Connection connection;
private final UUID id;
@ -67,19 +67,22 @@ public class CallbackClientDaemon extends Thread {
final ClientCallback callback = callbackMethod.makeDirectCall();
Ack ackMethod = new Ack(connection, id, callback.getMessageId());
ackMethod.makeCall();
callbackExecutor.submit(
new Runnable() {
@Override
public void run() {
try {
client.processCallback(callback);
}
catch (Exception ex) {
logger.fatal("CallbackClientDaemon error ", ex);
if (callbackExecutor.isShutdown())
logger.fatal("Attempt to submit callback to shutdown executor");
else
callbackExecutor.submit(
new Runnable() {
@Override
public void run() {
try {
client.processCallback(callback);
}
catch (Exception ex) {
logger.fatal("CallbackClientDaemon error ", ex);
}
}
}
}
);
);
} catch (CallbackException ex) {
logger.fatal("Callback failed ", ex);
}

2
Mage.Common/src/mage/remote/RemoteMethodCall.java
View file

@ -63,6 +63,7 @@ public abstract class RemoteMethodCall<T> extends AbstractRemoteMethodCall<T> {
@Override
public T makeCall() {
returnVal = null;
logger.debug("Calling: " + name);
try {
returnVal = super.makeCall();
}
@ -81,6 +82,7 @@ public abstract class RemoteMethodCall<T> extends AbstractRemoteMethodCall<T> {
public T makeDirectCall() throws ServerUnavailable, MageException {
T returnValue = null;
logger.debug("Calling direct: " + name);
try {
returnValue = super.makeCall();
}

55
Mage.Common/src/mage/remote/Session.java
View file

@ -85,9 +85,7 @@ public class Session {
}
public synchronized boolean connect(Connection connection) {
if (this.connection != null && sessionState == SessionState.DISCONNECTED) {
disconnect(true);
}
cleanupSession();
this.connection = connection;
return connect();
}
@ -128,33 +126,30 @@ public class Session {
return true;
} catch (Exception ex) {
logger.fatal("", ex);
if (sessionState == SessionState.CONNECTING) {
disconnect(false);
client.showMessage("Unable to connect to server. " + ex.getMessage());
}
sessionState = SessionState.SERVER_UNAVAILABLE;
disconnect(false);
client.showMessage("Unable to connect to server. " + ex.getMessage());
}
return false;
}
public synchronized void disconnect(boolean voluntary) {
sessionState = SessionState.DISCONNECTING;
public synchronized void disconnect(boolean showMessage) {
if (sessionState == SessionState.CONNECTED)
sessionState = SessionState.DISCONNECTING;
cleanupSession();
if (connection == null)
return;
if (future != null && !future.isDone())
future.cancel(true);
try {
if (callbackDaemon != null)
callbackDaemon.stopDaemon();
deregisterClient();
} catch (MageException ex) {
logger.fatal("Error disconnecting ...", ex);
if (sessionState == SessionState.CONNECTED) {
try {
deregisterClient();
} catch (Exception ex) {
logger.fatal("Error disconnecting ...", ex);
}
}
ServerCache.removeServerFromCache(connection);
client.disconnected();
logger.info("Disconnected ... ");
if (!voluntary) {
sessionState = SessionState.SERVER_UNAVAILABLE;
if (sessionState == SessionState.SERVER_UNAVAILABLE && showMessage) {
client.showError("Server error. You have been disconnected");
}
else {
@ -162,6 +157,14 @@ public class Session {
}
}
private void cleanupSession() {
q.clear();
if (future != null && !future.isDone())
future.cancel(true);
if (callbackDaemon != null)
callbackDaemon.stopDaemon();
}
private boolean handleCall(RemoteMethodCall method) {
try {
if (sessionState == method.getAllowedState()) {
@ -188,15 +191,16 @@ public class Session {
}
private UUID registerClient(String userName, UUID clientId, MageVersion version) throws MageException, ServerUnavailable {
RegisterClient method = new RegisterClient(connection, userName, clientId, version);
if (handleCall(method))
return method.getReturnVal();
if (sessionState == SessionState.CONNECTING) {
RegisterClient method = new RegisterClient(connection, userName, clientId, version);
return method.makeDirectCall();
}
return null;
}
private void deregisterClient() throws MageException {
private void deregisterClient() throws MageException, ServerUnavailable {
DeregisterClient method = new DeregisterClient(connection, sessionId);
handleCall(method);
method.makeDirectCall();
}
private ServerState getServerState() {
@ -480,8 +484,9 @@ public class Session {
}
private void handleServerUnavailable(ServerUnavailable ex) {
sessionState = SessionState.SERVER_UNAVAILABLE;
logger.fatal("server unavailable - ", ex);
disconnect(false);
disconnect(true);
}
private void handleGameException(GameException ex) {