source: trunk/src/sh_mem.c@ 149

Last change on this file since 149 was 149, checked in by katerina, 17 years ago

Make sh_hash.c thread-safe, remove plenty of tiny allocations, improve sh_mem_dump, modify port check to run as thread, and fix unsetting of sh_thread_pause_flag (was too early).
File size: 8.5 KB
Line 
1/* SAMHAIN file system integrity testing */
2/* Copyright (C) 1999, 2000 Rainer Wichmann */
3/* */
4/* This program is free software; you can redistribute it */
5/* and/or modify */
6/* it under the terms of the GNU General Public License as */
7/* published by */
8/* the Free Software Foundation; either version 2 of the License, or */
9/* (at your option) any later version. */
10/* */
11/* This program is distributed in the hope that it will be useful, */
12/* but WITHOUT ANY WARRANTY; without even the implied warranty of */
13/* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the */
14/* GNU General Public License for more details. */
15/* */
16/* You should have received a copy of the GNU General Public License */
17/* along with this program; if not, write to the Free Software */
18/* Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. */
19
20#include "config_xor.h"
21
22#if defined(HAVE_PTHREAD_MUTEX_RECURSIVE)
23#define _XOPEN_SOURCE 500
24#endif
25
26#include <stdio.h>
27#include <stdlib.h>
28#include <string.h>
29#include <sys/types.h>
30#include <unistd.h>
31
32
33#ifdef HAVE_MEMORY_H
34#include <memory.h>
35#endif
36
37#define SH_REAL_SET
38
39#include "samhain.h"
40#include "sh_error.h"
41#include "sh_utils.h"
42#include "sh_mem.h"
43#include "sh_pthread.h"
44
45extern int safe_logger (int signal, int method, char * details);
46
47#undef FIL__
48#define FIL__ _("sh_mem.c")
49
50#ifdef MEM_DEBUG
51
52#define CHECKBYTE 0x7F
53
54/* Memory alignment; should be 16 bytes on 64 bit machines.
55 * -> 32 bytes overhead/allocation
56 */
57#define SH_MEMMULT 16
58
59
60typedef struct mem_struct {
61 struct mem_struct *next; /* link to next struct */
62 char * real_address; /* address assigned */
63 char * address; /* address returned */
64 unsigned long size; /* size allocated */
65 char file[20]; /* Allocation file name */
66 int line; /* Allocation line number */
67} memlist_t;
68
69memlist_t * memlist = NULL;
70
71int Free_Count = 0, Alloc_Count = 0;
72int Now_Alloc_Count = 0, Max_Alloc_Count = 0;
73unsigned long Mem_Current = 0, Mem_Max = 0;
74
75#ifdef HAVE_PTHREAD
76SH_MUTEX_RECURSIVE(mutex_mem);
77#endif
78
79/* define MEM_LOG to an absolute filename to enable this */
80#ifdef MEM_LOG
81void sh_mem_dump ()
82{
83 memlist_t * this = memlist;
84 FILE * fd;
85
86 SH_MUTEX_RECURSIVE_INIT(mutex_mem);
87 SH_MUTEX_RECURSIVE_LOCK(mutex_mem);
88
89 fd = fopen(MEM_LOG, "w");
90 if (!fd)
91 {
92 perror(MEM_LOG);
93 _exit(EXIT_FAILURE);
94 }
95
96 while (this != NULL)
97 {
98 fprintf (fd, "## %20s %5d %ld\n", this->file, this->line, this->size);
99 fprintf (fd, "%10p %8ld\n", (void *)this->address, this->size);
100 this = this->next;
101 }
102 fclose(fd);
103
104 SH_MUTEX_RECURSIVE_UNLOCK(mutex_mem);
105 _exit(EXIT_SUCCESS);
106}
107#else
108void sh_mem_dump ()
109{
110 return;
111}
112#endif
113
114void sh_mem_stat ()
115{
116 memlist_t * this;
117
118
119 SL_ENTER(_("sh_mem_stat"));
120
121 SH_MUTEX_RECURSIVE_INIT(mutex_mem);
122 SH_MUTEX_RECURSIVE_LOCK(mutex_mem);
123
124 if (Alloc_Count == Free_Count)
125 {
126 sh_error_handle ((-1), FIL__, __LINE__, 0, MSG_MSTAMP,
127 Mem_Max, Mem_Current);
128 goto out;
129 }
130
131 sh_error_handle (SH_ERR_INFO, FIL__, __LINE__, 0, MSG_MSTAMP2,
132 Alloc_Count, Free_Count, Max_Alloc_Count);
133 sh_error_handle (SH_ERR_INFO, FIL__, __LINE__, 0, MSG_MSTAMP,
134 Mem_Max, Mem_Current);
135
136 this = memlist;
137
138 while (this != NULL)
139 {
140 sh_error_handle (SH_ERR_WARN, FIL__, __LINE__, 0, MSG_E_NOTFREE,
141 this->size, this->file, this->line);
142 this = this->next;
143 }
144 out:
145 ; /* label at end of compound statement */
146 SH_MUTEX_RECURSIVE_UNLOCK(mutex_mem);
147 SL_RET0(_("sh_mem_stat"));
148}
149
150void sh_mem_check ()
151{
152 memlist_t * this;
153 long nerr = 0;
154
155 SL_ENTER(_("sh_mem_check"));
156
157 SH_MUTEX_RECURSIVE_INIT(mutex_mem);
158 SH_MUTEX_RECURSIVE_LOCK(mutex_mem);
159
160 sh_error_handle ((-1), FIL__, __LINE__, 0, MSG_MSTAMP,
161 Mem_Max, Mem_Current);
162
163 this = memlist;
164
165 while (this != NULL)
166 {
167 if ( this->address == NULL )
168 {
169 sh_error_handle ((-1), FIL__, __LINE__, 0, MSG_E_MNULL);
170 ++nerr;
171 }
172 else
173 {
174 if ( this->address[this->size] != CHECKBYTE )
175 {
176 sh_error_handle ((-1), FIL__, __LINE__, 0, MSG_E_MOVER,
177 this->file, this->line, FIL__, __LINE__);
178 ++nerr;
179 }
180 if ( this->real_address[SH_MEMMULT-1] != CHECKBYTE )
181 {
182 sh_error_handle ((-1), FIL__, __LINE__, 0, MSG_E_MUNDER,
183 this->file, this->line, FIL__, __LINE__);
184 ++nerr;
185 }
186 }
187 this = this->next;
188 }
189
190
191 SH_MUTEX_RECURSIVE_UNLOCK(mutex_mem);
192 SL_RET0(_("sh_mem_check"));
193}
194
195void * sh_mem_malloc (size_t size, char * file, int line)
196{
197 void * the_realAddress;
198 void * theAddress;
199 memlist_t * this;
200
201 SL_ENTER(_("sh_mem_malloc"));
202
203 SH_MUTEX_RECURSIVE_INIT(mutex_mem);
204 SH_MUTEX_RECURSIVE_LOCK(mutex_mem);
205 the_realAddress = malloc(size + 2 * SH_MEMMULT);
206
207 if ( the_realAddress == NULL )
208 {
209 (void) safe_logger (0, 0, NULL);
210
211 /* use _exit() rather than exit() - we malloc() in atexit() functions
212 */
213 _exit (EXIT_FAILURE);
214 }
215
216 /* --- Set check bytes. ---
217 */
218 theAddress = ((char *) the_realAddress + SH_MEMMULT);
219
220 memset(the_realAddress, CHECKBYTE, SH_MEMMULT);
221 memset(theAddress, CHECKBYTE, size + 1);
222 memset(theAddress, 0, 1);
223
224 ++Alloc_Count;
225 ++Now_Alloc_Count;
226
227 if (Max_Alloc_Count < Now_Alloc_Count)
228 Max_Alloc_Count = Now_Alloc_Count;
229
230 Mem_Current += size;
231 Mem_Max = ( (Mem_Current > Mem_Max) ? Mem_Current : Mem_Max);
232
233 this = (memlist_t *) malloc (sizeof(memlist_t));
234
235 if ( this == NULL)
236 {
237 (void) safe_logger(0, 0, NULL);
238
239 _exit(EXIT_FAILURE);
240 }
241 else
242 {
243 /* make list entry */
244
245 this->real_address = the_realAddress;
246 this->address = theAddress;
247 this->size = size;
248 this->line = line;
249 sl_strlcpy(this->file, file, 20);
250
251 this->next = memlist;
252 memlist = this;
253 }
254
255 SH_MUTEX_RECURSIVE_UNLOCK(mutex_mem);
256 SL_RETURN( theAddress, _("sh_mem_malloc"));
257}
258
259
260void sh_mem_free (void * a, char * file, int line)
261{
262 memlist_t * this = memlist;
263 memlist_t * before = memlist;
264 unsigned long size = 0;
265
266 SL_ENTER(_("sh_mem_free"));
267
268 SH_MUTEX_RECURSIVE_INIT(mutex_mem);
269 SH_MUTEX_RECURSIVE_LOCK(mutex_mem);
270
271 if ( a == NULL )
272 {
273 sh_error_handle ((-1), FIL__, __LINE__, 0, MSG_E_MNULL,
274 file, line);
275 goto out;
276 }
277
278 /* -- Find record. --
279 */
280 while (this != NULL)
281 {
282 if (this->address == a)
283 break;
284 before = this;
285 this = this->next;
286 }
287
288 if (this == NULL)
289 {
290 sh_error_handle ((-1), FIL__, __LINE__, 0, MSG_E_MREC,
291 file, line);
292 goto out;
293 }
294 else
295 {
296 a = this->real_address;
297
298 if ( this->address[this->size] != CHECKBYTE )
299 {
300 sh_error_handle ((-1), FIL__, __LINE__, 0, MSG_E_MOVER,
301 this->file, this->line, file, line);
302 }
303 if ( this->real_address[SH_MEMMULT-1] != CHECKBYTE )
304 sh_error_handle ((-1), FIL__, __LINE__, 0, MSG_E_MUNDER,
305 this->file, this->line, file, line);
306
307 size = this->size;
308
309 if (this == memlist)
310 memlist = this->next;
311 else
312 before->next = this->next;
313 }
314
315 free(a);
316 if (this)
317 free(this);
318 ++Free_Count;
319 --Now_Alloc_Count;
320
321 Mem_Current -= size;
322 out:
323 ; /* label at end of compound statement */
324 SH_MUTEX_RECURSIVE_UNLOCK(mutex_mem);
325 SL_RET0(_("sh_mem_free"));
326}
327
328#else
329
330void sh_mem_free (void * a)
331{
332 SL_ENTER(_("sh_mem_free"));
333
334 if (a)
335 {
336 free(a);
337 }
338 else
339 {
340 sh_error_handle ((-1), FIL__, __LINE__, 0, MSG_E_MNULL);
341 }
342 SL_RET0(_("sh_mem_free"));
343}
344
345void * sh_mem_malloc (size_t size)
346{
347 void * theAddress;
348
349 SL_ENTER(_("sh_mem_malloc"));
350
351 theAddress = malloc(size);
352
353 if ( theAddress != NULL )
354 {
355 SL_RETURN( theAddress, _("sh_mem_malloc"));
356 }
357 else
358 {
359 (void) safe_logger(0, 0, NULL);
360
361 /* use _exit() rather than exit() - we malloc() in atexit()
362 */
363 _exit (EXIT_FAILURE);
364 }
365}
366#endif
Note: See TracBrowser for help on using the repository browser.