xref: /titanic_41/usr/src/uts/common/fs/sockfs/nl7cnca.c (revision 2e1a94749a6ae1ee25de9f4492d4b90a3b408c4c)
1 /*
2  * CDDL HEADER START
3  *
4  * The contents of this file are subject to the terms of the
5  * Common Development and Distribution License (the "License").
6  * You may not use this file except in compliance with the License.
7  *
8  * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
9  * or http://www.opensolaris.org/os/licensing.
10  * See the License for the specific language governing permissions
11  * and limitations under the License.
12  *
13  * When distributing Covered Code, include this CDDL HEADER in each
14  * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
15  * If applicable, add the following below this CDDL HEADER, with the
16  * fields enclosed by brackets "[]" replaced with your own identifying
17  * information: Portions Copyright [yyyy] [name of copyright owner]
18  *
19  * CDDL HEADER END
20  */
21 /*
22  * Copyright 2008 Sun Microsystems, Inc.  All rights reserved.
23  * Use is subject to license terms.
24  */
25 
26 #include <sys/types.h>
27 #include <sys/conf.h>
28 #include <sys/modctl.h>
29 #include <sys/stream.h>
30 #include <sys/strsubr.h>
31 #include <sys/stropts.h>
32 #define	_SUN_TPI_VERSION 2
33 #include <sys/ddi.h>
34 #include <sys/sunddi.h>
35 #include <sys/cmn_err.h>
36 #include <sys/debug.h>
37 #include <sys/vtrace.h>
38 #include <sys/errno.h>
39 #include <inet/common.h>
40 #include <inet/led.h>
41 #include <inet/mi.h>
42 #include <inet/nd.h>
43 #include <sys/strsun.h>
44 
45 #include <fs/sockfs/nl7c.h>
46 #include <fs/sockfs/nl7curi.h>
47 
48 #include <inet/nca/nca.h>
49 #include <inet/nca/ncalogd.h>
50 
51 /*
52  * This file is for NCA compatability, specifically it provides ndd
53  * support for existing NCA ndd ...
54  */
55 
56 extern boolean_t	nl7c_logd_enabled;
57 extern nca_fio_t	*nl7c_logd_fio;
58 extern clock_t		nl7c_uri_ttl;
59 extern boolean_t	nl7c_use_kmem;
60 extern uint64_t		nl7c_file_prefetch;
61 extern uint64_t		nl7c_uri_max;
62 extern uint64_t		nl7c_uri_bytes;
63 
64 extern void		nl7c_mi_report_addr(mblk_t *);
65 
66 #define	MS	1L
67 #define	SECONDS	(1000 * MS)
68 #define	MINUTES	(60 * SECONDS)
69 #define	HOURS	(60 * MINUTES)
70 #define	DAYS	(24 * HOURS)
71 
72 #define	PARAM_MAX UINT_MAX
73 #define	PARAML_MAX ULONG_MAX
74 
75 #include <inet/nca/ncandd.h>
76 
77 uint32_t nca_major_version = 1;
78 uint32_t nca_minor_version = 3;
79 uint32_t nca_httpd_version = NCA_HTTP_VERSION1;
80 uint32_t nca_logd_version = NCA_LOG_VERSION1;
81 
82 caddr_t	nca_g_nd;	/* Head of 'named dispatch' variable list */
83 
84 /*
85  * min, max, and value are int64_t's, addr is the optional address of an
86  * external int64_t to be updated at init/set, name is the ndd name used
87  * to access. Note, if min == max then only get is allowed, i.e. RO.
88  */
89 
90 /* BEGIN CSTYLED */
91 ncaparam_t	nca_param_arr[] = {
92  /*min	max		value		name */
93  { 0,	1,		1,		"nca_log_cycle"},
94  { 0,	1,		0,		"no_caching"},
95  { 0,	PARAML_MAX,    	0,		"nca_log_size"},
96  { 0,	PARAM_MAX,     	10000000,	"nca_max_cache_size"},
97  { 0,	PARAM_MAX,	300*SECONDS,	"nca_http_timeout"},
98  { 0,	PARAM_MAX,	15*SECONDS,	"nca_http_keep_alive_timeout"},
99  { 0,	PARAM_MAX,	100,		"nca_http_keep_alive_max"},
100  { 0,	1,		1,		"nca_inq_nointr"},
101  { 0,	1,		1,		"nca_use_hwcksum"},
102  { 0,	PARAM_MAX,	0,		"nca_segmap_min_size"},
103 };
104 
105 /*
106  * Obsolete ip variables, use "/dev/ip" instead.
107  */
108 
109 ncaparam_t	nca_ip_obsolete_arr[] = {
110  { 0, 0, 0, "ip_forwarding"},
111  { 0, 0, 0, "ip_respond_to_address_mask_broadcast"},
112  { 0, 0, 0, "ip_respond_to_echo_broadcast"},
113  { 0, 0, 0, "ip_respond_to_timestamp"},
114  { 0, 0, 0, "ip_respond_to_timestamp_broadcast"},
115  { 0, 0, 0, "ip_send_redirects"},
116  { 0, 0, 0, "ip_forward_directed_broadcasts"},
117  { 0, 0, 0, "ip_debug"},
118  { 0, 0, 0, "ip_mrtdebug"},
119  { 0, 0, 0, "ip_ire_cleanup_interval" },
120  { 0, 0, 0, "ip_ire_flush_interval" },
121  { 0, 0, 0, "ip_ire_redirect_interval" },
122  { 0, 0, 0, "ip_def_ttl" },
123  { 0, 0, 0, "ip_forward_src_routed"},
124  { 0, 0, 0, "ip_wroff_extra" },
125  { 0, 0, 0, "ip_ire_pathmtu_interval" },
126  { 0, 0, 0, "ip_icmp_return_data_bytes" },
127  { 0, 0, 0, "ip_send_source_quench" },
128  { 0, 0, 0, "ip_path_mtu_discovery" },
129  { 0, 0, 0, "ip_ignore_delete_time" },
130  { 0, 0, 0, "ip_ignore_redirect" },
131  { 0, 0, 0, "ip_output_queue" },
132  { 0, 0, 0, "ip_broadcast_ttl" },
133  { 0, 0, 0, "ip_icmp_err_interval" },
134  { 0, 0, 0, "ip_reass_queue_bytes" },
135  { 0, 0, 0, "ip_strict_dst_multihoming" },
136  { 0, 0, 0, "ip_addrs_per_if"},
137 };
138 
139 /*
140  * Obsolete tcp variables, use "/dev/tcp" instead.
141  */
142 
143 ncaparam_t	nca_tcp_obsolete_arr[] = {
144  { 0, 0, 0, "tcp_time_wait_interval"},
145  { 0, 0, 0, "tcp_conn_req_max_q" },
146  { 0, 0, 0, "tcp_conn_req_max_q0" },
147  { 0, 0, 0, "tcp_conn_req_min" },
148  { 0, 0, 0, "tcp_conn_grace_period" },
149  { 0, 0, 0, "tcp_cwnd_max" },
150  { 0, 0, 0, "tcp_debug" },
151  { 0, 0, 0, "tcp_smallest_nonpriv_port"},
152  { 0, 0, 0, "tcp_ip_abort_cinterval"},
153  { 0, 0, 0, "tcp_ip_abort_linterval"},
154  { 0, 0, 0, "tcp_ip_abort_interval"},
155  { 0, 0, 0, "tcp_ip_notify_cinterval"},
156  { 0, 0, 0, "tcp_ip_notify_interval"},
157  { 0, 0, 0, "tcp_ip_ttl"},
158  { 0, 0, 0, "tcp_keepalive_interval"},
159  { 0, 0, 0, "tcp_maxpsz_multiplier" },
160  { 0, 0, 0, "tcp_mss_def"},
161  { 0, 0, 0, "tcp_mss_max"},
162  { 0, 0, 0, "tcp_mss_min"},
163  { 0, 0, 0, "tcp_naglim_def"},
164  { 0, 0, 0, "tcp_rexmit_interval_initial"},
165  { 0, 0, 0, "tcp_rexmit_interval_max"},
166  { 0, 0, 0, "tcp_rexmit_interval_min"},
167  { 0, 0, 0, "tcp_wroff_xtra" },
168  { 0, 0, 0, "tcp_deferred_ack_interval" },
169  { 0, 0, 0, "tcp_snd_lowat_fraction" },
170  { 0, 0, 0, "tcp_sth_rcv_hiwat" },
171  { 0, 0, 0, "tcp_sth_rcv_lowat" },
172  { 0, 0, 0, "tcp_dupack_fast_retransmit" },
173  { 0, 0, 0, "tcp_ignore_path_mtu" },
174  { 0, 0, 0, "tcp_rcv_push_wait" },
175  { 0, 0, 0, "tcp_smallest_anon_port"},
176  { 0, 0, 0, "tcp_largest_anon_port"},
177  { 0, 0, 0, "tcp_xmit_hiwat"},
178  { 0, 0, 0, "tcp_xmit_lowat"},
179  { 0, 0, 0, "tcp_recv_hiwat"},
180  { 0, 0, 0, "tcp_recv_hiwat_minmss"},
181  { 0, 0, 0, "tcp_fin_wait_2_flush_interval"},
182  { 0, 0, 0, "tcp_max_buf"},
183  { 0, 0, 0, "tcp_strong_iss"},
184  { 0, 0, 0, "tcp_rtt_updates"},
185  { 0, 0, 0, "tcp_wscale_always"},
186  { 0, 0, 0, "tcp_tstamp_always"},
187  { 0, 0, 0, "tcp_tstamp_if_wscale"},
188  { 0, 0, 0, "tcp_rexmit_interval_extra"},
189  { 0, 0, 0, "tcp_deferred_acks_max"},
190  { 0, 0, 0, "tcp_slow_start_after_idle"},
191  { 0, 0, 0, "tcp_slow_start_initial"},
192  { 0, 0, 0, "tcp_sack_permitted"},
193 #ifdef DEBUG
194  { 0, 0, 0, "tcp_drop_oob"},
195 #endif
196 };
197 
198 /*
199  * Obsolete nca variables, just warn.
200  */
201 
202 ncaparam_t	nca_nca_obsolete_arr[] = {
203  { 0, 0, 0, "nca_ipport_table_bucket"},
204  { 0, 0, 0, "nca_ipport_table_size"},
205  { 0, 0, 0, "nca_ipport_table_expand"},
206  { 0, 0, 0, "nca_ipport_table_shrink"},
207  { 0, 0, 0, "nca_ip_virtual_hosting"},
208  { 0, 0, 0, "httpd_door_address"},
209  { 0, 0, 0, "httpd_door_path"},
210  { 0, 0, 0, "httpd_downdoor_path"},
211  { 0, 0, 0, "nca_ppmax"},
212  { 0, 0, 0, "nca_vpmax"},
213  { 0, 0, 0, "nca_use_segmap"},
214  { 0, 0, 0, "nca_availrmem"},
215  { 0, 0, 0, "nca_maxkmem"},
216  { 0, 0, 0, "nca_log_file"},
217  { 0, 0, 0, "conn_status"},
218  { 0, 0, 0, "conn_status_all"},
219  { 0, 0, 0, "nca_conn_req_max_q"},
220  { 0, 0, 0, "nca_conn_req_max_q0"},
221  { 0, 0, 0, "cache_clear"},
222  { 0, 0, 0, "nca_node_hash"},
223  { 0, 0, 0, "node_status"},
224 #ifdef DEBUG
225  { 0, 0, 0, "nca_debug_counter"},
226 #endif
227 };
228 /* END CSTYLED */
229 
230 static int
231 /*ARGSUSED*/
232 nl7c_uri_ttl_get(queue_t *q, mblk_t *mp, caddr_t cp, cred_t *cr)
233 {
234 	(void) mi_mpprintf(mp, "%ld", nl7c_uri_ttl);
235 	return (0);
236 }
237 
238 static int
239 /*ARGSUSED*/
240 nl7c_uri_ttl_set(queue_t *q, mblk_t *mp, char *value, caddr_t nu, cred_t *cr)
241 {
242 	if (ddi_strtol(value, NULL, 10, &nl7c_uri_ttl) != 0)
243 		return (EINVAL);
244 	return (0);
245 }
246 
247 static int
248 /*ARGSUSED*/
249 nca_logging_on_get(queue_t *q, mblk_t *mp, caddr_t cp, cred_t *cr)
250 {
251 	(void) mi_mpprintf(mp, "%d", nl7c_logd_enabled);
252 	return (0);
253 }
254 
255 static int
256 /*ARGSUSED*/
257 nca_logging_on_set(queue_t *q, mblk_t *mp, char *value, caddr_t nu, cred_t *cr)
258 {
259 	long new_value;
260 
261 	if (ddi_strtol(value, NULL, 10, &new_value) != 0 || new_value < 0 ||
262 	    new_value > 1) {
263 		return (EINVAL);
264 	}
265 	if (nca_fio_cnt(nl7c_logd_fio) == 0)
266 		return (EINVAL);
267 	nl7c_logd_enabled = new_value;
268 
269 	return (0);
270 }
271 
272 static int
273 /*ARGSUSED*/
274 nca_version_get(queue_t *q, mblk_t *mp, caddr_t cp, cred_t *cr)
275 {
276 	(void) mi_mpprintf(mp, "%d.%d", nca_major_version, nca_minor_version);
277 	return (0);
278 }
279 
280 static int
281 /*ARGSUSED*/
282 nca_httpd_version_get(queue_t *q, mblk_t *mp, caddr_t cp, cred_t *cr)
283 {
284 	(void) mi_mpprintf(mp, "%d", nca_httpd_version);
285 	return (0);
286 }
287 
288 static int
289 /*ARGSUSED*/
290 nca_logd_version_get(queue_t *q, mblk_t *mp, caddr_t cp, cred_t *cr)
291 {
292 	(void) mi_mpprintf(mp, "%d", nca_logd_version);
293 	return (0);
294 }
295 
296 static int
297 /*ARGSUSED*/
298 nca_httpd_door_inst_get(queue_t *q, mblk_t *mp, caddr_t nu, cred_t *cr)
299 {
300 	nl7c_mi_report_addr(mp);
301 	return (0);
302 }
303 
304 static int
305 /*ARGSUSED*/
306 nca_param_get(queue_t *q, mblk_t *mp, caddr_t cp, cred_t *cr)
307 {
308 	ncaparam_t	*ncapa = (ncaparam_t *)cp;
309 
310 	(void) mi_mpprintf(mp, "%ld", ncapa->param_val);
311 	return (0);
312 }
313 
314 static int
315 /*ARGSUSED*/
316 nca_param_set(queue_t *q, mblk_t *mp, char *value, caddr_t cp, cred_t *cr)
317 {
318 	ulong_t		new_value;
319 	ncaparam_t	*ncapa = (ncaparam_t *)cp;
320 
321 	if (ddi_strtoul(value, NULL, 10, &new_value) != 0 ||
322 	    new_value < ncapa->param_min || new_value > ncapa->param_max) {
323 		return (EINVAL);
324 	}
325 	ncapa->param_val = new_value;
326 	return (0);
327 }
328 
329 static int
330 /*ARGSUSED*/
331 nca_obsolete(queue_t *q, mblk_t *mp, caddr_t cp, cred_t *cr)
332 {
333 	(void) mi_mpprintf(mp, "obsolete");
334 	return (0);
335 }
336 
337 static int
338 /*ARGSUSED*/
339 nca_ip_obsolete(queue_t *q, mblk_t *mp, caddr_t cp, cred_t *cr)
340 {
341 	(void) mi_mpprintf(mp, "obsolete for /dev/nca, use /dev/ip");
342 	return (0);
343 }
344 
345 static int
346 /*ARGSUSED*/
347 nca_tcp_obsolete(queue_t *q, mblk_t *mp, caddr_t cp, cred_t *cr)
348 {
349 	(void) mi_mpprintf(mp, "obsolete for /dev/nca, use /dev/tcp");
350 	return (0);
351 }
352 
353 static int
354 /*ARGSUSED*/
355 nca_nca_obsolete(queue_t *q, mblk_t *mp, caddr_t cp, cred_t *cr)
356 {
357 	(void) mi_mpprintf(mp, "obsolete for /dev/nca");
358 	return (0);
359 }
360 
361 static boolean_t
362 nca_param_register(ncaparam_t *ncapa, int cnt)
363 {
364 	for (; cnt-- > 0; ncapa++) {
365 		if (ncapa->param_name && ncapa->param_name[0]) {
366 			if (!nd_load(&nca_g_nd, ncapa->param_name,
367 			    nca_param_get, nca_param_set,
368 			    (caddr_t)ncapa)) {
369 				goto error;
370 			}
371 		}
372 
373 	}
374 	if (!nd_load(&nca_g_nd, "nca_version", nca_version_get, nil(pfi_t),
375 	    nil(caddr_t))) {
376 		goto error;
377 	}
378 	if (!nd_load(&nca_g_nd, "nca_logd_version", nca_logd_version_get,
379 	    nil(pfi_t), nil(caddr_t))) {
380 		goto error;
381 	}
382 	if (!nd_load(&nca_g_nd, "nca_logging_on", nca_logging_on_get,
383 	    nca_logging_on_set, nil(caddr_t))) {
384 		goto error;
385 	}
386 
387 	if (!nd_load(&nca_g_nd, "uri_time_to_live", nl7c_uri_ttl_get,
388 	    nl7c_uri_ttl_set, nil(caddr_t))) {
389 		goto error;
390 	}
391 	if (!nd_load(&nca_g_nd, "nca_httpd_version", nca_httpd_version_get,
392 	    nil(pfi_t), nil(caddr_t))) {
393 		goto error;
394 	}
395 	if (!nd_load(&nca_g_nd, "httpd_door_instance", nca_httpd_door_inst_get,
396 	    nil(pfi_t), nil(caddr_t))) {
397 		nd_free(&nca_g_nd);
398 		return (B_FALSE);
399 	}
400 
401 	ncapa = nca_ip_obsolete_arr;
402 	cnt = A_CNT(nca_ip_obsolete_arr);
403 	for (; cnt-- > 0; ncapa++) {
404 		if (ncapa->param_name && ncapa->param_name[0]) {
405 			if (!nd_load(&nca_g_nd, ncapa->param_name,
406 			    nca_ip_obsolete, NULL, (caddr_t)ncapa)) {
407 				goto error;
408 			}
409 		}
410 
411 	}
412 
413 	ncapa = nca_tcp_obsolete_arr;
414 	cnt = A_CNT(nca_tcp_obsolete_arr);
415 	for (; cnt-- > 0; ncapa++) {
416 		if (ncapa->param_name && ncapa->param_name[0]) {
417 			if (!nd_load(&nca_g_nd, ncapa->param_name,
418 			    nca_tcp_obsolete, NULL, (caddr_t)ncapa)) {
419 				goto error;
420 			}
421 		}
422 
423 	}
424 
425 	ncapa = nca_nca_obsolete_arr;
426 	cnt = A_CNT(nca_nca_obsolete_arr);
427 	for (; cnt-- > 0; ncapa++) {
428 		if (ncapa->param_name && ncapa->param_name[0]) {
429 			if (!nd_load(&nca_g_nd, ncapa->param_name,
430 			    nca_nca_obsolete, NULL, (caddr_t)ncapa)) {
431 				goto error;
432 			}
433 		}
434 
435 	}
436 
437 	return (B_TRUE);
438 
439 error:
440 	nd_free(&nca_g_nd);
441 	return (B_FALSE);
442 }
443 
444 void
445 nl7c_nca_init(void)
446 {
447 	if (! nca_g_nd) {
448 		if (! nca_param_register(nca_param_arr, A_CNT(nca_param_arr)))
449 			cmn_err(CE_WARN,
450 			    "nl7c: /dev/nca ndd initialization failed.");
451 	}
452 }
453