summaryrefslogtreecommitdiff
path: root/src/network/core/tcp.cpp
diff options
context:
space:
mode:
authorrubidium <rubidium@openttd.org>2008-12-23 20:52:27 +0000
committerrubidium <rubidium@openttd.org>2008-12-23 20:52:27 +0000
commitafddfcb2b1a37358459158ce83a64535f13cd05e (patch)
tree5fc12b987e4ccf94d7c727fd7c3eccc1826b870a /src/network/core/tcp.cpp
parent94dd23aaf86cb1c22ce78d8555261d045de0ee60 (diff)
downloadopenttd-afddfcb2b1a37358459158ce83a64535f13cd05e.tar.xz
(svn r14730) -Codechange: remove the need for networkclientsockets and networkclientinfo structs to be in a contiguous piece of memory and put them in a pool.
-Note: 255 should really be enough for now... making it any more means network protocol bumps.
Diffstat (limited to 'src/network/core/tcp.cpp')
-rw-r--r--src/network/core/tcp.cpp33
1 files changed, 16 insertions, 17 deletions
diff --git a/src/network/core/tcp.cpp b/src/network/core/tcp.cpp
index 5ce7d4831..304e1d37e 100644
--- a/src/network/core/tcp.cpp
+++ b/src/network/core/tcp.cpp
@@ -16,30 +16,25 @@
#include "tcp.h"
#include "table/strings.h"
+#include "../../oldpool_func.h"
-/** Very ugly temporary hack !!! */
-void NetworkClientSocket::Initialize()
-{
- this->sock = INVALID_SOCKET;
+/** Make very sure the preconditions given in network_type.h are actually followed */
+assert_compile(MAX_CLIENT_SLOTS == (MAX_CLIENT_SLOTS >> NCI_BITS_PER_POOL_BLOCK) << NCI_BITS_PER_POOL_BLOCK);
+assert_compile(MAX_CLIENT_SLOTS > MAX_CLIENTS);
- this->client_id = INVALID_CLIENT_ID;
- this->last_frame = 0;
- this->last_frame_server = 0;
- this->lag_test = 0;
+typedef ClientIndex NetworkClientSocketID;
+DEFINE_OLD_POOL_GENERIC(NetworkClientSocket, NetworkClientSocket);
+NetworkClientSocket::NetworkClientSocket(ClientID client_id)
+{
+ this->sock = INVALID_SOCKET;
+ this->client_id = client_id;
this->status = STATUS_INACTIVE;
- this->has_quit = false;
- this->writable = false;
-
- this->packet_queue = NULL;
- this->packet_recv = NULL;
-
- this->command_queue = NULL;
}
-void NetworkClientSocket::Destroy()
+NetworkClientSocket::~NetworkClientSocket()
{
- closesocket(this->sock);
+ if (this->sock != INVALID_SOCKET) closesocket(this->sock);
this->writable = false;
this->has_quit = true;
@@ -57,6 +52,10 @@ void NetworkClientSocket::Destroy()
free(this->command_queue);
this->command_queue = p;
}
+
+ this->sock = INVALID_SOCKET;
+ this->client_id = INVALID_CLIENT_ID;
+ this->status = STATUS_INACTIVE;
}
/**