src/joblist.c

   1 #include "first.h"
   2
   3 #include "base.h"
   4 #include "joblist.h"
   5
   6 #include <stdlib.h>
   7 #include <string.h>
   8
   9 int joblist_append(server *srv, connection *con) {
  10         if (srv->joblist->size == 0) {
  11                 srv->joblist->size  = 16;
  12                 srv->joblist->ptr   = malloc(sizeof(*srv->joblist->ptr) * srv->joblist->size);
  13                 force_assert(NULL != srv->joblist->ptr);
  14         } else if (srv->joblist->used == srv->joblist->size) {
  15                 srv->joblist->size += 16;
  16                 srv->joblist->ptr   = realloc(srv->joblist->ptr, sizeof(*srv->joblist->ptr) * srv->joblist->size);
  17                 force_assert(NULL != srv->joblist->ptr);
  18         }
  19
  20         srv->joblist->ptr[srv->joblist->used++] = con;
  21
  22         return 0;
  23 }
  24
  25 void joblist_free(server *srv, connections *joblist) {
  26         UNUSED(srv);
  27
  28         free(joblist->ptr);
  29         free(joblist);
  30 }
  31
  32 connection *fdwaitqueue_unshift(server *srv, connections *fdwaitqueue) {
  33         connection *con;
  34         UNUSED(srv);
  35
  36
  37         if (fdwaitqueue->used == 0) return NULL;
  38
  39         con = fdwaitqueue->ptr[0];
  40
  41         memmove(fdwaitqueue->ptr, &(fdwaitqueue->ptr[1]), --fdwaitqueue->used * sizeof(*(fdwaitqueue->ptr)));
  42
  43         return con;
  44 }
  45
  46 int fdwaitqueue_append(server *srv, connection *con) {
  47         if (srv->fdwaitqueue->size == 0) {
  48                 srv->fdwaitqueue->size  = 16;
  49                 srv->fdwaitqueue->ptr   = malloc(sizeof(*(srv->fdwaitqueue->ptr)) * srv->fdwaitqueue->size);
  50                 force_assert(NULL != srv->fdwaitqueue->ptr);
  51         } else if (srv->fdwaitqueue->used == srv->fdwaitqueue->size) {
  52                 srv->fdwaitqueue->size += 16;
  53                 srv->fdwaitqueue->ptr   = realloc(srv->fdwaitqueue->ptr, sizeof(*(srv->fdwaitqueue->ptr)) * srv->fdwaitqueue->size);
  54                 force_assert(NULL != srv->fdwaitqueue->ptr);
  55         }
  56
  57         srv->fdwaitqueue->ptr[srv->fdwaitqueue->used++] = con;
  58
  59         return 0;
  60 }
  61
  62 void fdwaitqueue_free(server *srv, connections *fdwaitqueue) {
  63         UNUSED(srv);
  64         free(fdwaitqueue->ptr);
  65         free(fdwaitqueue);
  66 }