File: rds_util.c

package info (click to toggle)
rvm 1.13%2Bdebian-1
  • links: PTS
  • area: main
  • in suites: etch, etch-m68k
  • size: 2,800 kB
  • ctags: 2,012
  • sloc: ansic: 20,307; sh: 8,996; makefile: 115
file content (264 lines) | stat: -rw-r--r-- 6,552 bytes parent folder | download | duplicates (2)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
/* BLURB lgpl

                           Coda File System
                              Release 5

          Copyright (c) 1987-1999 Carnegie Mellon University
                  Additional copyrights listed below

This  code  is  distributed "AS IS" without warranty of any kind under
the  terms of the  GNU  Library General Public Licence  Version 2,  as
shown in the file LICENSE. The technical and financial contributors to
Coda are listed in the file CREDITS.

                        Additional copyrights
                           none currently

#*/


#include <stdio.h>
#include "rds_private.h"
    
#ifndef ZERO
#define ZERO 0
#endif

int
enqueue(list, block, tid, err)
     free_list_t  *list;
     free_block_t *block;
     rvm_tid_t    *tid;
     int	  *err;
{
    assert(0);
    return -1;
}

/*
 * Dequeue a memory object from the front of a list, return the memory object.
 */

free_block_t *
dequeue(list, tid, err)
     free_list_t  *list;
     rvm_tid_t    *tid;
     int	   *err;
{
    free_block_t *block = list->head;
    free_block_t *ptr;
    rvm_return_t rvmerr;
    
    /* Take the block off the head of the list. */
    rvmerr = rvm_set_range(tid, list, sizeof(free_list_t));
    if (rvmerr != RVM_SUCCESS) {
	(*err) = (int) rvmerr;
	return NULL;
    }
    ptr = list->head = block->next;

    if (ptr) {
	rvmerr = rvm_set_range(tid, &(ptr->prev), sizeof(free_list_t *));
	if (rvmerr != RVM_SUCCESS) {
	    (*err) = (int) rvmerr;
	    return NULL;
	}
	ptr->prev = (free_block_t *)NULL;
    }
	
    *err = SUCCESS;
    return block;
}

/*
 * Sometimes we want to remove an object from the middle of a list. This
 * routine takes a list, a pointer to the previous object, a ptr to the object,
 * and a transaction ID, the status is passed back in err. NOTE: If the object
 * is the first one on the list, prev isn't used.
 */
int
rm_from_list(list, bp, tid, err)
     free_list_t   *list;
     free_block_t  *bp;
     rvm_tid_t     *tid;
     int	    *err;
{
    rvm_return_t rvmret;
    free_block_t *ptr;
    
    /* If block is at the head of the list, dequeue will cleanly remove it. */
    if (bp == list->head) {
	bp = dequeue(list, tid, err);
	if (bp == NULL)
	    return ZERO;
    } else {
	/* Because we're not at the end, we know bp->prev is a valid pointer. */
	ptr = bp->prev;
	rvmret = rvm_set_range(tid, &(ptr->next), sizeof(free_block_t *));
	if (rvmret != RVM_SUCCESS) {
	    (*err) = (int) rvmret;
	    return ZERO;
	}
	ptr->next = bp->next;
	
	ptr = bp->next;
	if (ptr) {
	    rvmret = rvm_set_range(tid, &(ptr->prev), sizeof(free_block_t *));
	    if (rvmret != RVM_SUCCESS) {
		(*err) = (int) rvmret;
		return ZERO;
	    }
	    ptr->prev = bp->prev; /* NOTE: this may be zero */
	}
    }

    *err = SUCCESS;
    return 1;
}

/* Print out the free list structure */
int
print_heap()
{
    int i, j;
    int total_size = 0;
    free_block_t *fbp, *ptr;
    
    if (!HEAP_INIT)	/* Make sure RecoverableHeapStartAddress is inited */
	return -1;

    CRITICAL({
	printf("Heap starts at %lx, uses %ld sized chunks, and use %ld of %ld lists\n",
	       (long)RecoverableHeapStartAddress, RDS_CHUNK_SIZE, 
	       RDS_MAXLIST, RDS_NLISTS);

	for (i = 1; i < RDS_NLISTS + 1; i++) {
	    printf("list %d %c\n",i, ((i == RDS_MAXLIST)?'+':' '));
	    fbp = RDS_FREE_LIST[i].head;

	    if (RDS_FREE_LIST[i].guard != FREE_LIST_GUARD)
		printf("Bad guard on list %d!!!\n", i);

	    if (fbp && (fbp->prev != (free_block_t *)NULL))
		printf("Non-null Initial prev pointer.\n");
	    
	    j = 1;
	    while (fbp != NULL) {
		printf("%d	block %lx, size %ld\n", j++, (long)fbp, 
		       fbp->size);
		total_size += fbp->size;
	    
		if (fbp->type != FREE_GUARD)
		    printf("Bad lowguard on block\n");
		if ((*BLOCK_END(fbp)) != END_GUARD)
		    printf("Bad highguard, %p=%lx\n", BLOCK_END(fbp), 
						      *BLOCK_END(fbp));
		ptr = fbp->next;
		if (ptr && (ptr->prev != fbp))
		    printf("Bad chain link %lx <-> %lx\n", (long)fbp, 
			   (long)ptr);
		if (i != RDS_MAXLIST && fbp->size != i)
		    printf("OBJECT IS ON WRONG LIST!!!!\n");
		    
		fbp = fbp->next;
	    }
	}
    });
    
    printf("Sum of sizes of objects in free lists is %d.\n", total_size);
    return 0;
}

/*
 * Rather than having malloc access the lists directly, it seems wiser to
 * have intermediary routines to get and put blocks on the list.
 */

free_block_t *
get_block(size, tid, err)
      int       size;
      rvm_tid_t *tid;
      int	*err;
{
    int list = ((size >= RDS_MAXLIST)?RDS_MAXLIST:size);
    
    /* Check the guard on the list. */
    if (RDS_FREE_LIST[list].guard != FREE_LIST_GUARD) {
	*err = ECORRUPT;
	return NULL;
    }
    
    /* Update stats. Don't need a setrange, caller should have done that. */
    if ((RDS_FREE_LIST[list].head == NULL) ||	   /* For smaller blocks */
	(RDS_FREE_LIST[list].head->size != size)) { /* In case of large block */
	/* A block isn't available so we need to split one. */
	if (list < RDS_MAXLIST)
	    RDS_STATS.misses++;
	else
	    RDS_STATS.large_misses++;
	
	return split(size, tid, err);
    }

    assert(RDS_FREE_LIST[list].head->size == size); /* Sanity check */

    if (list < RDS_MAXLIST)
	RDS_STATS.hits++;	
    else
	RDS_STATS.large_hits++;	
	

    /* Fbp could be null indicating an error occured in dequeue. Let
       the calling routine handle this error. */
    return dequeue(&RDS_FREE_LIST[list], tid, err);
}

int
put_block(bp, tid, err)
     free_block_t *bp;
     rvm_tid_t    *tid;
     int	  *err;
{
    rvm_return_t rvmerr;
    int size = (((bp->size) >= RDS_MAXLIST)?RDS_MAXLIST:(bp->size));
    free_list_t *list = &RDS_FREE_LIST[size];
    free_block_t *ptr;

    /* Check the guard on the list. */
    if (list->guard != FREE_LIST_GUARD) {
	*err = ECORRUPT;
	return -1;
    }
    
    /* Add the block to the head of the list */
    rvmerr = rvm_set_range(tid, bp, sizeof(free_block_t));
    if (rvmerr != RVM_SUCCESS) {
	(*err) = (int) rvmerr;
	return -1;
    }
    bp->next = list->head;
    bp->prev = (free_block_t *)NULL;

    /* Make the old head of the list point to the new block. */
    ptr = bp->next;
    if (ptr) {
	rvmerr = rvm_set_range(tid, &(ptr->prev), sizeof(free_block_t *));
	if (rvmerr != RVM_SUCCESS) {
	    (*err) = (int) rvmerr;
	    return -1;
	}
	ptr->prev = bp;
    }
	
    /* Make the head point to the freed block */
    rvmerr = rvm_set_range(tid, list, sizeof(free_list_t));
    if (rvmerr != RVM_SUCCESS) {
	(*err) = (int) rvmerr;
	return -1;
    }
    list->head = bp;
    
    (*err) = SUCCESS;
    return 0;
}