Add files via upload

Author: ashcode028

Intermediate/para1.txt

@@ -0,0 +1 @@
+hello can you hear me?

Intermediate/para2.txt

@@ -0,0 +1 @@
+heya! Am I audible?

Intermediate/q1.c

@@ -0,0 +1,55 @@
+#include<stdio.h>
+#include<stdlib.h>
+#include <unistd.h>
+#include <sys/wait.h>
+#include <string.h>
+
+
+ int main()
+ {
+ 	pid_t pid;
+ 	int fd1[2];
+ 	int fd2[2];
+
+ 	if(pipe(fd1)==-1){
+ 		fprintf(stderr,"Pipe1 failed");
+ 		return 1;
+ 	}
+ 	if(pipe(fd2)==-1){
+ 		fprintf(stderr,"Pipe2 failed");
+ 		return 1;
+ 	}
+	pid=fork();
+ 	if(pid <0){
+ 		fprintf(stderr, "Fork failed\n");
+
+ 	}
+ 	else if(pid == 0){
+ 		char str2[500];
+ 		close(fd1[1]);
+ 		close(fd2[0]);   //close unwanted discripters
+ 		read(fd1[0], str2,sizeof(str2));
+      		for (int i = 0; str2[i]!='\0'; i++) {
+      			if(str2[i] >= 'a' && str2[i] <= 'z') {
+         			str2[i] = str2[i] -32;
+      			}
+   		}
+      		write(fd2[1], str2, sizeof(str2));
+ 	
+ 	}
+ 	else{
+
+ 		char str1[500];
+ 		//scanf("%[^\n]s", str1);
+ 		fgets(str1,500,stdin);
+ 		//str1=getchar();
+ 		close(fd1[0]);   // close unwanted descriptors
+ 		close(fd2[1]);
+ 		write(fd1[1],str1,sizeof(str1));
+ 		wait(NULL);
+ 		read(fd2[0], str1, sizeof(str1));
+		printf("%s", str1 );
+
+ 	}
+ 	return 0;
+ }

Intermediate/q2b.c

@@ -0,0 +1,34 @@
+#include <stdio.h>
+#include <sys/ipc.h>
+#include <sys/msg.h>
+#include<string.h>
+// structure for message queue
+#define delim " ,\t\r\n\a"
+char buff[500];
+struct msg_buffer {
+   long msg_type;
+   char msg[500];
+} message;
+void main() {
+   key_t my_key;
+   int msg_id;
+   my_key = ftok("progfile", 65); //create unique key
+   msg_id = msgget(my_key, 0666 | IPC_CREAT); //create message queue and return id
+   message.msg_type = 1;
+  FILE *fd= fopen("para2.txt","r");
+      if(!fd){
+      printf("Error in opening the file\n");
+      }
+      //fgets(buff, 500, fd);
+   while(fgets(buff, 500, fd)>0){	
+   	char* token = strtok(buff," ");
+   	while(token!=NULL){
+   		strcpy(message.msg,token);
+   		msgsnd(msg_id, &message, sizeof(message), 0);
+   		token = strtok(NULL," ");
+   	}
+   }
+   //msgsnd(msg_id, &message, sizeof(message), 0); //send message
+   printf("Sent message is : %s \n", message.msg);
+}
+

Intermediate/q2c.c

@@ -0,0 +1,23 @@
+#include <stdio.h>
+#include <sys/ipc.h>
+#include <sys/msg.h>
+// Define message queue structure
+
+
+struct msg_buffer {
+   long msg_type;
+   char msg[500];
+} message;
+void main() {
+   key_t my_key;
+   int msg_id;
+   my_key = ftok("progfile", 65); //create unique key
+
+   msg_id = msgget(my_key, 0666 | IPC_CREAT); //create message queue and return id
+   msgrcv(msg_id, &message, sizeof(message), 1, 0); //used to receive message
+
+   printf("Received Message is : %s \n", message.msg);
+  // msgctl(msg_id, IPC_RMID, NULL); //destroy the message queue
+
+}
+

Intermediate/q3a.c

@@ -0,0 +1,32 @@
+#include <stdio.h>
+#include <sys/socket.h>
+#include <netinet/in.h>
+#include <string.h>
+
+int main(){
+  int sckid, nBytes;
+  char buff[1024];
+  struct sockaddr_in srvAdrs;
+  socklen_t addr_size;
+
+  /*Create UDP socket*/
+   if((sckid = socket(PF_INET, SOCK_DGRAM, 0))<0)
+  	  perror("cannot create socket\n");
+
+  /*Configure settings in address struct*/
+  srvAdrs.sin_family = AF_INET;
+  srvAdrs.sin_port = htons(8080);
+  srvAdrs.sin_addr.s_addr = INADDR_ANY;
+  memset(srvAdrs.sin_zero, '\0', sizeof srvAdrs.sin_zero);  
+  addr_size = sizeof srvAdrs;
+  
+   FILE *fd= fopen("para1.txt","r");
+   if(!fd){
+      printf("Error in opening the file\n");
+    }
+    fgets(buff, 500, fd);
+    if(sendto(sckid,buff,strlen(buff)+1 ,0,(struct sockaddr*)&srvAdrs,addr_size)<0)
+      perror("Sending packets failed");
+
+  return 0;
+}

Intermediate/q3c.c

@@ -0,0 +1,39 @@
+#include <stdio.h>
+#include <sys/socket.h>
+#include <netinet/in.h>
+#include <string.h>
+#include <stdlib.h>
+
+int main(){
+  int sckid, nBytes;
+  char buff[500];
+  struct sockaddr_in serverAddr, clientAddr;
+  struct sockaddr_storage srvSt;
+  socklen_t addr_size;
+  /*Create UDP socket*/
+  if((sckid = socket(PF_INET, SOCK_DGRAM, 0))<0)
+  	  perror("cannot create socket\n");
+
+  /*Configure settings in address struct*/
+  serverAddr.sin_family = AF_INET;
+  serverAddr.sin_port = htons(8080);
+  serverAddr.sin_addr.s_addr = INADDR_ANY;
+  memset(serverAddr.sin_zero, '\0', sizeof serverAddr.sin_zero); 
+  /*Bind socket with address struct*/
+  if(bind(sckid, (struct sockaddr *) &serverAddr, sizeof(serverAddr))<0)
+  	perror("bind failed");
+  	
+  addr_size = sizeof srvSt;
+
+/* Recieve packets*/
+  printf("waiting on port 8080\n");
+  nBytes = recvfrom(sckid,buff,500,0,(struct sockaddr *)&srvSt, &addr_size);
+
+  printf("received %d bytes\n", nBytes);
+  if (nBytes > 0) {
+         buff[nBytes] = 0;
+         printf("received message: \"%s\"\n", buff);
+   }
+
+  return 0;
+}

Intermediate/q5.c

@@ -0,0 +1,106 @@
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <sys/types.h>
+#include <sys/ipc.h>
+#include <sys/shm.h>
+#include<semaphore.h>
+#include<unistd.h>
+#include<pthread.h>
+#define SHM_SIZE 8 /* make it a 8byte hared memory segment */
+char *data;
+sem_t mutex,mutex_w;
+pthread_t writerthreads[10],readerthreads[102];
+int readercount = 0;
+
+void *writer(void* param)
+{   char *temp="Please Wait";
+    int i=(int)param;
+    printf("%d Writer is trying to enter\n",i);
+    sem_wait(&mutex_w);
+    
+    printf("Writer %d writing to segment: \"%s\"\n", i,temp);
+    strncpy(data,temp, SHM_SIZE);
+    sem_post(&mutex_w);
+    printf("%d Writer is leaving\n",i);
+    return NULL;
+}
+
+void *reader(void* param)
+{
+    int i=(int)param;
+    sem_wait(&mutex);
+    readercount++;
+    if(readercount==1)
+        sem_wait(&mutex_w);
+    sem_post(&mutex);
+    printf("%d reader is inside\n",i);
+    printf("Reader %d reading from segment:\"%s\"\n", i,data);
+    usleep(3);
+    sem_wait(&mutex);
+    readercount--;
+    if(readercount==0)
+    {
+        sem_post(&mutex_w);
+    }
+    sem_post(&mutex);
+    printf("%d Reader is leaving\n",i);
+    return NULL;
+}
+
+
+int main(int argc, char *argv[])
+{
+    key_t key;
+    int shmid;
+    int mode;
+    /* make the key: */
+    if ((key = ftok("hello.txt", 'R')) == -1) /*Here the file must exist */ 
+	{
+        perror("ftok");
+        exit(1);
+    }
+
+    /*  create the segment: */
+    if ((shmid = shmget(key, SHM_SIZE, 0644 | IPC_CREAT)) == -1) {
+        perror("shmget");
+        exit(1);
+    }
+
+    /* attach to the segment to get a pointer to it: */
+    data = shmat(shmid, NULL, 0);
+    if (data == (char *)(-1)) {
+        perror("shmat");
+        exit(1);
+    }
+    int i;
+    int n2=5;
+    int n1[n2];
+    sem_init(&mutex,0,1);
+    sem_init(&mutex_w,0,1);
+    for(i=0;i<n2;i++)
+    {
+        pthread_create(&writerthreads[i],NULL,writer,(void *)i);
+        pthread_create(&readerthreads[i],NULL,reader,(void *)i);
+    }
+    for(i=0;i<n2;i++)
+    {
+        pthread_join(writerthreads[i],NULL);
+        pthread_join(readerthreads[i],NULL);
+    }
+
+
+    /* detach from the segment: */
+    if (shmdt(data) == -1) {
+        perror("shmdt");
+        exit(1);
+    }
+    /* delete the segment: 
+    if (shmctl(shmid,IPC_RMID,NULL) == -1) {
+        perror("shmdt");
+        exit(1);
+    }
+    */
+    return 0;
+}
+

Intermediate/q6.c

@@ -0,0 +1,48 @@
+#include<stdio.h>
+#include<stdlib.h>
+#include<pthread.h>
+#include<semaphore.h>
+#include<unistd.h>
+
+#define N 5 
+#define LEFT i
+#define RIGHT (i+1) % N 
+sem_t room;
+sem_t forks[5];
+void * philosopher(void * num)
+{
+	int i=*(int *)num;
+
+	sem_wait(&room);
+	printf("\nPhilosopher %d has entered room",i+1);
+	sem_wait(&forks[LEFT]);
+	sem_wait(&forks[RIGHT]);
+
+	printf("\nPhilosopher %d is eating with %d and %d fork",i+1,LEFT,RIGHT);
+	sleep(2);
+
+	sem_post(&forks[RIGHT]);
+	sem_post(&forks[LEFT]);
+	printf("\nPhilosopher %d is thinking",i+1);
+	sem_post(&room);
+}
+
+
+int main()
+{
+	int i,a[5];
+	pthread_t tid[5];
+	
+	sem_init(&room,0,4);
+	
+	for(i=0;i<5;i++)
+		sem_init(&forks[i],0,1);
+		
+	for(i=0;i<5;i++){
+		a[i]=i;
+		pthread_create(&tid[i],NULL,philosopher,(void *)&a[i]);
+	}
+	for(i=0;i<5;i++)
+		pthread_join(tid[i],NULL);
+	return 0;
+}