-
Notifications
You must be signed in to change notification settings - Fork 0
/
PongGameServer.cpp
94 lines (82 loc) · 2.99 KB
/
PongGameServer.cpp
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
#pragma once
#include "stdafx.h"
#include "Room.h"
typedef std::pair<SOCKET, SOCKADDR_IN> CLIENT;
typedef std::pair<Room*, std::thread*> GAME;
void StartGame(Room *room, std::thread*gameThread) {
while (!room->getIsGameEnd()) {
room->Update();
}
}
int main() {
std::deque<CLIENT> clientList;
std::deque<GAME> gameList;
WSADATA wsaData;
if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0) {
std::cout << "Ver 2.2 Erorr" << std::endl;
return 1;
}
SOCKET serverSock = socket(PF_INET, SOCK_STREAM, 0);
SOCKADDR_IN addr;
memset(&addr, 0, sizeof(addr));
addr.sin_family = AF_INET;
addr.sin_addr.s_addr = htonl(INADDR_ANY);
addr.sin_port = htons(3737);
if (bind(serverSock, (SOCKADDR*)&addr, sizeof(SOCKADDR_IN)) == SOCKET_ERROR) {
std::cout << "Bind Failed" << std::endl;
return 1;
}
if (listen(serverSock, SOMAXCONN) == SOCKET_ERROR) {
std::cout << "Listen Error" << std::endl;
return 1;
}
std::cout << "Server Start" << std::endl;
char buffer[BUFFER_SIZE] = { '0','0','0','0','0','0',';' };
while (true) {
if (gameList.size() < MAX_GAME) {
int len = sizeof(SOCKADDR_IN);
SOCKADDR_IN clientAddr;
SOCKET clientSock = accept(serverSock, (SOCKADDR*)&clientAddr, &len);
CLIENT client(clientSock, clientAddr);
clientList.push_back(client);
for (auto client = clientList.begin(); client < clientList.end(); client++) {
send(client->first, buffer, BUFFER_SIZE, 0);
if (recv(client->first, buffer, BUFFER_SIZE, 0) == SOCKET_ERROR) {
closesocket(client->first);
clientList.erase(client);
continue;
}
}
if (clientList.size() >= 2) {
for (int i = 0; i < clientList.size() / 2; i++) {
CLIENT client1 = clientList.front();
clientList.pop_front();
CLIENT client2 = clientList.front();
clientList.pop_front();
Room* room = new Room;
room->SetPlayer(client1.first, client1.second, client2.first, client2.second);
std::thread* gameThread = new std::thread(StartGame, room, gameThread);
GAME game(room, gameThread);
gameList.push_back(game);
}
}
if (gameList.size() > 0) {
if (gameList.front().first->getIsGameEnd()) {
GAME game = gameList.front();
gameList.pop_front();
delete game.first;
game.second->join();
}
}
}
}
while (!gameList.empty()) {
GAME game = gameList.front();
gameList.pop_front();
delete game.first;
game.second->join();
}
closesocket(serverSock);
WSACleanup();
return 0;
}