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
|
/* Private data for pager library.
Copyright (C) 1994, 1995 Free Software Foundation
This program 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.
This program 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 <mach.h>
#include <hurd.h>
#include "pager.h"
#include <hurd/ports.h>
/* Define this if you think the kernel is sending memory_object_init
out of sequence with memory_object_terminate. */
/* #undef KERNEL_INIT_RACE */
struct pager
{
struct port_info port;
struct user_pager_info *upi;
enum
{
NOTINIT, /* before memory_object_init */
NORMAL, /* while running */
SHUTDOWN, /* ignore all further requests */
} pager_state;
struct mutex interlock;
struct condition wakeup;
struct lock_request *lock_requests; /* pending lock requests */
struct attribute_request *attribute_requests; /* pending attr requests */
boolean_t may_cache;
memory_object_copy_strategy_t copy_strategy;
/* Interface ports */
memory_object_control_t memobjcntl;
memory_object_name_t memobjname;
int seqno;
int noterm; /* number of threads blocking termination */
struct pager *next, **pprev;
int termwaiting:1;
int waitingforseqno:1;
#ifdef KERNEL_INIT_RACE
/* Out of sequence object_init calls waiting for
terminations. */
struct pending_init *init_head, *init_tail;
#endif
char *pagemap;
int pagemapsize;
};
struct lock_request
{
struct lock_request *next, **prevp;
vm_address_t start, end;
int pending_writes;
int locks_pending;
int threads_waiting;
};
struct attribute_request
{
struct attribute_request *next, **prevp;
boolean_t may_cache;
memory_object_copy_strategy_t copy_strategy;
int threads_waiting;
int attrs_pending;
};
#ifdef KERNEL_INIT_RACE
struct pending_init
{
mach_port_t control;
mach_port_t name;
struct pending_init *next;
};
#endif
enum page_errors
{
PAGE_NOERR,
PAGE_ENOSPC,
PAGE_EIO,
PAGE_EDQUOT,
};
int _pager_page_errors[];
/* Pagemap format */
/* These are binary state bits */
#define PM_INIT 0x80 /* data has been written */
#define PM_PAGINGOUT 0x40 /* being written to disk */
#define PM_PAGEINWAIT 0x20 /* provide data back when write done */
#define PM_INVALID 0x10 /* data on disk is irrevocably wrong */
/* These take values of enum page_errors */
/* Doesn't belong here; this is the error that should have been passed
through m_o_data_error to the user but isn't; this lets internal use
of the pager know what the error is. */
#define PM_ERROR(byte) (((byte) & 0xc) >> 2)
#define SET_PM_ERROR(byte,err) (((byte) & ~0xc) | ((err) << 2))
/* Issue this error on next data_request, but only if it asks for
write access. */
#define PM_NEXTERROR(byte) ((byte) & 0x3)
#define SET_PM_NEXTERROR(byte,err) (((byte) & ~0x3) | (err))
struct port_class *_pager_class;
void _pager_wait_for_seqno (struct pager *, int);
void _pager_release_seqno (struct pager *, int);
void _pager_block_termination (struct pager *);
void _pager_allow_termination (struct pager *);
void _pager_pagemap_resize (struct pager *, vm_address_t);
void _pager_mark_next_request_error (struct pager *, vm_address_t,
vm_size_t, error_t);
void _pager_mark_object_error (struct pager *, vm_address_t,
vm_size_t, error_t);
void _pager_lock_object (struct pager *, vm_offset_t, vm_size_t, int, int,
vm_prot_t, int);
void _pager_free_structure (struct pager *);
void _pager_clean (void *arg);
void _pager_real_dropweak (void *arg);
|
