client.c

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <pthread.h>
#include <unistd.h>
#include <time.h>

#include <sys/socket.h>
#include "sock.h"
#include "buffer.h"

void *producer();
void *consumer();
void *transmitter_handler();

int port;
char file_name[200];
FILE *fr;
buffer b;

#define check(A,msg) \
  if ((A)) { \
    printf("##msg"); \
    exit(1); \
  }
    
int MAX_THREADS;
int main(int argc, char *argv[])
{
  pthread_t pthread_consumidor, pthread_produtor;

  if (argc != 4)
  {
    printf("Usage: %s port filename nthreads\n", argv[0]);
    return 1;
  }
  port = atoi(argv[1]);

  strncpy(file_name, argv[2], 199);
  file_name[199] = '\0';

  MAX_THREADS = atoi(argv[3]);
  initBuffer(&b);

  double start = clock();
  check(pthread_create(&pthread_produtor, NULL, producer, NULL), "ERROR creating thread producer!!\n");
  check(pthread_create(&pthread_consumidor, NULL, consumer, NULL), "ERROR creating thread consumer!!\n")
  check(pthread_join(pthread_consumidor, NULL), "ERROR joining thread consumer")
  check(pthread_join(pthread_produtor, NULL), "ERROR joining thread producer")

  double end = clock();
  printf("Tempo total de execucao: %.2e\n", ((double)(end - start)/ CLOCKS_PER_SEC));
  destructBuffer(&b);
  pthread_exit(NULL);
  return 1;
}

void *producer()
{
  buffer_element elem;
  buffer *pb = &b;
  int n_read;
  fr = fopen (file_name, "rb");
  
  elem.pos = ftell(fr);
  n_read = fread(&elem.c, sizeof(char), 1, fr);
  while(n_read != 0)
  {
    pb->insert(pb, elem);
    elem.pos = ftell(fr);
    n_read = fread(&elem.c, sizeof(char), 1, fr);
  }
  elem.c = EOF;
  elem.pos = -1;
  for (int i = 0; i < MAX_THREADS; i++)
  {
    pb->insert(pb, elem);
  }
  fclose(fr);  /* close the file prior to exiting the routine */
  return 0;
}
void *consumer()
{
  pthread_t n_threads[MAX_THREADS];
  for (int i = 0; i < MAX_THREADS; i++)
  {
    check(pthread_create(&n_threads[i], NULL, transmitter_handler, NULL), "Failed to create the client consumer thread");
  }
  for (int i = 0; i < MAX_THREADS; i++)
  {
    check(pthread_join(n_threads[i], NULL), "Error joining threads");
  }

  return NULL;
}

void *transmitter_handler()
{
  buffer *pb = &b;
  int s = sock_conn("localhost", port);
  if (s < 0)
    printf("Error: Couldn't connect to localhost at port %d!\n", port);

  buffer_element elem;
  elem  = pb->get(pb);
  while (elem.pos != -1)
  {
    if (send(s, &elem, sizeof(elem), 0) < 0)
    {
      printf("Send failed\n");
    }
    elem = pb->get(pb);
  }
  close(s);
  return NULL;
}