src/cmsg.c

   1 /*
   2  * cmsg.c
   3  *
   4  * create and free message buffers
   5  *
   6  * Copyright 1996 (c) D-J Koopman
   7  *
   8  * $Header$
   9  */
  10
  11
  12 static char rcsid[] = "$Id$";
  13
  14 #include <time.h>
  15 #include <stdlib.h>
  16
  17 #include "chain.h"
  18 #include "cmsg.h"
  19
  20 long cmsg_count = 0;
  21
  22 #ifdef DB_CMSG
  23 #include <malloc.h>
  24 #include <stdio.h>
  25
  26
  27 #define MAXSORT 20
  28 #define INTERVAL 10
  29 #define FN "msg_stats"
  30
  31 static struct {
  32         long new;
  33         long free;
  34 } stats[MAXSORT+1];
  35
  36 static void store()
  37 {
  38         static time_t t;
  39         time_t systime;
  40
  41         time(&systime);
  42         if (systime - t > INTERVAL) {
  43                 FILE *f = fopen(FN, "w");
  44                 if (f) {
  45                         int i;
  46                         struct mallinfo m;
  47                         fprintf(f, "\nMSG STATISTICS\n");
  48                         fprintf(f,   "==============\n\n");
  49                         fprintf(f, "cmsg_count = %ld\n\n", cmsg_count);
  50                         for (i = 0; i < MAXSORT+1; ++i) {
  51                                 if (stats[i].new == 0 && stats[i].free == 0)
  52                                         continue;
  53                                 fprintf(f, "%d new: %ld free: %ld outstanding: %ld\n", i, stats[i].new, stats[i].free, stats[i].new-stats[i].free);
  54                         }
  55                         m = mallinfo();
  56                         fprintf(f, "\nmalloc total arena used: %ld used: %ld free: %ld\n\n", m.arena, m.uordblks, m.fordblks);
  57                         fclose(f);
  58                 }
  59                 t = systime;
  60         }
  61 }
  62
  63 void cmsg_clear_stats()
  64 {
  65         memset(stats, 0, sizeof stats);
  66         store();
  67 }
  68
  69 #endif
  70
  71 cmsg_t *cmsg_new(int size, int sort, void *pp)
  72 {
  73         cmsg_t *mp;
  74
  75         mp = malloc(sizeof(cmsg_t) + size);
  76         if (!mp)
  77                 die("no room in cmsg_new");
  78         mp->size = 0;
  79         mp->sort = sort & CMSG_SORTMASK;
  80         mp->portp = pp;
  81         mp->state = mp->reply = 0;
  82         mp->inp = mp->data;
  83         mp->callback = 0;
  84         ++cmsg_count;
  85 #ifdef DB_CMSG
  86         if (sort > MAXSORT)
  87                 sort = MAXSORT;
  88         ++stats[sort].new;
  89         store();
  90 #endif
  91         return mp;
  92 }
  93
  94
  95 void cmsg_send(reft *base, cmsg_t *mp, void (*callback)())
  96 {
  97         time(&mp->t);
  98         mp->size = mp->inp - mp->data;     /* calc the real size */
  99         mp->callback = callback;                   /* store the reply address */
 100         chain_insert(base, mp);
 101 #ifdef DB_CMSG
 102         store();
 103 #endif
 104 }
 105
 106 void cmsg_priority_send(reft *base, cmsg_t *mp, void (*callback)())
 107 {
 108         time(&mp->t);
 109         mp->size = mp->inp - mp->data;     /* calc the real size */
 110         mp->callback = callback;                   /* store the reply address */
 111         chain_add(base, mp);
 112 #ifdef DB_CMSG
 113         store();
 114 #endif
 115 }
 116
 117 /*
 118  * get the next cmsg (from the front), this removes the message from the chain
 119  */
 120
 121 cmsg_t *cmsg_next(reft *base)
 122 {
 123         cmsg_t *mp = chain_get_next(base, 0);
 124         if (mp)
 125                 chain_delete(mp);
 126 #ifdef DB_CMSG
 127         store();
 128 #endif
 129         return mp;
 130 }
 131
 132 /*
 133  * get the prev cmsg (from the back), this removes the message from the chain
 134  */
 135
 136 cmsg_t *cmsg_prev(reft *base)
 137 {
 138         cmsg_t *mp = chain_get_prev(base, 0);
 139         if (mp)
 140                 chain_delete(mp);
 141 #ifdef DB_CMSG
 142         store();
 143 #endif
 144         return mp;
 145 }
 146
 147 void cmsg_callback(cmsg_t *m, int reply)
 148 {
 149         if (m->callback)
 150                 (m->callback)(m, reply);
 151         cmsg_free(m);
 152 }
 153
 154 void cmsg_free(cmsg_t *m)
 155 {
 156         --cmsg_count;
 157 #ifdef DB_CMSG
 158         if (m->sort > MAXSORT)
 159                 m->sort = MAXSORT;
 160         ++stats[m->sort].free;
 161         store();
 162 #endif
 163         free(m);
 164 }
 165
 166 void cmsg_flush(reft *base, int reply)
 167 {
 168         cmsg_t *m;
 169
 170         while (m = cmsg_next(base)) {
 171                 cmsg_callback(m, reply);
 172         }
 173 #ifdef DB_CMSG
 174         store();
 175 #endif
 176 }
 177
 178 /*
 179  *
 180  * $Log$
 181  * Revision 1.3  2000-10-29 11:00:07  minima
 182  * added echo cancelling
 183  * started new filter code, objectifyed old filter code
 184  *
 185  * Revision 1.2  2000/07/20 14:16:00  minima
 186  * can use Sourceforge now!
 187  * added user->qra cleaning
 188  * added 4 digit qra to user broadcast dxspots if available
 189  *
 190  * Revision 1.1  2000/03/26 00:03:30  djk
 191  * first cut of client
 192  *
 193  * Revision 1.12  1998/05/05 14:01:27  djk
 194  * Tidied up various global variables in the hope that there is likely
 195  * to be less undefined interaction between modules.
 196  * Added some extra LINUX debugging to check for possible cmsg memory leaks.
 197  *
 198  * Revision 1.11  1998/01/02 19:39:58  djk
 199  * made various changes to cope with glibc
 200  * fixed problem with extended status in etsi_router
 201  *
 202  * Revision 1.10  1997/06/13 16:51:17  djk
 203  * fixed various library problems
 204  * got the taipstack and hayes to the point of half duplex reliability
 205  * hayes now successfully communicates with taiptest and has part of the
 206  * command level taip stuff in.
 207  *
 208  * Revision 1.9  1997/05/20 20:45:14  djk
 209  * The 1.22 version more or less unchanged
 210  *
 211  * Revision 1.8  1997/03/25 18:12:55  djk
 212  * dunno
 213  *
 214  * Revision 1.7  1997/03/19 09:57:28  djk
 215  * added a count to check for leaks
 216  *
 217  * Revision 1.6  1997/02/13 17:02:04  djk
 218  * forgotten?
 219  *
 220  * Revision 1.5  1997/02/04 17:47:04  djk
 221  * brought into line with public2
 222  *
 223  * Revision 1.4  1997/02/04 01:27:37  djk
 224  * altered size semantics on create (size now = 0 not creation size)
 225  *
 226  * Revision 1.3  1997/01/20 22:29:27  djk
 227  * added status back
 228  *
 229  * Revision 1.2  1997/01/13 23:34:29  djk
 230  * The first working test version of smsd
 231  *
 232  * Revision 1.1  1997/01/03 23:42:21  djk
 233  * added a general message handling module (still developing)
 234  * added parity handling to ser.c
 235  *
 236  */