summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorAndrei Karas <akaras@inbox.ru>2014-07-19 19:57:39 +0300
committerAndrei Karas <akaras@inbox.ru>2014-07-19 19:57:39 +0300
commiteff2fe4be9a25e6f870967d1a5e492c05f6b0abd (patch)
tree50203bdfc2a7cda0ac1f77a6cd4f1f2f7f98e654 /src
parent649aaea644fc30847f5707ff47361d8907ab54c9 (diff)
downloadmanaverse-eff2fe4be9a25e6f870967d1a5e492c05f6b0abd.tar.gz
manaverse-eff2fe4be9a25e6f870967d1a5e492c05f6b0abd.tar.bz2
manaverse-eff2fe4be9a25e6f870967d1a5e492c05f6b0abd.tar.xz
manaverse-eff2fe4be9a25e6f870967d1a5e492c05f6b0abd.zip
In ipc code replace SLD_net into tcpnet.
Diffstat (limited to 'src')
-rw-r--r--src/net/ipc.cpp44
-rw-r--r--src/net/ipc.h3
2 files changed, 24 insertions, 23 deletions
diff --git a/src/net/ipc.cpp b/src/net/ipc.cpp
index 96113154f..6d7c2c45b 100644
--- a/src/net/ipc.cpp
+++ b/src/net/ipc.cpp
@@ -36,10 +36,10 @@
IPC *ipc = nullptr;
-IPC::IPC(const unsigned short port) :
+IPC::IPC() :
mListen(false),
mNumReqs(0),
- mPort(port),
+ mPort(44007),
mSocket(nullptr),
mThread(nullptr)
{
@@ -53,16 +53,16 @@ bool IPC::init()
{
IPaddress ip;
- if(SDLNet_ResolveHost(&ip, nullptr, mPort) == -1)
+ if(TcpNet::resolveHost(&ip, nullptr, mPort) == -1)
{
- logger->log("IPC: SDLNet_ResolveHost: %s\n", SDLNet_GetError());
+ logger->log("IPC: resolveHost error: %s\n", SDLNet_GetError());
return false;
}
- mSocket = SDLNet_TCP_Open(&ip);
+ mSocket = TcpNet::open(&ip);
if (!mSocket)
{
- logger->log("IPC: Error in TcpNet::open(): %s", TcpNet::getError());
+ logger->log("IPC: open error: %s", TcpNet::getError());
return false;
}
@@ -82,27 +82,27 @@ int IPC::acceptLoop(void *ptr)
IPC *const ipc1 = reinterpret_cast<IPC*>(ptr);
const int max_length = 1024;
- SDLNet_SocketSet set = SDLNet_AllocSocketSet(1);
- SDLNet_TCP_AddSocket(set, ipc1->mSocket);
+ TcpNet::SocketSet set = TcpNet::allocSocketSet(1);
+ TcpNet::addSocket(set, ipc1->mSocket);
ipc->mListen = true;
while (ipc1->mListen)
{
- SDLNet_CheckSockets(set, 250);
- if (!SDLNet_SocketReady(ipc1->mSocket))
+ TcpNet::checkSockets(set, 250);
+ if (!TcpNet::socketReady(ipc1->mSocket))
continue;
- TCPsocket sock = SDLNet_TCP_Accept(ipc1->mSocket);
+ TcpNet::Socket sock = TcpNet::accept(ipc1->mSocket);
if (!sock)
{
logger->log_r("IPC: unable to accept connection");
continue;
}
char data[max_length] = {0};
- int result = SDLNet_TCP_Recv(sock, data, max_length);
+ int result = TcpNet::recv(sock, data, max_length);
if (result <= 0)
{
logger->log_r("IPC: unable to accept connection");
- SDLNet_TCP_Close(sock);
+ TcpNet::closeSocket(sock);
continue;
}
@@ -117,16 +117,16 @@ int IPC::acceptLoop(void *ptr)
const char *respc = resp.c_str();
const int len = strlen(respc) + 1;
- result = SDLNet_TCP_Send(sock, respc, len);
+ result = TcpNet::send(sock, respc, len);
if (result < len)
{
- logger->log_r("IPC: SDLNet_TCP_Send: %s\n", SDLNet_GetError());
- SDLNet_TCP_Close(sock);
+ logger->log_r("IPC: send error: %s\n", SDLNet_GetError());
+ TcpNet::closeSocket(sock);
continue;
}
- SDLNet_TCP_Close(sock);
+ TcpNet::closeSocket(sock);
}
- SDLNet_TCP_Close(ipc1->mSocket);
+ TcpNet::closeSocket(ipc1->mSocket);
return 0;
}
@@ -153,13 +153,13 @@ void IPC::start()
logger->log("Starting IPC...");
ipc = new IPC;
- for (int port = 44007; port < 65535; port ++)
+ for (int f = port; f < 65535; f ++)
{
- ipc->setPort(port);
- logger->log(" -> trying port %d...", ipc_port);
+ ipc->setPort(f);
+ logger->log(" -> trying port %d...", f);
if (ipc->init())
{
- logger->log(" -> Port %d selected", ipc_port);
+ logger->log(" -> Port %d selected", f);
return;
}
else
diff --git a/src/net/ipc.h b/src/net/ipc.h
index 611dba35c..acf6ab59c 100644
--- a/src/net/ipc.h
+++ b/src/net/ipc.h
@@ -22,6 +22,7 @@
#define IPC_H
#include "net/sdltcpnet.h"
+
#include <SDL_thread.h>
class IPC final
@@ -30,7 +31,7 @@ public:
/**
* Constructor.
*/
- IPC(const unsigned short port);
+ IPC();
/**
* Destructor.