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
|
/*
* CDDL HEADER START
*
* The contents of this file are subject to the terms of the
* Common Development and Distribution License, Version 1.0 only
* (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 2005 Sun Microsystems, Inc. All rights reserved.
* Use is subject to license terms.
*/
#ifndef _UDP_IMPL_H
#define _UDP_IMPL_H
#pragma ident "%Z%%M% %I% %E% SMI"
/*
* UDP implementation private declarations. These interfaces are
* used to build the IP module and are not meant to be accessed
* by any modules except IP itself. They are undocumented and are
* subject to change without notice.
*/
#ifdef __cplusplus
extern "C" {
#endif
#ifdef _KERNEL
#include <sys/int_types.h>
#include <netinet/in.h>
#include <netinet/ip6.h>
#include <inet/common.h>
#include <inet/ip.h>
#define UDP_MOD_ID 5607
/* udp_mode. UDP_MT_HOT and UDP_SQUEUE are stable modes. Rest are transient */
typedef enum {
UDP_MT_HOT = 0, /* UDP endpoint is MT HOT */
UDP_MT_QUEUED = 1, /* Messages enqueued in udp_mphead */
UDP_QUEUED_SQUEUE = 2, /* Messages enqueued in conn_sqp */
UDP_SQUEUE = 3 /* Single threaded using squeues */
} udp_mode_t;
/* Internal udp control structure, one per open stream */
typedef struct udp_s {
uint32_t udp_state; /* TPI state */
in_port_t udp_port; /* Port bound to this stream */
in_port_t udp_dstport; /* Connected port */
in6_addr_t udp_v6src; /* Source address of this stream */
in6_addr_t udp_bound_v6src; /* Explicitly bound address */
in6_addr_t udp_v6dst; /* Connected destination */
uint32_t udp_flowinfo; /* Connected flow id and tclass */
uint32_t udp_max_hdr_len; /* For write offset in stream head */
sa_family_t udp_family; /* Family from socket() call */
/*
* IP format that packets transmitted from this struct should use.
* Value can be IP4_VERSION or IPV6_VERSION.
*/
ushort_t udp_ipversion;
uint32_t udp_ip_snd_options_len; /* Len of IPv4 options */
uchar_t *udp_ip_snd_options; /* Ptr to IPv4 options */
uint32_t udp_ip_rcv_options_len; /* Len of IPv4 options recvd */
uchar_t *udp_ip_rcv_options; /* Ptr to IPv4 options recvd */
uchar_t udp_multicast_ttl; /* IP*_MULTICAST_TTL/HOPS */
ipaddr_t udp_multicast_if_addr; /* IP_MULTICAST_IF option */
uint_t udp_multicast_if_index; /* IPV6_MULTICAST_IF option */
int udp_bound_if; /* IP*_BOUND_IF option */
int udp_xmit_if; /* IP_XMIT_IF option */
conn_t *udp_connp;
uint32_t
udp_debug : 1, /* SO_DEBUG "socket" option. */
udp_dontroute : 1, /* SO_DONTROUTE "socket" option. */
udp_broadcast : 1, /* SO_BROADCAST "socket" option. */
udp_useloopback : 1, /* SO_USELOOPBACK "socket" option */
udp_reuseaddr : 1, /* SO_REUSEADDR "socket" option. */
udp_dgram_errind : 1, /* SO_DGRAM_ERRIND option */
udp_recvdstaddr : 1, /* IP_RECVDSTADDR option */
udp_recvopts : 1, /* IP_RECVOPTS option */
udp_discon_pending : 1, /* T_DISCON_REQ in progress */
udp_unspec_source : 1, /* IP*_UNSPEC_SRC option */
udp_ipv6_recvpktinfo : 1, /* IPV6_RECVPKTINFO option */
udp_ipv6_recvhoplimit : 1, /* IPV6_RECVHOPLIMIT option */
udp_ipv6_recvhopopts : 1, /* IPV6_RECVHOPOPTS option */
udp_ipv6_recvdstopts : 1, /* IPV6_RECVDSTOPTS option */
udp_ipv6_recvrthdr : 1, /* IPV6_RECVRTHDR option */
udp_ipv6_recvtclass : 1, /* IPV6_RECVTCLASS */
udp_ipv6_recvpathmtu : 1, /* IPV6_RECVPATHMTU */
udp_anon_priv_bind : 1,
udp_exclbind : 1, /* ``exclusive'' binding */
udp_recvif : 1, /* IP_RECVIF option */
udp_recvslla : 1, /* IP_RECVSLLA option */
udp_recvttl : 1, /* IP_RECVTTL option */
udp_recvucred : 1, /* IP_RECVUCRED option */
udp_old_ipv6_recvdstopts : 1, /* old form of IPV6_DSTOPTS */
udp_ipv6_recvrthdrdstopts : 1, /* IPV6_RECVRTHDRDSTOPTS */
udp_rcvhdr : 1, /* UDP_RCVHDR option */
udp_issocket : 1, /* socket mode */
udp_direct_sockfs : 1, /* direct calls to/from sockfs */
udp_pad_to_bit_31 : 4;
uint8_t udp_type_of_service; /* IP_TOS option */
uint8_t udp_ttl; /* TTL or hoplimit */
ip6_pkt_t udp_sticky_ipp; /* Sticky options */
uint8_t *udp_sticky_hdrs; /* Prebuilt IPv6 hdrs */
uint_t udp_sticky_hdrs_len; /* Incl. ip6h and any ip6i */
struct udp_s *udp_bind_hash; /* Bind hash chain */
struct udp_s **udp_ptpbhn; /* Pointer to previous bind hash next. */
udp_mode_t udp_mode; /* Current mode of operation */
mblk_t *udp_mphead; /* Head of the queued operations */
mblk_t *udp_mptail; /* Tail of the queued operations */
uint_t udp_mpcount; /* Number of messages in the queue */
uint_t udp_reader_count; /* Number of reader threads */
uint_t udp_squeue_count; /* Number of messages in conn_sqp */
kmutex_t udp_drain_lock; /* lock for udp_rcv_list */
boolean_t udp_drain_qfull; /* drain queue is full */
mblk_t *udp_rcv_list_head; /* b_next chain of mblks */
mblk_t *udp_rcv_list_tail; /* last mblk in chain */
uint_t udp_rcv_cnt; /* total data in rcv_list */
uint_t udp_rcv_msgcnt; /* total messages in rcv_list */
size_t udp_rcv_hiwat; /* receive high watermark */
} udp_t;
/* UDP Protocol header */
/* UDP Protocol header aligned */
typedef struct udpahdr_s {
in_port_t uha_src_port; /* Source port */
in_port_t uha_dst_port; /* Destination port */
uint16_t uha_length; /* UDP length */
uint16_t uha_checksum; /* UDP checksum */
} udpha_t;
#define UDPH_SIZE 8
/* Named Dispatch Parameter Management Structure */
typedef struct udpparam_s {
uint32_t udp_param_min;
uint32_t udp_param_max;
uint32_t udp_param_value;
char *udp_param_name;
} udpparam_t;
extern udpparam_t udp_param_arr[];
#define udp_wroff_extra udp_param_arr[0].udp_param_value
#define udp_ipv4_ttl udp_param_arr[1].udp_param_value
#define udp_ipv6_hoplimit udp_param_arr[2].udp_param_value
#define udp_smallest_nonpriv_port udp_param_arr[3].udp_param_value
#define udp_do_checksum udp_param_arr[4].udp_param_value
#define udp_smallest_anon_port udp_param_arr[5].udp_param_value
#define udp_largest_anon_port udp_param_arr[6].udp_param_value
#define udp_xmit_hiwat udp_param_arr[7].udp_param_value
#define udp_xmit_lowat udp_param_arr[8].udp_param_value
#define udp_recv_hiwat udp_param_arr[9].udp_param_value
#define udp_max_buf udp_param_arr[10].udp_param_value
#define udp_ndd_get_info_interval udp_param_arr[11].udp_param_value
/* Kstats */
typedef struct { /* Class "net" kstats */
kstat_named_t udp_ip_send;
kstat_named_t udp_ip_ire_send;
kstat_named_t udp_ire_null;
kstat_named_t udp_drain;
kstat_named_t udp_sock_fallback;
kstat_named_t udp_rrw_busy;
kstat_named_t udp_rrw_msgcnt;
kstat_named_t udp_out_sw_cksum;
kstat_named_t udp_out_sw_cksum_bytes;
kstat_named_t udp_out_opt;
kstat_named_t udp_out_err_notconn;
kstat_named_t udp_out_err_output;
kstat_named_t udp_out_err_tudr;
kstat_named_t udp_in_pktinfo;
kstat_named_t udp_in_recvdstaddr;
kstat_named_t udp_in_recvopts;
kstat_named_t udp_in_recvif;
kstat_named_t udp_in_recvslla;
kstat_named_t udp_in_recvucred;
kstat_named_t udp_in_recvttl;
kstat_named_t udp_in_recvhopopts;
kstat_named_t udp_in_recvhoplimit;
kstat_named_t udp_in_recvdstopts;
kstat_named_t udp_in_recvrtdstopts;
kstat_named_t udp_in_recvrthdr;
kstat_named_t udp_in_recvpktinfo;
kstat_named_t udp_in_recvtclass;
#ifdef DEBUG
kstat_named_t udp_data_conn;
kstat_named_t udp_data_notconn;
#endif
} udp_stat_t;
extern udp_stat_t udp_statistics;
#define UDP_STAT(x) (udp_statistics.x.value.ui64++)
#define UDP_STAT_UPDATE(x, n) (udp_statistics.x.value.ui64 += (n))
#ifdef DEBUG
#define UDP_DBGSTAT(x) UDP_STAT(x)
#else
#define UDP_DBGSTAT(x)
#endif /* DEBUG */
extern major_t UDP6_MAJ;
extern int udp_opt_default(queue_t *, t_scalar_t, t_scalar_t, uchar_t *);
extern int udp_opt_get(queue_t *, t_scalar_t, t_scalar_t, uchar_t *);
extern int udp_opt_set(queue_t *, uint_t, int, int, uint_t, uchar_t *,
uint_t *, uchar_t *, void *, cred_t *, mblk_t *);
extern int udp_snmp_get(queue_t *, mblk_t *);
extern int udp_snmp_set(queue_t *, t_scalar_t, t_scalar_t, uchar_t *, int);
extern void udp_close_free(conn_t *);
extern void udp_quiesce_conn(conn_t *);
extern void udp_ddi_init(void);
extern void udp_ddi_destroy(void);
extern void udp_resume_bind(conn_t *, mblk_t *);
extern void udp_conn_recv(conn_t *, mblk_t *);
extern boolean_t udp_compute_checksum(void);
extern void udp_wput_data(queue_t *, mblk_t *, struct sockaddr *,
socklen_t);
#endif /* _KERNEL */
#ifdef __cplusplus
}
#endif
#endif /* _UDP_IMPL_H */
|
