One Level Up Top Level

src/worker.c - weighttp

Functions defined

Source code

  1. /*
  2. * weighttp - a lightweight and simple webserver benchmarking tool
  3. *
  4. * Author:
  5. *     Copyright (c) 2009-2011 Thomas Porzelt
  6. *
  7. * License:
  8. *     MIT, see COPYING file
  9. */

  11. #include "weighttp.h"

  13. ‌Worker *worker_new(uint8_t id, Config *config, uint16_t num_clients, uint64_t num_requests) {
  14.     Worker *worker;
  15.     uint16_t i;

  17.     worker = W_MALLOC(Worker, 1);
  18.     worker->id = id;
  19.     worker->loop = ev_loop_new(0);
  20.     ev_ref(worker->loop);
  21.     worker->config = config;
  22.     worker->num_clients = num_clients;
  23.     worker->stats.req_todo = num_requests;
  24.     worker->progress_interval = num_requests / 10;

  26.     if (worker->progress_interval == 0)
  27.         worker->progress_interval = 1;

  29.     worker->clients = W_MALLOC(Client*, num_clients);

  31.     for (i = 0; i < num_clients; i++) {
  32.         if (NULL == (worker->clients[i] = client_new(worker)))
  33.             return NULL;
  34.     }

  36.     return worker;
  37. }

  39. ‌void worker_free(Worker *worker) {
  40.     uint16_t i;

  42.     for (i = 0; i < worker->num_clients; i++)
  43.         client_free(worker->clients[i]);

  45.     free(worker->clients);
  46.     free(worker);
  47. }

  49. ‌void *worker_thread(void* arg) {
  50.     uint16_t i;
  51.     Worker *worker = (Worker*)arg;

  53.     /* start all clients */
  54.     for (i = 0; i < worker->num_clients; i++) {
  55.         if (worker->stats.req_started < worker->stats.req_todo)
  56.             client_state_machine(worker->clients[i]);
  57.     }

  59.     ev_loop(worker->loop, 0);

  61.     ev_loop_destroy(worker->loop);

  63.     return NULL;
  64. }

One Level Up Top Level