Program - 5
Aim: Program to implement Mutual Exclusion to share files using token based
algorithm.
Code:
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <errno.h>
#include <string.h>
#include <sys/types.h>
#include <time.h>
#define MAXLINE 1024
typedef struct sockaddr SA;
typedef struct sockaddr_in SA_IN;
void verify(int num, char * quitMessage){
if(num < 0)
{
perror(quitMessage);
exit(EXIT_FAILURE);
}
}
int connect_to_port(int port_num){
int sock_id; int opt = 1;
SA_IN server_addr;
verify(sock_id = socket(AF_INET, SOCK_DGRAM, 0), "Unable to create socket");
setsockopt(sock_id, SOL_SOCKET, SO_REUSEADDR,
(const void *)&opt, sizeof(int));
memset(&server_addr, 0, sizeof(server_addr));
server_addr.sin_family = AF_INET;
server_addr.sin_addr.s_addr = INADDR_ANY;
server_addr.sin_port = htons(port_num);
verify(bind(sock_id, (const SA * ) & server_addr,
sizeof(server_addr)), "Unable to bind to port");
return sock_id;
}
void critical_section(int self_port){
printf("Critical Section Entered\n");
sleep(5);
FILE * fp = fopen("common_token_ring.txt","a");
fprintf(fp,"Process %d was here\n", self_port);
fclose(fp);
}
int main(int argc,char* argv[]) {
int self_port = atoi(argv[1]);
int next_port = atoi(argv[2]);
int initiate = atoi(argv[3]);
char buffer[MAXLINE];
printf("Initialising the server at port %d.\n", self_port);
int sockfd = connect_to_port(self_port);
struct sockaddr_in next_client_addr, prev_client_addr;
int len, n;
char response[MAXLINE];
memset(&next_client_addr,0,sizeof(next_client_addr));
next_client_addr.sin_family=AF_INET;
next_client_addr.sin_addr.s_addr = inet_addr("127.0.0.1");
next_client_addr.sin_port = htons(next_port);
if(initiate)
{
critical_section(self_port);
strcpy(response,"ACK");
printf("Printing %s to port %d.\n", response, next_port);
int check = sendto(sockfd, (const char * ) response, strlen(response),
MSG_CONFIRM,(const SA *)&next_client_addr,
sizeof(next_client_addr));
memset(&prev_client_addr, 0 , sizeof(prev_client_addr));
n = recvfrom(sockfd, (char*)buffer,MAXLINE, MSG_WAITALL,
(SA * ) &prev_client_addr, &len);
buffer[n]='\0';
if(!strcmp(buffer,"ACK"))
{
strcpy(response,"TERM");
sendto(sockfd, (const char * ) response, strlen(response),
MSG_CONFIRM, (const SA *) & next_client_addr,
sizeof(next_client_addr));
printf("Exiting\n");
}
else
{
printf("Invalid Message Recieved\n");
}
exit(0);
}
else
{
while(1)
{
memset(&prev_client_addr, 0, sizeof(prev_client_addr));
printf("Ready to Listen at port %d\n", self_port);
n = recvfrom(sockfd, (char*)buffer, MAXLINE,
MSG_WAITALL, ( SA *)&prev_client_addr, &len);
buffer[n]='\0';
if(!strcmp(buffer,"ACK"))
{
critical_section(self_port);
printf("Printing %s to port %d.\n", buffer, next_port);
sendto(sockfd, (const char * ) buffer, strlen(buffer),
MSG_CONFIRM, (const SA *) & next_client_addr,
sizeof(next_client_addr));
}
else if(!strcmp(buffer,"TERM"))
{
printf("Printing %s to port %d.\n", buffer , next_port);
sendto(sockfd, (const char * ) buffer, strlen(buffer),
MSG_CONFIRM, (const SA *) & next_client_addr,
sizeof(next_client_addr));
printf("Exiting\n");
exit(0);
}
else{
printf("Invalid Message Recieved\n");
}
}
}
}
Output:
Process 1: -
Process 2: -
Process 3: -
Shared File: -
