---

client.c

/***************************************************************************
                                 client.c
                             -------------------
    begin                : Thu Jan 17 13:48:35 CET 2002
    copyright            : (C) 2002 by Christian Hoenig & Gunter Ohrner
    email                : pdepp@customcdrom.de
 ***************************************************************************/

/***************************************************************************
 *                                                                         *
 *   This program is free software; you can redistribute it and/or modify  *
 *   it under the terms of the GNU General Public License as published by  *
 *   the Free Software Foundation; either version 2 of the License, or     *
 *   (at your option) any later version.                                   *
 *                                                                         *
 ***************************************************************************/


#include <errno.h>
#include <pthread.h>

#include <sys/time.h>
#include <unistd.h>
#include <netdb.h>
#include <sys/socket.h> 
#include <netinet/in.h> 


#include "client.h"

#include "pdeppd/xmalloc.h"
#include "pdeppd/bufplist.h"

#include "deppmark.h"

int cConnect(char* buf, struct Buffer* file_to_catch)
{
  int sock = socket(PF_INET, SOCK_STREAM,0);
  struct sockaddr_in serv_addr;
/*  int bytes_read; */

  serv_addr.sin_family = AF_INET;
  serv_addr.sin_port   = port;
  serv_addr.sin_addr   = host_addr;

  if (connect(sock,(struct sockaddr*) &serv_addr, sizeof(struct sockaddr_in)) == -1)
  {
    fprintf(stderr, "Error: connect: failed %s\n", strerror(errno));
    return -1;
  }

  strcpy(buf, "GET ");
  strcpy(buf +4, file_to_catch->data);
  strcpy(buf +4 +file_to_catch->len, " HTTP/1.0\r\n\r\n");
  write(sock, buf, 4 + file_to_catch->len + 9 + 4);

  while((/* bytes_read = */ read(sock, buf, buf_len-1)) > 0)
  {
/*    buf[bytes_read] = '\0'; */
/*    printf("%s", buf); */
  };
    
  shutdown(sock, 2);
  close(sock);

  return 0;  
}

void cPause(long int msec)
{
  pthread_mutex_t mut = PTHREAD_MUTEX_INITIALIZER;
  pthread_cond_t cond = PTHREAD_COND_INITIALIZER;
  struct timespec tv;
  struct timeval now;
  long int timetowait_sec = msec / 1000;
  long int timetowait_nsec = (msec % 1000) * 1000000;

  pthread_mutex_lock(&mut);
  gettimeofday(&now, NULL);

  tv.tv_sec  = now.tv_sec         + timetowait_sec;
  tv.tv_nsec = now.tv_usec * 1000 + timetowait_nsec;

  pthread_cond_timedwait(&cond, &mut, &tv);

  pthread_mutex_unlock(&mut);
}

int virtualClient(void* num) 
{
  unsigned thrd_num = (unsigned) num;
  unsigned cnt = 0;
  char* method_buf;
  BufpList file_list_clone;

#ifndef NDEBUG
  printf("Thread number %u is going to bed...\n", thrd_num);
#endif

  // wait (num/10) seconds before executing...
  cPause(thrd_num*100);

#ifndef NDEBUG
  printf("Thread number %u woke up - GO!!!\n", thrd_num);
#endif

  // malloc is not thread-safe
  pthread_mutex_lock(&malloc_mut);
  method_buf = pd_malloc(buf_len);
  pthread_mutex_unlock(&malloc_mut);

  // clone filelist
  file_list_clone = bufpListClone(file_list);

  bufpListFirst(file_list_clone);
  
  // seek to a "random" position within the list... <g>
  for(cnt = 0; cnt < thrd_num; ++cnt)
  {
    if (bufpListIsTail(file_list_clone))
      bufpListFirst(file_list_clone);
    else
      bufpListNext(file_list_clone);
  }

  // Ok, let's go!
  for(cnt = 0; cnt < repeat; ++cnt)
  {
//    bufpListFirst(file_list_clone);
    while (!bufpListIsTail(file_list_clone))
    {
      if (cConnect(method_buf, bufpListGetPayload(file_list_clone)) == -1)
        break;

      /* Wait some time before issuing the next request... */
      cPause(delay * 100);

      bufpListNext(file_list_clone);
    }
  }

  bufpListTerminate(file_list_clone);

  // free is not thread-safe
  pthread_mutex_lock(&malloc_mut);
  pd_free(method_buf);
  pthread_mutex_unlock(&malloc_mut);

  return 0; 
}

---