alterwain/Nosedive
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

debug x7

Browse Source
This commit is contained in:
Michael Wain 2024-07-13 18:51:56 +03:00
parent 3994ca7603
commit 3c5522b475
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/com/alterdekim/game/component/game/GameRoom.java
View File

@ -43,6 +43,8 @@ public class GameRoom extends Thread {
@Setter
private boolean isGameLoopFrozen = false;
private boolean isAllPlayersAlreadyJoined = false;
private final ConcurrentMap<GameState, StateManager> manager;
public GameRoom(List<RoomPlayer> players, UserServiceImpl userService) {
@ -75,7 +77,6 @@ public class GameRoom extends Thread {
log.info("GameRoomManager: {}", this.manager.keySet());
log.info("GameRoomManagerVals: {}", this.manager.values());
this.initBoard();
this.start();
}
private void initBoard() {
@ -141,6 +142,7 @@ public class GameRoom extends Thread {
public void receiveMessage(BasicMessage message, WebSocketSession session) {
if(players.stream().noneMatch(p -> p.getUserId().longValue() == message.getUid().longValue())) return;
socks.put(message.getUid(), session);
if(players.size() == socks.keySet().size() && !isAllPlayersAlreadyJoined) onAllPlayersJoined();
log.info("receiveMessage " + message.getType());
parseMessage(message);
}
@ -195,6 +197,11 @@ public class GameRoom extends Thread {
}
}
private void onAllPlayersJoined() {
this.start();
this.isAllPlayersAlreadyJoined = true;
}
@Override
public void run() {
while(true) {