Danbias/Code/Network/OysterNetworkServer/ServerMain.cpp

133 lines
2.7 KiB
C++
Raw Normal View History

2013-11-18 16:47:57 +01:00
#include <iostream>
#include <WinSock2.h>
2013-11-22 14:23:08 +01:00
#include <vld.h>
#include "../NetworkDependencies/WinsockFunctions.h"
#include "../NetworkDependencies/Listener.h"
#include "../NetworkDependencies/Translator.h"
#include "Client.h"
#include "../NetworkDependencies/OysterByte.h"
2013-11-18 16:47:57 +01:00
#pragma comment(lib, "ws2_32.lib")
using namespace std;
using namespace Oyster::Network::Server;
2013-11-21 14:49:30 +01:00
using namespace Oyster::Network;
using namespace ::Protocols;
int main()
{
OysterByte recvBuffer;
2013-11-21 14:49:30 +01:00
cout << "Server" << endl;
2013-11-22 08:56:00 +01:00
Translator t;
2013-11-26 13:45:03 +01:00
int errorCode;
2013-11-19 14:21:25 +01:00
2013-11-26 13:45:03 +01:00
if(!InitWinSock())
{
2013-11-26 13:45:03 +01:00
cout << "errorMessage: unable to start winsock" << endl;
}
//Create socket
Listener listener;
listener.Init(9876);
Sleep(1000);
//Start listening
2013-11-19 14:21:25 +01:00
//Accept a client
ProtocolTest test;
test.clientID = 0;
test.size = 2;
test.textMessage = "hej";
test.numOfFloats = 35;
test.f = new float[test.numOfFloats];
float temp = 395.456f;
for(int i = 0; i < (int)test.numOfFloats; i++)
{
test.f[i] = temp;
temp--;
}
t.Pack(test, recvBuffer);
while(1)
{
int client = listener.GetNewClient();
if(client != -1)
{
cout << "Client connected: " << client << endl;
Client client1(client);
client1.Send(recvBuffer);
}
//Sleep(100);
}
/* int clientSocket = listener.Accept();
2013-11-19 14:21:25 +01:00
Client client1(clientSocket);
cout << "First client connected." << endl;
//Accept a client
2013-11-19 14:21:25 +01:00
clientSocket = listener.Accept();
Client client2(clientSocket);
cout << "Second client connected." << endl;
*/
2013-11-19 14:21:25 +01:00
/*
ProtocolSet* set = new ProtocolSet;
2013-11-22 15:48:49 +01:00
ProtocolTest test;
test.clientID = 0;
test.size = 2;
2013-11-22 15:48:49 +01:00
test.textMessage = "hej";
test.numOfFloats = 35;
test.f = new float[test.numOfFloats];
float temp = 395.456f;
2013-11-27 11:28:11 +01:00
for(int i = 0; i < (int)test.numOfFloats; i++)
{
test.f[i] = temp;
temp--;
}
t.Pack(test, recvBuffer);*/
2013-11-22 15:48:49 +01:00
/*
2013-11-22 15:48:49 +01:00
client1.Send(recvBuffer);
2013-11-19 14:21:25 +01:00
while(1)
{
2013-11-22 08:56:00 +01:00
client1.Recv(recvBuffer);
t.Unpack(set, recvBuffer);
cout << set->Protocol.pTest->clientID << ' ' << set->Protocol.pTest->packageType << ' ' << set->Protocol.pTest->size << endl;
cout << "Client1: " << set->Protocol.pTest->textMessage << endl;
2013-11-27 11:28:11 +01:00
for(int i = 0; i < (int)set->Protocol.pTest->numOfFloats; i++)
{
cout << set->Protocol.pTest->f[i] << ' ';
}
cout << endl;
set->Release();
2013-11-19 14:21:25 +01:00
client2.Send(recvBuffer);
client2.Recv(recvBuffer);
2013-11-22 08:56:00 +01:00
t.Unpack(set, recvBuffer);
cout << set->Protocol.pTest->clientID << ' ' << set->Protocol.pTest->packageType << ' ' << set->Protocol.pTest->size << endl;
cout << "Client2: " << set->Protocol.pTest->textMessage << endl;
2013-11-27 11:28:11 +01:00
for(int i = 0; i < (int)set->Protocol.pTest->numOfFloats; i++)
{
cout << set->Protocol.pTest->f[i] << ' ';
}
cout << endl;
set->Release();
2013-11-22 08:56:00 +01:00
client1.Send(recvBuffer);
2013-11-19 14:21:25 +01:00
}
2013-11-18 16:47:57 +01:00
2013-11-26 13:45:03 +01:00
ShutdownWinSock();
delete set;
*/
system("pause");
return 0;
}