DWORD WINAPI SendThread(LPVOID lpParam)
{
	SOCKET * connectSocket=(SOCKET *)lpParam;
	char recvbuf[DEFAULT_BUFLEN];
	char recvbuffer[DEFAULT_BUFLEN];
	int size = 0;
	int priority = 0;
	int clientID = 0;

	//int byteCounter = 0;
	int messageCounter = 0;
	double flowParameter = 0; //flowParametar = flow * 10;
	double flow = 2;
	flowParameter = flow * 10;
	//*((int*)recvbuf) = 396; //MESSAGE SIZE
	//*((int*)recvbuf + 1) = 1; // PRIORITY

	*((int*)recvbuf) = 2; // CLIENT ID
	sendWrapper(connectSocket, recvbuf, sizeof(int));

	clock_t start = clock();
	/*Do something*/

	//do{
		//RANDOM PORUKE
		/*
		char *recvbuffer;
		size = RandomMessageSize();
		priority = RandomPriority();
		clientID = RandomClientID();
		recvbuffer = (char*)malloc(size);
		*((int*)recvbuffer) = size-sizeof(int) ; //MESSAGE SIZE
		*((int*)recvbuffer + 1) = priority; // PRIORITY
		*((int*)recvbuffer + 2) = clientID; // CLIENT ID
		memset((char*)(recvbuffer + 12), '3', size - 3*sizeof(int)); //CONTENT

		sendWrapper(*connectSocket,recvbuffer,sizeof(int));
		sendWrapper(*connectSocket,recvbuffer+4, size - sizeof(int));

		printf("Poslato je:%s",recvbuffer+12);
		free(recvbuffer);

		//Sleep(2);

		byteCounter += size;
		if(byteCounter >= flowParameter*1024)
		{
			byteCounter = 0;
			Sleep(10);
		}*/

		//HARDKODOVANE PORUKE
	size = 0;
	priority = 1;
	clientID = 2;
	int cnt = 0;
	int mnozioc = 500;
	int mbC = 0;
	int byteCounter = 0;
	int kbCounter = 0;
	int mbCounter = 0;
	float secondsFor1gb = 0;
	do
	{
		cnt++;
		if(cnt == 4)
		{
			cnt = 1;
		}
		size = cnt * mnozioc;
		//recvbuffer = (char*)malloc(size);
		*((int*)recvbuffer) = size-sizeof(int) ; //MESSAGE SIZE
		*((int*)recvbuffer + 1) = priority; // PRIORITY
		*((int*)recvbuffer + 2) = clientID; // CLIENT ID
		memset((char*)(recvbuffer + 12), '2', size - 3*sizeof(int)); //CONTENT

		sendWrapper(connectSocket,recvbuffer,sizeof(int));
		sendWrapper(connectSocket,recvbuffer+4, size - sizeof(int));

		byteCounter += size;
		if(byteCounter >= 1024)
		{
			kbCounter += (byteCounter/1024);
			byteCounter = (byteCounter%1024);
			if(kbCounter >= 1024)
			{
				mbCounter += (kbCounter/1024);
				kbCounter = (kbCounter%1024);
				clock_t end = clock();
				float seconds = (float)(end - start) / CLOCKS_PER_SEC;
				secondsFor1gb=seconds;
				if(mbCounter % 10 == 0)
				{
					printf("Poslato je %d mb! Vreme slanja je %f\n", mbCounter,seconds);
				}
			}
		}

	}while(mbCounter < 1024);
	return 0;
	/*
	size = 0;
	priority = 1;
	clientID = 2;
	int cnt = 0;
	int mnozioc = 500;
	for(int i=0;i<350*1024;i++)
	{
		cnt++;
		if(cnt == 4)
		{
			cnt = 1;
		}
		size = cnt * mnozioc;
		//recvbuffer = (char*)malloc(size);
		*((int*)recvbuffer) = size-sizeof(int) ; //MESSAGE SIZE
		*((int*)recvbuffer + 1) = priority; // PRIORITY
		*((int*)recvbuffer + 2) = clientID; // CLIENT ID
		memset((char*)(recvbuffer + 12), '2', size - 3*sizeof(int)); //CONTENT

		sendWrapper(connectSocket,recvbuffer,sizeof(int));
		sendWrapper(connectSocket,recvbuffer+4, size - sizeof(int));

		//printf("Poslato je:%s",recvbuffer+12);
		//free(recvbuffer);

		messageCounter++;
		if((messageCounter % (30*1024)) == 0)
		{
			messageCounter = 0;
			clock_t end = clock();
			float seconds = (float)(end - start) / CLOCKS_PER_SEC;
			printf("Poslato je 30 mb poruka! Vreme slanja je %f\n", seconds);
		}
		//Sleep(1); //regulisanje protoka
	}
	clock_t end = clock();
	float seconds = (float)(end - start) / CLOCKS_PER_SEC;
	printf("Poslat je 1 GB podataka na prioritetu 2, za %f", seconds);
	return 0;*/
		/*
		byteCounter += size;
		if(byteCounter >= flowParameter*1024)
		{
			byteCounter = 0;
			Sleep(10);
		}*/
	//}while(true);
}

DWORD WINAPI ReceiveThread(LPVOID lpParam)
{
    SOCKET * socket=(SOCKET *)lpParam;
	char buffer[1024];
	int messageCounter = 0;
	int mbCounter=0;
	float secondsFor200Mb;
	float secondsFor1gb;
	clock_t start = clock();
	int mbC = 0;
	int byteCounter = 0;
	int kbCounter = 0;
	while(true)
	{
		receiveWrapper(socket,buffer,sizeof(int));
	    int size=*((int *)buffer);
		receiveWrapper(socket,buffer+sizeof(int),size);
		messageCounter++;
		byteCounter += (size + 3*sizeof(int));
		if(byteCounter >= 1024)
		{
			kbCounter += (byteCounter/1024);
			byteCounter = (byteCounter%1024);
			if(kbCounter >= 1024)
			{
				mbCounter += (kbCounter/1024);
				kbCounter = (kbCounter%1024);
				clock_t end = clock();
				float seconds = (float)(end - start) / CLOCKS_PER_SEC;
				secondsFor1gb=seconds;
				printf("Primljeno je %d mb! Vreme slanja je %f\n", mbCounter,seconds);
			}
		}
		if(mbCounter == 1024)
		{
			clock_t end = clock();
			float seconds = (float)(end - start) / CLOCKS_PER_SEC;
			printf("Primljen 1 GB na prioritetu 2, za %f", seconds);
			break;
		}


		/*
		if(messageCounter % 1000 == 0)
		{

			messageCounter=0;
			mbCounter++;
				mbC++;
				clock_t end = clock();
				float seconds = (float)(end - start) / CLOCKS_PER_SEC;
				secondsFor1gb=seconds;
				printf("Primljeno je %d mb! Vreme slanja je %f\n", mbCounter,seconds);
		}
		if(mbC == 1024)
		{
			clock_t end = clock();
			float seconds = (float)(end - start) / CLOCKS_PER_SEC;
			printf("Primljen 1 GB na prioritetu 2, za %f", seconds);
			break;
		}
			//clock_t end = clock();
			//float seconds = (float)(end - start) / CLOCKS_PER_SEC;
			//printf("Primljeno je 1024 poruke! Vreme slanja je %f\n", seconds);
		//Sleep(1);
		*/
	}
	return 0;
}