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
|
/*
* CDDL HEADER START
*
* The contents of this file are subject to the terms of the
* Common Development and Distribution License (the "License").
* You may not use this file except in compliance with the License.
*
* You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
* or http://www.opensolaris.org/os/licensing.
* See the License for the specific language governing permissions
* and limitations under the License.
*
* When distributing Covered Code, include this CDDL HEADER in each
* file and include the License file at usr/src/OPENSOLARIS.LICENSE.
* If applicable, add the following below this CDDL HEADER, with the
* fields enclosed by brackets "[]" replaced with your own identifying
* information: Portions Copyright [yyyy] [name of copyright owner]
*
* CDDL HEADER END
*/
/*
* Copyright 2006 Sun Microsystems, Inc. All rights reserved.
* Use is subject to license terms.
*/
#ifndef _SYS_SOCKFS_NL7CURI_H
#define _SYS_SOCKFS_NL7CURI_H
#pragma ident "%Z%%M% %I% %E% SMI"
#ifdef __cplusplus
extern "C" {
#endif
#include <sys/types.h>
#include <sys/atomic.h>
#include <sys/cmn_err.h>
#include <sys/stropts.h>
#include <sys/socket.h>
#include <sys/socketvar.h>
#undef PROMIF_DEBUG
/*
* Some usefull chararcter macros:
*/
#ifndef tolower
#define tolower(c) ((c) >= 'A' && (c) <= 'Z' ? (c) | 0x20 : (c))
#endif
#ifndef isdigit
#define isdigit(c) ((c) >= '0' && (c) <= '9')
#endif
#ifndef isalpha
#define isalpha(c) (((c) >= 'A' && (c) <= 'Z') || ((c) >= 'a' && (c) <= 'z'))
#endif
#ifndef isspace
#define isspace(c) ((c) == ' ' || (c) == '\t' || (c) == '\n' || \
(c) == '\r' || (c) == '\f' || (c) == '\013')
#endif
/*
* ref_t - reference type, ...
*
* Note, all struct's must contain a single ref_t, all must use
* kmem_cache, all must use the REF_* macros for free.
*/
typedef struct ref_s {
uint32_t cnt; /* Reference count */
void (*last)(void *); /* Call-back for last ref */
kmem_cache_t *kmc; /* Container allocator cache */
} ref_t;
#define REF_INIT(container, count, inactive, kmem) { \
(container)->ref.cnt = (count); \
(container)->ref.last = (void (*)(void *))((inactive)); \
(container)->ref.kmc = (kmem); \
}
#define REF_HOLD(container) { \
atomic_add_32(&(container)->ref.cnt, 1); \
ASSERT((container)->ref.cnt != 0); \
}
#define REF_RELE(container) { \
if (atomic_add_32_nv(&(container)->ref.cnt, -1) == 0) { \
(container)->ref.last((container)); \
kmem_cache_free((container)->ref.kmc, (container)); \
} \
}
#define REF_COUNT(container) (container)->ref.cnt
#define REF_ASSERT(container, count) \
ASSERT((container)->ref.cnt == (count));
/*
* str_t - string type, used to access a an arbitrary span of a char[].
*/
typedef struct str_s {
char *cp; /* Char pointer current char */
char *ep; /* Char pointer past end of string */
} str_t;
/*
* uri_*_t - URI descriptor, used to describe a cached URI object.
*/
typedef struct uri_rd_s {
size_t sz; /* Size of data */
offset_t off; /* Offset into file or -1 for kmem */
union { /* Response data */
char *kmem; /* Data in kmem */
vnode_t *vnode; /* Data in vnode */
} data;
struct uri_rd_s *next; /* Next response descriptor */
} uri_rd_t;
typedef struct uri_desc_s {
struct uri_desc_s *hash; /* Hash *next */
uint64_t hit; /* Hit counter */
clock_t expire; /* URI lbolt expires on (-1 = NEVER) */
#ifdef notyet
void *sslctx; /* SSL context */
#endif
boolean_t nocache; /* URI no cache */
boolean_t conditional; /* Conditional response */
uint32_t hvalue; /* Hashed value */
mblk_t *reqmp; /* Request mblk_t */
str_t path; /* Path name of response */
str_t auth; /* Authority for response */
ssize_t resplen; /* Response length */
ssize_t respclen; /* Response chunk length */
char *eoh; /* End of header pointer */
void *scheme; /* Scheme private state */
ref_t ref; /* Reference stuff */
size_t count; /* rd_t chain byte count */
uri_rd_t *tail; /* Last response descriptor */
uri_rd_t response; /* First response descriptor */
struct sonode *proc; /* Socket processing this uri */
kcondvar_t waiting; /* Socket(s) waiting for processing */
kmutex_t proclock; /* Lock for proc and waiting */
} uri_desc_t;
/* Hash the (char)c to the hash accumulator (uint32_t)hv */
#define CHASH(hv, c) (hv) = ((hv) << 5) + (hv) + c; (hv) &= 0x7FFFFFFF
#define URI_TEMP (uri_desc_t *)-1 /* Temp (nocache) uri_t.hash pointer */
#define URI_LEN_NOVALUE -1 /* Length (int) counter no value yet */
#define URI_LEN_CONSUMED -2 /* Length (int) counter consumed */
typedef struct uri_segmap_s {
ref_t ref; /* Reference, one per uri_desb_t */
caddr_t base; /* Base addr of segmap mapping */
size_t len; /* Length of segmap mapping */
vnode_t *vp; /* Vnode mapped */
} uri_segmap_t;
typedef struct uri_desb_s {
frtn_t frtn; /* For use by esballoc() and freinds */
uri_desc_t *uri; /* Containing URI of REF_HOLD() */
uri_segmap_t *segmap; /* If segmap mapped else NULL */
} uri_desb_t;
/*
* Add (and create if need be) a new uri_rd_t to a uri.
*
* Note, macro can block, must be called from a blockable context.
*/
#define URI_RD_ADD(uri, rdp, size, offset) { \
if ((uri)->tail == NULL) { \
(rdp) = &(uri)->response; \
} else { \
(rdp) = kmem_cache_alloc(nl7c_uri_rd_kmc, KM_SLEEP); \
(uri)->tail->next = (rdp); \
} \
(rdp)->sz = size; \
(rdp)->off = offset; \
(rdp)->next = NULL; \
(uri)->tail = rdp; \
(uri)->count += size; \
}
#ifdef __cplusplus
}
#endif
#endif /* _SYS_SOCKFS_NL7CURI_H */
|
