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
|
/*-
* Copyright (c) 2009-2010 Fabio Checconi, Luigi Rizzo
* All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
* 2. Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
*
* THIS SOFTWARE IS PROVIDED BY THE AUTHORS AND CONTRIBUTORS ``AS IS'' AND
* ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
* ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHORS OR CONTRIBUTORS BE LIABLE
* FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
* OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
* LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
* OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
* SUCH DAMAGE.
*/
#ifndef _G_SCHED_H_
#define _G_SCHED_H_
/*
* $Id$
* $FreeBSD$
*
* Header for the geom_sched class (userland library and kernel part).
* See g_sched.c for documentation.
* The userland code only needs the three G_SCHED_* values below.
*/
#define G_SCHED_CLASS_NAME "SCHED"
#define G_SCHED_VERSION 0
#define G_SCHED_SUFFIX ".sched."
#ifdef _KERNEL
#define G_SCHED_DEBUG(lvl, ...) do { \
if (me.gs_debug >= (lvl)) { \
printf("GEOM_SCHED"); \
if (me.gs_debug > 0) \
printf("[%u]", lvl); \
printf(": "); \
printf(__VA_ARGS__); \
printf("\n"); \
} \
} while (0)
#define G_SCHED_LOGREQ(bp, ...) do { \
if (me.gs_debug >= 2) { \
printf("GEOM_SCHED[2]: "); \
printf(__VA_ARGS__); \
printf(" "); \
g_print_bio(bp); \
printf("\n"); \
} \
} while (0)
LIST_HEAD(g_hash, g_sched_class);
/*
* Descriptor of a scheduler.
* In addition to the obvious fields, sc_flushing and sc_pending
* support dynamic switching of scheduling algorithm.
* Normally, sc_flushing is 0, and requests that are scheduled are
* also added to the sc_pending queue, and removed when we receive
* the 'done' event.
*
* When we are transparently inserted on an existing provider,
* sc_proxying is set. The detach procedure is slightly different.
*
* When switching schedulers, sc_flushing is set so requests bypass us,
* and at the same time we update the pointer in the pending bios
* to ignore us when they return up.
* XXX it would be more efficient to implement sc_pending with
* a generation number: the softc generation is increased when
* we change scheduling algorithm, we store the current generation
* number in the pending bios, and when they come back we ignore
* the done() call if the generation number do not match.
*/
struct g_sched_softc {
/*
* Generic fields used by any scheduling algorithm:
* a mutex, the class descriptor, flags, list of pending
* requests (used when flushing the module) and support
* for hash tables where we store per-flow queues.
*/
struct mtx sc_mtx;
struct g_gsched *sc_gsched; /* Scheduler descriptor. */
int sc_pending; /* Pending requests. */
int sc_flags; /* Various flags. */
/*
* Hash tables to store per-flow queues are generally useful
* so we handle them in the common code.
* sc_hash and sc_mask are parameters of the hash table,
* the last two fields are used to periodically remove
* expired items from the hash table.
*/
struct g_hash *sc_hash;
u_long sc_mask;
int sc_flush_ticks; /* Next tick for a flush. */
int sc_flush_bucket; /* Next bucket to flush. */
/*
* Pointer to the algorithm's private data, which is the value
* returned by sc_gsched->gs_init() . A NULL here means failure.
* XXX intptr_t might be more appropriate.
*/
void *sc_data;
};
#define G_SCHED_PROXYING 1
#define G_SCHED_FLUSHING 2
/*
* Temporary- our own version of the disksort, because the
* version in 7.x and 8.x before march 2009 is buggy.
*/
void gs_bioq_init(struct bio_queue_head *);
void gs_bioq_remove(struct bio_queue_head *, struct bio *);
void gs_bioq_flush(struct bio_queue_head *, struct devstat *, int);
void gs_bioq_insert_head(struct bio_queue_head *, struct bio *);
void gs_bioq_insert_tail(struct bio_queue_head *, struct bio *);
struct bio *gs_bioq_first(struct bio_queue_head *);
struct bio *gs_bioq_takefirst(struct bio_queue_head *);
void gs_bioq_disksort(struct bio_queue_head *, struct bio *);
#endif /* _KERNEL */
#endif /* _G_SCHED_H_ */
|
