client.c

#include "extra.h"

int pipe_p2c[2];
int pipe_c2p[2];
int* figures ;
char name[100] = "";
void equipMain(int client_sock);
void commoditySales(int client_sock);
void writeCache(int* figures);
void readCache(int* figures);

typedef struct mess_buffer {
    long mesg_type;
    char mesg_text[BUFF_SIZE];
} message;


int
main(int argc, char *argv[])
{

  figures = (int*) malloc(3 * sizeof(int));
  char* figures_str = (char*) malloc(BUFF_SIZE);
  int server_port = 0;
  char server_ip[16] = "";
  int stat;
  
  va_cli(argc, argv, server_ip, &server_port, &name);

  int client_sock;
  
  struct sockaddr_in server_addr;
  
  // Construct socket
  client_sock = socket(AF_INET,SOCK_STREAM,0);
  
  // Specify server address
  server_addr.sin_family = AF_INET;
  server_addr.sin_port = htons(server_port);
  server_addr.sin_addr.s_addr = inet_addr(server_ip);

  // Request to connect server
  if(connect(client_sock,
	     (struct sockaddr*)&server_addr,
	     sizeof(struct sockaddr)) < 0)
    {
      printf("\nError!Can not connect to sever! \
                Client exit imediately!\n");
      return 0;
    }

  if(send(client_sock, name, 100, 0) < 0) {
    printf("Cannot send machine's name\nClient exit imediately!\n");
    return 0;
  }
  recv(client_sock,figures_str,  BUFF_SIZE, 0);
  sscanf(figures_str, "%d %d %d", figures, figures + 1, figures + 2);
  writeCache(figures);
  printf("recvd figures from server %d %d %d\n", figures[0], figures[1], figures[2]);
  pid_t pid = fork();

    if(pid == 0) {
      equipMain(client_sock);
      //exit(0);
    } else {
      while(1) {
	
	char stri[BUFF_SIZE];    
	recv(client_sock,stri,BUFF_SIZE,0);
	int x;
	sscanf(stri,"%d", &x);
        printf("\nDang giao hang cho 10s hi hi hi\n Co nhan cung khong duoc dau\n");
	readCache(figures);
	figures[x] += 10;

	writeCache(figures);
	kill(pid,SIGSTOP);
	pid_t pid2 = fork();
	if (pid2 == 0){
	  char i;
	  while(1)
	    scanf("%c", &i);
	}
	sleep(10);
	fseek(stdin,0,SEEK_END);
	kill(pid2, SIGKILL);
	menu_home(figures);
	kill(pid, SIGCONT);
	
	
      }
    }
  
   

  
  close(client_sock);
  return 0;
}

void
equipMain(int client_sock)
{
  
  
  while(1)
    {
      menu_home(figures); 
      int c;
      char i;
      //fflush(stdin);
      //while ((i = getchar()) != '\n' && i != EOF) { }
      fseek(stdin,0,SEEK_END);
      
      scanf("%d", &c);
      readCache(figures);
      	
      if (figures[c-1] <= 0 && c != 4){
	printf("sold out!\n");
	continue;
      }
      else if (c != 4)
	figures[c-1] -= 1; 
      writeCache(figures);
      switch(c)
	{
	case 4:
	  menu_bye();
	  send(client_sock,
	       "shut_down", strlen("shut_down") + 1, 0);
	  kill(0, SIGKILL);
	  exit(0);
	 
	} // end switch menu home

      char buff[BUFF_SIZE];
      sprintf(buff,"%d",c-1);
      
     
      pipe(pipe_p2c);
      pipe(pipe_c2p);

      pid_t pid = 0;


      // la la la
      /*
      if(fork() == 0) {
	key_t key = 1234;
	int msqid = msgget(key,IPC_CREAT | 0664);
	//printf("%d~~\n",msqid);
	message mess_x;
	mess_x.mesg_type = 1;

	char stri[BUFF_SIZE];
    
	recv(client_sock,stri,BUFF_SIZE,0);
	
	strcpy(mess_x.mesg_text,stri);
	printf("xx\n");
	int aa;
	if((aa = msgsnd(msqid,&mess_x,sizeof(mess_x),0)) == -1)
	  printf("nhan duoc cai nay nay %s --  %d\n",stri,aa);
	
	exit(0);
      }
      */
      // la la la

      
      switch(pid = fork())
	{
	case -1:
	  perror("processGenerate fork");
	  exit(1);
	case 0:
	  //printf("childProcess start\n");
	  commoditySales(client_sock);
	  exit(0);
	default:
	  //printf("parentProcess start\n");

	  close(pipe_p2c[0]);
	  write(pipe_p2c[1], buff, strlen(buff) + 1);
	  close(pipe_p2c[1]);

	  wait(NULL);
	  
	  char tmp[BUFF_SIZE];
	  
	  close(pipe_c2p[1]);
	  read(pipe_c2p[0], tmp, BUFF_SIZE);
	  close(pipe_c2p[0]);

	  printf("\n\n%s\n\n",tmp);

	  // xam xi tai day
	  /*
	  key_t key = 1234;
	  int msqid = msgget(key,IPC_CREAT | 0664);
	  message mess_y;
	  mess_y.mesg_type = 1;

	  msgrcv(msqid,&mess_y,sizeof(mess_y),1,0);
	  int xx;
	  sscanf(mess_y.mesg_text,"%d",&xx);
	  figures[xx] += 10;
	  */
	  // xam xi

		
	} // end switch fork()
    } // end while
  
}

void
commoditySales(int client_sock)
{
  char recv_str[BUFF_SIZE];

  close(pipe_p2c[1]);
  read(pipe_p2c[0], recv_str, BUFF_SIZE);
  close(pipe_p2c[0]);

  char send_str[BUFF_SIZE] = "Thank you for chosing us\n";

  close(pipe_c2p[0]);
  write(pipe_c2p[1], send_str, strlen(send_str) + 1);
  close(pipe_c2p[1]);

  send(client_sock, recv_str, strlen(recv_str) + 1, 0);
  
}

void writeCache(int* figures){
  char a[100] = "cache_";
  FILE *f = fopen(strcat(a,name) , "w");
  int i = 0;
  while(i < 3){
    fprintf(f, "%d\n", figures[i]);
    i++;
  }
  fclose(f);
}

void readCache(int* figures){
  char a[100] = "cache_";
  FILE *f = fopen(strcat(a,name) , "r");
  int i = 0;
  while(i < 3){
    fscanf(f, "%d\n", figures+i);
    i++;
  }
  fclose(f);
}