//---------------client_net

int my_client_net::init(char *ip, int port){

printf("my_client_net init(%s,%i)...\n",ip,port);
WSADATA WsaData;	
int res=0;
if (WSAStartup( MAKEWORD(2,2), &WsaData ) == NO_ERROR){
	int opt = TRUE;
	int iResult=0;
	printf("my_client_net WSAStartup success\n");
	if( (serv_socket = socket(AF_INET , SOCK_STREAM , IPPROTO_TCP)) == 0) 
	{
		printf("socket failed");
		res=-1;
	}
	if(res==0){
		//set master socket to allow multiple connections , this is just a good habit, it will work without this
		if( setsockopt(serv_socket, SOL_SOCKET, SO_REUSEADDR, (char *)&opt, sizeof(opt)) < 0 )
		{
			printf("setsockopt failed");
			res=-1;
		}
	}
	
	if(res==0){
		int flag = 1;
		iResult = setsockopt(serv_socket,      // socket affected 
								IPPROTO_TCP,     // set option at TCP level 
								TCP_NODELAY,     // name of option 
								(char *) &flag,  // the cast is historical cruft 
								sizeof(int));    // length of option value 
		if (iResult < 0)
		{
			printf("set TCP_NODELAY ERROR\n");
			res=-1;
		}
	}
	if(res==0){
		memset(&address, 0, sizeof(address));
		address.sin_family = AF_INET;
		address.sin_addr.s_addr = inet_addr( ip );//INADDR_ANY;
		address.sin_port = htons( port );
		if(connect(serv_socket, (struct sockaddr *)&address, sizeof(struct sockaddr))<0){
			printf("can't connect\n");
			//printf("send() failed with error: %d\n", WSAGetLastError());
			res=-1;
		}
		
	}
	
}
else{
	printf("my_client_net failed WSAStartup\n");
	res=-1;
}

return res;
}

my_client_net client[CL_COUNT];
for(int i=0;i<CL_COUNT;i++){
		Sleep(10);
		client[i].clear();
		res[i]=client[i].init(SERVER_IP,5555);
		}

void my_client_net::clear(){
printf("my_client_net clear...\n");
WSACleanup();
}

byte msg[1024];
int my_client_net::sendvector(){
	int res=0;
	int len=0;
	int msglen=sendmess.size();
	//int m=msglen;
	//printf("sending... %s %d",msg,msglen);
	//printf("sending %d bytes...",msglen);
	//byte *msg=new byte(msglen);
	for(int i=0;i<msglen;i++){
		msg[i]=sendmess[i];
	}
	msg[msglen]=0;
	while (msglen>0){
		len=send(serv_socket,(char*)msg,msglen,0);
		if(msglen!=len) printf("> send part");
		if(len>0){
			msglen-=len;
			for(int i=0;i<msglen;i++){
				msg[i]=msg[i+len];
			}
		}
		else{
			printf("send() failed with error: %d\n", WSAGetLastError());
			msglen=0;
			disconnect();
		}
			
		
	}
	//delete [] msg;
	//printf("/ %d bytes sended \n",m);
	//printf("/ %s %d bytes sended\n",msg,m);
	return res;
	
}

//здесь создается сообщение по определенному протоколу все закидывается в vector
// на него я и думаю. может он память забивает
int my_client_net::send_msg_to(string msg,int id){
		sendmess.clear(); // здесь стоит очистка вектора может она как то не так очищает 
		sendmess.push_back(245);
		sendmess.push_back(25);
		short l=(short)msg.length();
		write_short(l+10);		
		write_int(id);
		for(int i=0;i<msg.length();i++){
			sendmess.push_back((byte)msg.c_str()[i]);
		}
		sendmess.push_back(0);
		sendmess.push_back(0);
		sendvector();
	return 0;
}

while(b){
		Sleep(1);
		//b=false;
		for(int i=0;i<CL_COUNT;i++){
			if(res[i]==0){
				if(client[i].isconnected()){
				b=true;
						uid++;
						/*if(uid>105000){
							//printf("send() failed with error:%d %d\n", WSAGetLastError(),uid);
						}*/
					client[i].send_msg_to("HELLO!",uid);
				}
			}
		}
	}

class my_client_net{
public:
	vector <byte> sendmess;
	int serv_socket;
	int buffer_size;
	char buffer[MAX_BUF_SIZE];
	string appPath;
	my_packet packet;
	struct sockaddr_in address;
	void clear();
	int init(char *ip, int port);
	bool isconnected(){
		bool res=false;
		if(serv_socket>0)res=true;
		return res;
	}
	void disconnect();
	my_client_net(void);
	virtual ~my_client_net(void);
	int sendmsg(/*const char *buf,int buflen*/);
	int sendmessage(char * msg,int msglen);
	int sendbytes(byte * msg,int msglen);
	int sendvector();
	int getmessage();
	int parse();
	int sendfile(string fname,string fullname);
	int senddir(string dname,string curdir="");
	void sendshortname(string shortname);
	void remove(int n){
		buffer_size-=n;
		for(int i=0;i<buffer_size;i++){
			buffer[i]=buffer[i+n];
		}
	}
	int begin_write(){
		sendmess.clear();
		return 0;
	}
	int write_byte(byte b){
		sendmess.push_back(b);
		return 0;	
	}
	int write_short(short b){
		byte bb[2];
		for (int i =0; i <2; i++){
         bb[i] = (b >> (i * 8));
		}
		//for(int i=1;i>=0;i--)
		for(int i=0;i<2;i++)
		 sendmess.push_back(bb[i]);
		
		return 0;
	}
	int write_int(int b){
		byte bb[4];
		for (int i =0; i <4; i++){
         bb[i] = (b >> (i * 8));
		}
		//for(int i=3;i>=0;i--)
		for(int i=0;i<4;i++)
		 sendmess.push_back(bb[i]);
		
		return 0;
	}
	int send_msg_to(string msg,int id);
};

int my_client_net::init(char *ip, int port){

printf("my_client_net init(%s,%i)...\n",ip,port);
WSADATA WsaData;	
	int res=0;
	if (WSAStartup( MAKEWORD(2,2), &WsaData ) == NO_ERROR){
	int opt = TRUE;
	int iResult=0;
	printf("my_client_net WSAStartup success\n");
	if( (serv_socket = socket(AF_INET , SOCK_STREAM , IPPROTO_TCP)) == 0) 
	{
		printf("socket failed");
		res=-1;
	}
	if(res==0){
		//set master socket to allow multiple connections , this is just a good habit, it will work without this
		if( setsockopt(serv_socket, SOL_SOCKET, SO_REUSEADDR, (char *)&opt, sizeof(opt)) < 0 )
		{
			printf("setsockopt failed");
			res=-1;
		}
	}
	
	if(res==0){
		int flag = 1;
		iResult = setsockopt(serv_socket,      // socket affected 
								IPPROTO_TCP,     // set option at TCP level 
								TCP_NODELAY,     // name of option 
								(char *) &flag,  // the cast is historical cruft 
								sizeof(int));    // length of option value 
		if (iResult < 0)
		{
			printf("set TCP_NODELAY ERROR\n");
			res=-1;
		}
	}
	if(res==0){
		memset(&address, 0, sizeof(address));
		address.sin_family = AF_INET;
		address.sin_addr.s_addr = inet_addr( ip );//INADDR_ANY;
		address.sin_port = htons( port );
		if(connect(serv_socket, (struct sockaddr *)&address, sizeof(struct sockaddr))<0){
			printf("can't connect\n");
			//printf("send() failed with error: %d\n", WSAGetLastError());
			res=-1;
		}
		
	}
	
	}
	else{
		printf("my_client_net failed WSAStartup\n");
		res=-1;
	}

return res;
}



void my_client_net::clear(){
printf("my_client_net clear...\n");
WSACleanup();
}

void my_client_net::disconnect(){
closesocket(serv_socket);
serv_socket=-1;
//clear();
}



byte msg[1024];
int my_client_net::sendvector(){
	int res=0;
	int len=0;
	int msglen=sendmess.size();
	//int m=msglen;
	//printf("sending... %s %d",msg,msglen);
	//printf("sending %d bytes...",msglen);
	//byte *msg=new byte(msglen);
	for(int i=0;i<msglen;i++){
		msg[i]=sendmess[i];
	}
	msg[msglen]=0;
	//while (msglen>0){
		len=send(serv_socket,(char*)msg,msglen,0);
		if(msglen!=len) printf("> send part");
		if(len>0){
		/*	msglen-=len;
			for(int i=0;i<msglen;i++){
				msg[i]=msg[i+len];
			}*/
		}
		else{
			printf("send() failed with error: %d\n", WSAGetLastError());
			msglen=0;
			disconnect();
		}
			
		
	//}
	//delete [] msg;
	//printf("/ %d bytes sended \n",m);
	//printf("/ %s %d bytes sended\n",msg,m);
	return res;
	
}

int my_client_net::send_msg_to(string msg,int id){
		sendmess.clear();
		sendmess.push_back(245);
		sendmess.push_back(25);
		short l=(short)msg.length();
		write_short(l+10);
		
		write_int(id);
		for(int i=0;i<msg.length();i++){
			sendmess.push_back((byte)msg.c_str()[i]);
		}
		sendmess.push_back(0);
		sendmess.push_back(0);
		sendvector();
	return 0;
}

#include "stdafx.h"
#define CL_COUNT 99
my_client_net client[CL_COUNT];

int _tmain(int argc, _TCHAR* argv[])
{
	setlocale(LC_CTYPE, "rus");
	int result=0;
	int res[CL_COUNT];
	
	client[0].clear();
	for(int i=0;i<CL_COUNT;i++){
		Sleep(1);
		
		res[i]=client[i].init(SERVER_IP,5555);
		}
	bool b=true;
	int uid=0;
	string pl="PLAYER1",msg="HELLO";
					
	while(b){
		Sleep(1);
		//b=false;
		for(int i=0;i<CL_COUNT;i++){
			if(res[i]==0){
				if(client[i].isconnected()){
				b=true;
						uid++;
						/*if(uid>105000){
							//printf("send() failed with error:%d %d\n", WSAGetLastError(),uid);
						}*/
					client[i].send_msg_to("HELLO!",uid);
				}
			}
		}
	}

	for(int i=0;i<CL_COUNT;i++){
		client[i].disconnect();
	}
	client[0].clear();
	//b=false;
		
	
	
	
	
	return 0;
}

int my_client_net::init(char *ip, int port){

printf("my_client_net init(%s,%i)...\n",ip,port);
	
	int res=0;
	bool wsas=true;
	if (wsas){
	//if (WSAStartup( MAKEWORD(2,2), &WsaData ) == NO_ERROR){
	int opt = TRUE;
	int iResult=0;
	printf("my_client_net WSAStartup success\n");
	if( (serv_socket = socket(AF_INET , SOCK_STREAM , IPPROTO_TCP)) == 0) 
	{
		printf("socket failed");
		res=-1;
	}
	if(res==0){
		//set master socket to allow multiple connections , this is just a good habit, it will work without this
		if( setsockopt(serv_socket, SOL_SOCKET, SO_REUSEADDR, (char *)&opt, sizeof(opt)) < 0 )
		{
			printf("setsockopt failed");
			res=-1;
		}
	}
	
	if(res==0){
		int flag = 1;
		iResult = setsockopt(serv_socket,      // socket affected 
								IPPROTO_TCP,     // set option at TCP level 
								TCP_NODELAY,     // name of option 
								(char *) &flag,  // the cast is historical cruft 
								sizeof(int));    // length of option value 
		if (iResult < 0)
		{
			printf("set TCP_NODELAY ERROR\n");
			res=-1;
		}
	}
	if(res==0){
		memset(&address, 0, sizeof(address));
		address.sin_family = AF_INET;
		address.sin_addr.s_addr = inet_addr( ip );//INADDR_ANY;
		address.sin_port = htons( port );
		if(connect(serv_socket, (struct sockaddr *)&address, sizeof(struct sockaddr))<0){
			printf("can't connect\n");
			//printf("send() failed with error: %d\n", WSAGetLastError());
			res=-1;
		}
		
	}
	
	}
	else{
		printf("my_client_net failed WSAStartup\n");
		res=-1;
	}

return res;
}

#include "stdafx.h"
#define CL_COUNT 99
my_client_net client[CL_COUNT];

int _tmain(int argc, _TCHAR* argv[])
{WSADATA WsaData;
	if (WSAStartup( MAKEWORD(2,2), &WsaData ) == NO_ERROR){
	setlocale(LC_CTYPE, "rus");
	int result=0;
	int res[CL_COUNT];
	
	//client[0].clear();
	for(int i=0;i<CL_COUNT;i++){
		Sleep(1);
		
		res[i]=client[i].init(SERVER_IP,5555);
		}
	bool b=true;
	int uid=0;
	string pl="PLAYER1",msg="HELLO";
					
	while(b){
		Sleep(1);
		//b=false;
		for(int i=0;i<CL_COUNT;i++){
			if(res[i]==0){
				if(client[i].isconnected()){
				b=true;
						uid++;
						/*if(uid>105000){
							//printf("send() failed with error:%d %d\n", WSAGetLastError(),uid);
						}*/
					client[i].send_msg_to("HELLO!",uid);
				}
			}
		}
	}

	for(int i=0;i<CL_COUNT;i++){
		client[i].disconnect();
	}
	client[0].clear();
	

	}	
	
	
	return 0;
}

while (msglen>0){
		len=send(serv_socket,(char*)msg,msglen,0); // вот тут останавливается работа клиента и дальше ничего не происходит
		if(msglen!=len) printf("> send part");
		if(len>0){
			msglen-=len;
			for(int i=0;i<msglen;i++){
				msg[i]=msg[i+len];
			}
		}
		else{
			printf("send() failed with error: %d\n", WSAGetLastError());
			msglen=0;
			disconnect();
		}
			
		
	}

			timeval wait_time = {0};
			fd_set fd;	
			FD_ZERO(&fd);
			FD_SET(serv_socket, &fd);
			int sel = select(serv_socket + 1, NULL, &fd, NULL, &wait_time);
			if(!FD_ISSET(serv_socket, &fd)) {
				printf("socket is full\n");
			} else {
				len=send(...

	while (msglen>0){

		timeval wait_time = {0};
			fd_set fd;	
			FD_ZERO(&fd);
			FD_SET(serv_socket, &fd);
			int sel = select(serv_socket + 1, NULL, &fd, NULL, &wait_time);
			if(!FD_ISSET(serv_socket, &fd)) {
				//printf("socket is full\n");
			} else {
				//len=send(...
				len=send(serv_socket,(char*)msg,msglen,0);
		
				if(msglen!=len) printf("> send part");
				if(len>0){
					msglen-=len;
					for(int i=0;i<msglen;i++){
						msg[i]=msg[i+len];
					}
				}
				else{
					printf("send() failed with error: %d\n", WSAGetLastError());
					msglen=0;
					disconnect();
				}
			
			}
	}

	for (index = 0; index < MAX_PLAYERS; index++) 
	{	
		s = client_socket[index];
		if (!FD_ISSET( s , &readfds)){ 
			printf("net dannyh\n");
			continue; //нет данных в сокете
		}
		//printf("begin cycle\n");	
		
		// определяем сколько байт мы можем еще прочетать
		// это исправляет фикс когда байт траффик не влезает в буффер
		// в оригинале стояло maxread постоянно 1024, тем самым могло перезаписать буффер.
		maxread = RECV_BUFFER_SIZE-splitread[index];		//фиксируем maxread, чтобы не записать сверх буффер'а
		if (maxread>1024) maxread=1024;
		
		valread = recv( s , (char *)&recvbuffer[index][splitread[index]], maxread, 0);
		if (valread==0)														//closed by client
		{
			client_disconnect(index);
			continue;
		}
		
		if (valread==SOCKET_ERROR && GetLastError( ) != WSAEWOULDBLOCK )	//closed with error
		{
			client_disconnect(index);
			continue;
		}
.......

while (msglen>0){


			FD_ZERO(&fd);
			FD_SET(serv_socket, &fd);
			int sel = select(serv_socket + 1, NULL, &fd, NULL, &wait_time);
			if(sel == -1) {
				printf("error1 %d\n", WSAGetLastError());
				
			}
			if(FD_ISSET(serv_socket, &fd)) {
				printf("error2 %d\n", WSAGetLastError());
			}
			if(!FD_ISSET(serv_socket, &fd)) {
				printf("socket is full\n");
			} else {
				//len=send(...
				len=send(serv_socket,(char*)msg,msglen,0);
...

while (msglen>0){


			FD_ZERO(&fd);
			FD_SET(serv_socket, &fd);
			int sel = select(serv_socket + 1, NULL, &fd, NULL, &wait_time);
			if(sel == -1) {
				printf("error1 %d\n", WSAGetLastError());
				
			}
			else if(FD_ISSET(serv_socket, &fd)) {
				printf("error2 %d\n", WSAGetLastError());
			}
			if(!FD_ISSET(serv_socket, &fd)) {
				printf("socket is full\n");
			} else {
				//len=send(...
				len=send(serv_socket,(char*)msg,msglen,0);

#define MAX_PLAYERS 100
...

activity = select( MAX_PLAYERS + 3 , &readfds , NULL , NULL , &tv);
...

#if !defined MAIN_H
#define MAIN_H

#define MAX_PLAYERS 100
#define FD_SETSIZE  MAX_PLAYERS