hydrar/mistserver
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Tryout for committing

Browse source
This commit is contained in:
serverericoza 2010-06-06 11:50:29 +02:00
parent 30b6230c50
commit 15a5eb42fe
4 changed files with 17 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

0
Client/1
View file

0
Client/2
View file

28
Server/main.cpp
View file

@ -5,7 +5,7 @@
#include <cstdlib> #include <cstdlib>
#include <cstdio> #include <cstdio>
#define BUFLEN 3000000 #define BUFLEN 1000000
bool machineEndianness() { bool machineEndianness() {
int i = 1; int i = 1;
@ -20,14 +20,16 @@ bool machineEndianness() {
int main() { int main() {
char buffer[BUFLEN]; char buffer[BUFLEN];
char input[BUFLEN]; char input[BUFLEN];
char header[BUFLEN];
int inp_amount; int inp_amount;
int cur_header_pos;
int position_current = 0; int position_current = 0;
int position_startframe = 0; int position_startframe = 0;
int frame_bodylength = 0; int frame_bodylength = 0;
SWUnixSocket listener; SWUnixSocket listener;
SWUnixSocket *mySocket; SWUnixSocket *mySocket;
SWBaseSocket::SWBaseError BError; SWBaseSocket::SWBaseError BError;
char header[13] = {'F','L','V',0x01,0x05,0x00,0x00,0x00,0x09,0x00,0x00,0x00,0x00}; cur_header_pos = fread(&header,1,13,stdin);
listener.bind("../socketfile"); listener.bind("../socketfile");
listener.listen(); listener.listen();
@ -36,34 +38,32 @@ int main() {
while(true) { while(true) {
inp_amount = fread(&input,1,11,stdin); inp_amount = fread(&input,1,11,stdin);
if (input[0] == 9) { if (input[0] == 9) {
std::cout << "9!!\n";
if (!mySocket) { if (!mySocket) {
mySocket = (SWUnixSocket *)listener.accept(&BError); mySocket = (SWUnixSocket *)listener.accept(&BError);
mySocket->send(&header[0],13); if (mySocket) {
mySocket->send(&header[0],cur_header_pos);
}
} }
} }
std::cout << "Blaah\n";
position_current = 0; position_current = 0;
position_startframe = position_current; position_startframe = position_current;
for(int i = 0; i < 11; i++) { buffer[position_current] = input[i]; position_current ++; } for(int i = 0; i < 11; i++) { buffer[position_current] = input[i]; position_current ++; }
frame_bodylength = 0; frame_bodylength = 0;
if (machineEndianness() ) {
frame_bodylength += input[1];
frame_bodylength += (input[2] << 8);
frame_bodylength += (input[3] << 16);
} else {
frame_bodylength += input[3]; frame_bodylength += input[3];
frame_bodylength += (input[2] << 8); frame_bodylength += (input[2] << 8);
frame_bodylength += (input[1] << 16); frame_bodylength += (input[1] << 16);
}
std::cout << frame_bodylength << "\n"; std::cout << frame_bodylength << "\n";
for (int i = 0; i < frame_bodylength + 4; i++) { for (int i = 0; i < frame_bodylength + 4; i++) {
inp_amount = fread(&input,1,1,stdin); inp_amount = fread(&input,1,1,stdin);
buffer[position_current] = input[0]; position_current ++; buffer[position_current] = input[0];
std::cout << " " << position_current << "\n"; position_current ++;
} }
std::cout << "Total message read!\n"; std::cout << "Total message read!\n";
exit(0); if (mySocket) {
mySocket->send(&buffer[0], position_current-1, &BError); mySocket->send(&buffer[0], position_current, &BError);
}
} }
// disconnect and clean up // disconnect and clean up

BIN
Server/sockets.zip
View file

Binary file not shown.