@@ -35,6 +35,24 @@ public class UpdateServer implements IUpdateServer {
35
35
private long lastUpdateInMillis ;
36
36
private CacheArchive [] cacheArchiveLoaders = new CacheArchive [256 ];
37
37
38
+ private enum Opcode {
39
+ REQUEST (0 ),
40
+ PRIORITY_REQUEST (1 ),
41
+ LOGGED_IN (2 ),
42
+ LOGGED_OUT (3 ),
43
+ NEW_ENCRYPTION (4 );
44
+
45
+ private final int value ;
46
+
47
+ Opcode (int value ) {
48
+ this .value = value ;
49
+ }
50
+
51
+ public int getValue () {
52
+ return value ;
53
+ }
54
+ }
55
+
38
56
39
57
@ Override
40
58
public void receiveConnection (GameSocket socket , boolean isLoggedIn ) {
@@ -81,7 +99,7 @@ public void receiveConnection(GameSocket socket, boolean isLoggedIn) {
81
99
if (encryption != 0 ) {
82
100
try {
83
101
Buffer fileRequestBuffer = new Buffer (4 );
84
- fileRequestBuffer .putByte (4 );
102
+ fileRequestBuffer .putByte (Opcode . NEW_ENCRYPTION . getValue () );
85
103
fileRequestBuffer .putByte (encryption );
86
104
fileRequestBuffer .putShortBE (0 );
87
105
updateServerSocket .sendDataFromBuffer (4 , 0 , fileRequestBuffer .buffer );
@@ -130,7 +148,7 @@ public boolean poll() {
130
148
}
131
149
UpdateServerNode updateServerNode = (UpdateServerNode ) immediateWriteQueue .getNextNode ();
132
150
Buffer buffer = new Buffer (4 );
133
- buffer .putByte (1 ); // immediate file request
151
+ buffer .putByte (Opcode . PRIORITY_REQUEST . getValue () ); // immediate file request
134
152
buffer .putMediumBE ((int ) updateServerNode .key ); // file index + file id
135
153
updateServerSocket .sendDataFromBuffer (4 , 0 , buffer .buffer );
136
154
activeRequests .put (updateServerNode .key , updateServerNode );
@@ -141,7 +159,7 @@ public boolean poll() {
141
159
for (/**/ ; pendingResponses < 20 && pendingWrites > 0 ; pendingWrites --) {
142
160
UpdateServerNode updateServerNode = (UpdateServerNode ) pendingWriteQueue .next ();
143
161
Buffer buffer = new Buffer (4 );
144
- buffer .putByte (0 ); // queued file request
162
+ buffer .putByte (Opcode . REQUEST . getValue () ); // queued file request
145
163
buffer .putMediumBE ((int ) updateServerNode .key ); // file index + file id
146
164
updateServerSocket .sendDataFromBuffer (4 , 0 , buffer .buffer );
147
165
updateServerNode .clear ();
@@ -372,7 +390,7 @@ public void resetRequests(boolean loggedIn) {
372
390
if (updateServerSocket != null ) {
373
391
try {
374
392
Buffer buffer = new Buffer (4 );
375
- buffer .putByte (loggedIn ? 2 : 3 );
393
+ buffer .putByte (loggedIn ? Opcode . LOGGED_IN . getValue () : Opcode . LOGGED_OUT . getValue () );
376
394
buffer .putMediumBE (0 );
377
395
updateServerSocket .sendDataFromBuffer (4 , 0 , buffer .buffer );
378
396
} catch (java .io .IOException ioexception ) {
0 commit comments