Unzipping the codes

Author: ssaurab

Assignment1/.DS_Store

@@ -0,0 +1,10 @@
+all : clien server srclient srserver
+clien:
+	g++ GBNC.cpp -o clien -std=c++0x -pthread
+server:
+	g++ server.cpp -o server -std=c++0x
+srclient:
+	g++ srclient.cpp -o srclient -std=c++0x -pthread
+srserver:	
+	g++ srserver.cpp -o srserver -std=c++0x
+

Assignment1/Assignment1-CS16B039.tar.gz

@@ -0,0 +1,20 @@
+******************************************************************
+			CS16B039
+		     S SRINIVAS SAURAB
+			README
+
+******************************************************************
+
+The port number is hardcoded and thus need not be mentioned.
+To run the source codes, first compile them using make file.
+After that run the executables in pairs as follows : 
+
+SR : ./srclient -d -s m2 -p 12345 -n 8 -L 512 -R 10 -N 10 -W 4 -B 100
+     ./srserver -d -p 2312 -N 10 -n 8 -w 4 -B 100 -e 0.5
+
+GBN : ./clien -d -s machine1 -p 12345 -l 512 -r 10 -n 10 -w 4 -b 6
+	./server -d -p 000 -n 10 -e 0.1
+Note : do not exculed any field in the command line input, except for -d 
+flag which can be removed if debugging mode is not to be activated. Also the 
+order of these parameters must be maintained same.
+

Assignment1/Assignment1-CS16B039/GBNC.cpp

@@ -0,0 +1,158 @@
+// Server side implementation of UDP client-server model 
+#include <bits/stdc++.h> 
+#include <sys/types.h> 
+#include <sys/socket.h> 
+#include <arpa/inet.h> 
+#include <netinet/in.h> 
+#include <cstdlib>
+
+using namespace std;
+
+#define PORT	 8080 
+#define MAXLINE 1024 
+
+
+int binaryToDecimal(int n) 
+{ 
+	int num = n; 
+	int dec_value = 0; 
+	
+	// Initializing base value to 1, i.e 2^0 
+	int base = 1; 
+	
+	int temp = num; 
+	while (temp) 
+	{ 
+		int last_digit = temp % 10; 
+		temp = temp/10; 
+		
+		dec_value += last_digit*base; 
+		
+		base = base*2; 
+	} 
+	
+	return dec_value; 
+} 
+
+int MAX_PACKETS;
+float rate;
+// Driver code 
+int main(int argc, char const *argv[])
+{ 
+	bool debugflag = false;
+	if(argv[1][0] == '-' && argv[1][1] == 'd')
+	{
+		cout << "ywah" << endl;
+		debugflag = true;
+		MAX_PACKETS = atoi(argv[5]);
+		rate = atof(argv[7]);
+	}
+	else
+	{
+		//debugflag = true;.
+		MAX_PACKETS = atoi(argv[4]);
+		rate = atof(argv[6]);
+	}
+
+
+
+	int sockfd; 
+	char buffer[MAXLINE]; 
+	char *hello = "Hello from server"; 
+	struct sockaddr_in servaddr, cliaddr; 
+	
+	// Creating socket file descriptor 
+	if ( (sockfd = socket(AF_INET, SOCK_DGRAM, 0)) < 0 ) { 
+		perror("socket creation failed"); 
+		exit(EXIT_FAILURE); 
+	} 
+
+	//int MAX_PACKETS = 100;
+	int gotit[MAX_PACKETS] = {0};
+	
+	memset(&servaddr, 0, sizeof(servaddr)); 
+	memset(&cliaddr, 0, sizeof(cliaddr)); 
+	
+	// Filling server information 
+	servaddr.sin_family = AF_INET; // IPv4 
+	servaddr.sin_addr.s_addr = INADDR_ANY; 
+	servaddr.sin_port = htons(PORT); 
+	
+	// Bind the socket with the server address 
+	if ( bind(sockfd, (const struct sockaddr *)&servaddr, 
+			sizeof(servaddr)) < 0 ) 
+	{ 
+		perror("bind failed"); 
+		exit(EXIT_FAILURE); 
+	} 
+	
+	int windowstart = 0;
+	//int windowsize = 4;
+	while(true){
+		int n; 
+		socklen_t len;
+		n = recvfrom(sockfd, (char *)buffer, MAXLINE, 
+					MSG_WAITALL, ( struct sockaddr *) &cliaddr, 
+					&len); 
+		buffer[n] = '\0';
+
+		int decval = 0;
+
+		cout << buffer << endl;
+
+		string s = buffer;
+
+		cout << s << endl;
+
+		for(int i = 0; i < 32; i++)
+		{
+			//cout << s[i]<< endl;
+			if(s[i] == '\0') break;
+			else if(s[i] == '1')
+				decval = decval * 2 + 1;
+			else 
+				decval = decval * 2;
+		}
+
+		cout << decval << endl;
+		string p;
+		p = to_string(decval);
+		printf("Client : %s\n", buffer); 
+		//&& decval < windowsize + windowstart && decval >= windowstart
+		if(((float)(rand()%10)/10.00000000) > rate)
+		{
+			cout << "got the packet" <<decval <<endl;
+			gotit[decval] = 1;
+
+			int x = 1;
+			int u = -1;
+			while(x == 1 && u < MAX_PACKETS)
+			{
+				u++;
+				x = gotit[u];
+			}
+		//	if(gotit[0] == 0) u = -1;
+			u--;
+			if(u < decval) gotit[decval] = 0;
+			p = to_string(u);
+			//cout << (float)(rand() % 10) / 10 << endl;
+
+			sendto(sockfd, (const char *)&p[0], p.size(), 
+			MSG_CONFIRM, (const struct sockaddr *) &cliaddr, 
+				len);
+			if(u == MAX_PACKETS-1) 
+			{
+				return 0;
+			}
+			cout << "sent" << p << endl;
+
+			if(windowstart == decval - 1)
+			{
+				windowstart ++;
+			}
+		} 
+		printf("Hello message sent.\n"); 
+	}
+	
+	return 0; 
+}