neocturne/JRummikub
Archived
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fix nickname for Vysper server

Browse source 
git-svn-id: svn://sunsvr01.isp.uni-luebeck.de/swproj13/trunk@590 72836036-5685-4462-b002-a69064685172
This commit is contained in:
Matthias Schiffer 2011-06-22 10:34:02 +02:00
parent 5b53a640ee
commit e1df2b8e88
1 changed files with 38 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

40
src/jrummikub/control/network/ConnectionControl.java
View file

@ -125,6 +125,7 @@ public class ConnectionControl implements IConnectionControl {
private BlockingQueue<Runnable> actionQueue = new LinkedBlockingQueue<Runnable>();
private volatile GameData offeredGame;
private volatile String nickname;
/**
* Creates new connection control
@ -138,7 +139,7 @@ public class ConnectionControl implements IConnectionControl {
@Override
public String getNickname() {
return muc.getNickname();
return nickname;
}
@Override
@ -644,6 +645,9 @@ public class ConnectionControl implements IConnectionControl {
if (error == null) {
error = doJoin();
}
if (error == null) {
error = doFindNickname();
}
if (error == null) {
connection.addConnectionListener(new DisconnectListener());
@ -691,7 +695,7 @@ public class ConnectionControl implements IConnectionControl {
DiscussionHistory history = new DiscussionHistory();
history.setMaxStanzas(0);
String nickname = loginData.getUserName();
nickname = loginData.getUserName();
// Loop until a unused nickname is found
while (true) {
try {
@ -724,6 +728,38 @@ public class ConnectionControl implements IConnectionControl {
return null;
}
private LoginError doFindNickname() {
final Message message = muc.createMessage();
PacketListener listener = new PacketListener() {
@Override
public void processPacket(Packet packet) {
if (packet.getPacketID().equals(message.getPacketID())) {
synchronized (ConnectRunner.this) {
nickname = StringUtils.parseResource(packet.getFrom());
ConnectRunner.this.notify();
}
}
}
};
synchronized (this) {
connection.addPacketListener(listener, new PacketTypeFilter(
Message.class));
connection.sendPacket(message);
try {
wait(5000);
} catch (InterruptedException e) {
}
}
connection.removePacketListener(listener);
return null;
}
private class DisconnectListener implements ConnectionListener {
@Override
public void connectionClosed() {