Set state to connected. We may want an interim state for this step of the protocol.
This commit is contained in:
+2
-4
@@ -143,13 +143,9 @@ public class LocalClientHandlerConnecting extends LocalClientHandler {
|
|||||||
} else if (packet.getBody() instanceof PacketBody2Command) {
|
} else if (packet.getBody() instanceof PacketBody2Command) {
|
||||||
SimpleCommand command = ((PacketBody2Command) packet.getBody()).parse();
|
SimpleCommand command = ((PacketBody2Command) packet.getBody()).parse();
|
||||||
|
|
||||||
Ts3Debugging.debug(command.build());
|
|
||||||
|
|
||||||
if (command.getName().equalsIgnoreCase("initivexpand2")) {
|
if (command.getName().equalsIgnoreCase("initivexpand2")) {
|
||||||
// 3.2.2 initivexpand2 (Client <- Server)
|
// 3.2.2 initivexpand2 (Client <- Server)
|
||||||
|
|
||||||
Ts3Debugging.debug(command.build());
|
|
||||||
|
|
||||||
if (!command.get("ot").getValue().equals("1"))
|
if (!command.get("ot").getValue().equals("1"))
|
||||||
throw new IllegalArgumentException("ot constant != 1: " + command.get("ot").getValue());
|
throw new IllegalArgumentException("ot constant != 1: " + command.get("ot").getValue());
|
||||||
|
|
||||||
@@ -231,6 +227,8 @@ public class LocalClientHandlerConnecting extends LocalClientHandler {
|
|||||||
)
|
)
|
||||||
)
|
)
|
||||||
);
|
);
|
||||||
|
|
||||||
|
getClient().setState(ClientConnectionState.CONNECTED);
|
||||||
} else if (command.getName().equals("error")) {
|
} else if (command.getName().equals("error")) {
|
||||||
getClient().setState(ClientConnectionState.DISCONNECTED);
|
getClient().setState(ClientConnectionState.DISCONNECTED);
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user