Programming

#include<stdio.h>
#include<unistd.h>
#include<stdlib.h>
#include<sys/types.h>
#include<string.h>
#include<sys/wait.h>
#include<sys/stat.h>
#include<dirent.h>
#include<semaphore.h>
#include<pthread.h>
#include<fcntl.h>

char **buffer3,**buffer4;

sem_t empty,full;
int in=0;
pthread_mutex_t mutex=PTHREAD_MUTEX_INITIALIZER;

void *stage3();
void *stage4();

int main(){
pthread_t thrd1,thrd2;

buffer3 = (char **)malloc(10);
buffer4 = (char **)malloc(10);

pthread_mutex_init(&mutex,NULL);
sem_init(&empty,0,10);
sem_init(&full,0,0);

int tid1 = pthread_create(&thrd1,NULL,&stage3,(void *)0);
	if(tid1 == -1)
	perror("cant create thread \n");
	int tid2 = pthread_create(&thrd2,NULL,&stage4,(void *)0);
    if(tid2 == -1)
    perror("cant create thread \n");
    
    pthread_join(thrd1, NULL);
     pthread_join(thrd2, NULL);
//getchar();

sem_destroy(&empty);
sem_destroy(&full);
exit(0);

}

void *stage3(){
	
	int r;
	char file[] = "sample.txt";
	char str[256];
	FILE *fd;
	fd = fopen(file,"r");
	
	while(1){
		
		r = random()%30000;
        usleep(r);
     
		sem_wait(&empty);
		pthread_mutex_lock(&mutex);
	
	    if(fgets(str,sizeof(str),fd)==NULL)
	    pthread_exit(NULL);
	    //printf("str = %s \n",str);
	         str[strlen(str)-1] = '\0';
	         buffer3[in] = str;
	         //printf("\n buffer3in[%d] = %s\n",in,buffer3[in]);
	         in = (in+1)%10;	           
	    pthread_mutex_unlock(&mutex);
	    sem_post(&full);		    	
	}
	printf("\n buffer3in[3] = %s\n",buffer3[3]);
	pthread_exit(NULL);
}

void *stage4(){
	//printf("In stage 4 \n");
	char *str2 = "asd";
	int out = 0;
	int in2 = 0;
	int r;
	
	while(1){
		r = random()%30000;
        usleep(r);
        //printf("buffer is not full \n");
        sem_wait(&full);
        pthread_mutex_lock(&mutex);
        //printf(" comapring $$ buffer3out[%d] %s $$  \n",out,buffer3[out]);    
        if(strstr(buffer3[out],str2)){
			buffer4[in2] = buffer3[out];
			printf(" \n buffer4 = %s \n",buffer4[in2]);
			//buffer3[out] = NULL;
			in2 = (in2+1)%10;
			

		}
		
		out = (out+1)%10;
		
		pthread_mutex_unlock(&mutex);
		sem_post(&empty);
	}
	
	pthread_exit(NULL);
	
}

ameya@ameya-Dell-System-Inspiron-N4110:~/os_concepts/Advanced_shell$ ./read

 buffer3in[0] = cat deer dog bando moron bahavar.
 comapring $$ buffer3out[0] cat deer dog bando moron bahavar. $$  

 buffer3in[1] = asdsdas
 comapring $$ buffer3out[1] asdsdas $$  

 buffer3in[2] = asdsdasbhafd

 buffer3in[3] = asdsgetg

 buffer3in[4] = adgrg
 comapring $$ buffer3out[2] adgrg $$  
 comapring $$ buffer3out[3] adgrg $$

ameya@ameya-Dell-System-Inspiron-N4110:~/os_concepts/Advanced_shell$ ./read

 buffer3in[0] = cat deer dog bando moron bahavar.

 buffer3in[1] = asdsdas

 buffer3in[2] = asdsdasbhafd

 buffer3in[3] = asdsgetg

 buffer3in[4] = adgrg
 comapring $$ buffer3out[0] adgrg $$  
 comapring $$ buffer3out[1] adgrg $$  
 comapring $$ buffer3out[2] adgrg $$  
 comapring $$ buffer3out[3] adgrg $$  
 comapring $$ buffer3out[4] adgrg $$  

 buffer3in[5] = grgdfdsfds

buffer3 = (char **)malloc(10);
buffer4 = (char **)malloc(10);

fgets(str,sizeof(str),fd)==NULL

buffer3[in] = str;