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
|
/* Remember where we've written the disk to speed up sync
Copyright (C) 1994, 1995 Free Software Foundation, Inc.
Written by Michael I. Bushnell.
This file is part of the GNU Hurd.
The GNU Hurd is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License as
published by the Free Software Foundation; either version 2, or (at
your option) any later version.
The GNU Hurd is distributed in the hope that it will be useful, but
WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
General Public License for more details.
You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. */
#include "ext2fs.h"
void pokel_init (struct pokel *pokel, struct pager *pager, void *image)
{
pokel->lock = SPIN_LOCK_INITIALIZER;
pokel->pokes = NULL;
pokel->pager = pager;
pokel->image = image;
}
/* Remember that data here on the disk has been modified. */
void
pokel_add (struct pokel *pokel, void *loc, vm_size_t length)
{
struct poke *pl;
vm_offset_t offset = trunc_page (loc - pokel->image);
vm_offset_t end = round_page (loc + length - pokel->image);
printf ("pokel_add (%p, %p, %u) [%u, %u]\n", pokel, loc, length, offset, end);
spin_lock (&pokel->lock);
pl = pokel->pokes;
while (pl != NULL)
{
vm_offset_t p_offs = pl->offset;
vm_size_t p_end = p_offs + pl->length;
if (p_offs == offset && p_end == end)
break;
else if (p_end >= offset && end >= p_offs)
{
pl->offset = offset < p_offs ? offset : p_offs;
pl->length = (end > p_end ? end : p_end) - pl->offset;
printf ("Extended %d[%d] to %d[%d] in pokel %p\n", p_offs, p_end,
pl->offset, pl->length, pokel);
break;
}
pl = pl->next;
}
if (pl == NULL)
{
pl = pokel->free_pokes;
if (pl == NULL)
pl = malloc (sizeof (struct poke));
else
pokel->free_pokes = pl->next;
pl->offset = offset;
pl->length = end - offset;
pl->next = pokel->pokes;
pokel->pokes = pl;
printf ("Added %d[%d] to pokel %p\n", offset, end - offset, pokel);
}
spin_unlock (&pokel->lock);
}
/* Sync all the modified pieces of disk */
void
pokel_sync (struct pokel *pokel, int wait)
{
struct poke *pl, *next;
spin_lock (&pokel->lock);
for (pl = pokel->pokes; pl; pl = next)
{
printf ("Syncing %d[%d] from pokel %p\n", pl->offset, pl->length, pokel);
pager_sync_some (pokel->pager, pl->offset, pl->length, wait);
next = pl->next;
pl->next = pokel->free_pokes;
pokel->free_pokes = pl;
}
pokel->pokes = NULL;
spin_unlock (&pokel->lock);
}
|