diff options
Diffstat (limited to 'usr/src/uts/common/inet/tcp_impl.h')
| -rw-r--r-- | usr/src/uts/common/inet/tcp_impl.h | 332 |
1 files changed, 332 insertions, 0 deletions
diff --git a/usr/src/uts/common/inet/tcp_impl.h b/usr/src/uts/common/inet/tcp_impl.h new file mode 100644 index 0000000000..93c08cb144 --- /dev/null +++ b/usr/src/uts/common/inet/tcp_impl.h @@ -0,0 +1,332 @@ +/* + * 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 _INET_TCP_IMPL_H +#define _INET_TCP_IMPL_H + +#pragma ident "%Z%%M% %I% %E% SMI" + +/* + * TCP 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 <inet/tcp.h> + +#define TCP_MOD_ID 5105 + +/* + * Was this tcp created via socket() interface? + */ +#define TCP_IS_SOCKET(tcp) ((tcp)->tcp_issocket) + +/* + * Is this tcp not attached to any upper client? + */ +#define TCP_IS_DETACHED(tcp) ((tcp)->tcp_detached) + +#define TCP_TIMER(tcp, f, tim) \ + tcp_timeout(tcp->tcp_connp, f, tim) +#define TCP_TIMER_CANCEL(tcp, id) \ + tcp_timeout_cancel(tcp->tcp_connp, id) + +/* + * To restart the TCP retransmission timer. + */ +#define TCP_TIMER_RESTART(tcp, intvl) { \ + if ((tcp)->tcp_timer_tid != 0) \ + (void) TCP_TIMER_CANCEL((tcp), (tcp)->tcp_timer_tid); \ + (tcp)->tcp_timer_tid = TCP_TIMER((tcp), tcp_timer, \ + MSEC_TO_TICK(intvl)); \ +} + +/* + * This stops synchronous streams for a fused tcp endpoint + * and prevents tcp_rrw() from pulling data from it. + */ +#define TCP_FUSE_SYNCSTR_STOP(tcp) { \ + if ((tcp)->tcp_direct_sockfs) { \ + mutex_enter(&(tcp)->tcp_fuse_lock); \ + (tcp)->tcp_fuse_syncstr_stopped = B_TRUE; \ + mutex_exit(&(tcp)->tcp_fuse_lock); \ + } \ +} + +/* + * This resumes synchronous streams for this fused tcp endpoint + * and allows tcp_rrw() to pull data from it again. + */ +#define TCP_FUSE_SYNCSTR_RESUME(tcp) { \ + if ((tcp)->tcp_direct_sockfs) { \ + mutex_enter(&(tcp)->tcp_fuse_lock); \ + (tcp)->tcp_fuse_syncstr_stopped = B_FALSE; \ + mutex_exit(&(tcp)->tcp_fuse_lock); \ + } \ +} + +/* + * Write-side flow-control is implemented via the per instance STREAMS + * write-side Q by explicitly setting QFULL to stop the flow of mblk_t(s) + * and clearing QFULL and calling qbackenable() to restart the flow based + * on the number of TCP unsent bytes (i.e. those not on the wire waiting + * for a remote ACK). + * + * This is different than a standard STREAMS kmod which when using the + * STREAMS Q the framework would automatictly flow-control based on the + * defined hiwat/lowat values as mblk_t's are enqueued/dequeued. + * + * As of FireEngine TCP write-side flow-control needs to take into account + * both the unsent tcp_xmit list bytes but also any squeue_t enqueued bytes + * (i.e. from tcp_wput() -> tcp_output()). + * + * This is accomplished by adding a new tcp_t fields, tcp_squeue_bytes, to + * count the number of bytes enqueued by tcp_wput() and the number of bytes + * dequeued and processed by tcp_output(). + * + * So, the total number of bytes unsent is (squeue_bytes + unsent) with all + * flow-control uses of unsent replaced with the macro TCP_UNSENT_BYTES. + */ +extern void tcp_clrqfull(tcp_t *); +extern void tcp_setqfull(tcp_t *); + +#define TCP_UNSENT_BYTES(tcp) \ + ((tcp)->tcp_squeue_bytes + (tcp)->tcp_unsent) + +/* Named Dispatch Parameter Management Structure */ +typedef struct tcpparam_s { + uint32_t tcp_param_min; + uint32_t tcp_param_max; + uint32_t tcp_param_val; + char *tcp_param_name; +} tcpparam_t; + +extern tcpparam_t tcp_param_arr[]; + +#define tcp_time_wait_interval tcp_param_arr[0].tcp_param_val +#define tcp_conn_req_max_q tcp_param_arr[1].tcp_param_val +#define tcp_conn_req_max_q0 tcp_param_arr[2].tcp_param_val +#define tcp_conn_req_min tcp_param_arr[3].tcp_param_val +#define tcp_conn_grace_period tcp_param_arr[4].tcp_param_val +#define tcp_cwnd_max_ tcp_param_arr[5].tcp_param_val +#define tcp_dbg tcp_param_arr[6].tcp_param_val +#define tcp_smallest_nonpriv_port tcp_param_arr[7].tcp_param_val +#define tcp_ip_abort_cinterval tcp_param_arr[8].tcp_param_val +#define tcp_ip_abort_linterval tcp_param_arr[9].tcp_param_val +#define tcp_ip_abort_interval tcp_param_arr[10].tcp_param_val +#define tcp_ip_notify_cinterval tcp_param_arr[11].tcp_param_val +#define tcp_ip_notify_interval tcp_param_arr[12].tcp_param_val +#define tcp_ipv4_ttl tcp_param_arr[13].tcp_param_val +#define tcp_keepalive_interval_high tcp_param_arr[14].tcp_param_max +#define tcp_keepalive_interval tcp_param_arr[14].tcp_param_val +#define tcp_keepalive_interval_low tcp_param_arr[14].tcp_param_min +#define tcp_maxpsz_multiplier tcp_param_arr[15].tcp_param_val +#define tcp_mss_def_ipv4 tcp_param_arr[16].tcp_param_val +#define tcp_mss_max_ipv4 tcp_param_arr[17].tcp_param_val +#define tcp_mss_min tcp_param_arr[18].tcp_param_val +#define tcp_naglim_def tcp_param_arr[19].tcp_param_val +#define tcp_rexmit_interval_initial tcp_param_arr[20].tcp_param_val +#define tcp_rexmit_interval_max tcp_param_arr[21].tcp_param_val +#define tcp_rexmit_interval_min tcp_param_arr[22].tcp_param_val +#define tcp_deferred_ack_interval tcp_param_arr[23].tcp_param_val +#define tcp_snd_lowat_fraction tcp_param_arr[24].tcp_param_val +#define tcp_sth_rcv_hiwat tcp_param_arr[25].tcp_param_val +#define tcp_sth_rcv_lowat tcp_param_arr[26].tcp_param_val +#define tcp_dupack_fast_retransmit tcp_param_arr[27].tcp_param_val +#define tcp_ignore_path_mtu tcp_param_arr[28].tcp_param_val +#define tcp_smallest_anon_port tcp_param_arr[29].tcp_param_val +#define tcp_largest_anon_port tcp_param_arr[30].tcp_param_val +#define tcp_xmit_hiwat tcp_param_arr[31].tcp_param_val +#define tcp_xmit_lowat tcp_param_arr[32].tcp_param_val +#define tcp_recv_hiwat tcp_param_arr[33].tcp_param_val +#define tcp_recv_hiwat_minmss tcp_param_arr[34].tcp_param_val +#define tcp_fin_wait_2_flush_interval tcp_param_arr[35].tcp_param_val +#define tcp_co_min tcp_param_arr[36].tcp_param_val +#define tcp_max_buf tcp_param_arr[37].tcp_param_val +#define tcp_strong_iss tcp_param_arr[38].tcp_param_val +#define tcp_rtt_updates tcp_param_arr[39].tcp_param_val +#define tcp_wscale_always tcp_param_arr[40].tcp_param_val +#define tcp_tstamp_always tcp_param_arr[41].tcp_param_val +#define tcp_tstamp_if_wscale tcp_param_arr[42].tcp_param_val +#define tcp_rexmit_interval_extra tcp_param_arr[43].tcp_param_val +#define tcp_deferred_acks_max tcp_param_arr[44].tcp_param_val +#define tcp_slow_start_after_idle tcp_param_arr[45].tcp_param_val +#define tcp_slow_start_initial tcp_param_arr[46].tcp_param_val +#define tcp_co_timer_interval tcp_param_arr[47].tcp_param_val +#define tcp_sack_permitted tcp_param_arr[48].tcp_param_val +#define tcp_trace tcp_param_arr[49].tcp_param_val +#define tcp_compression_enabled tcp_param_arr[50].tcp_param_val +#define tcp_ipv6_hoplimit tcp_param_arr[51].tcp_param_val +#define tcp_mss_def_ipv6 tcp_param_arr[52].tcp_param_val +#define tcp_mss_max_ipv6 tcp_param_arr[53].tcp_param_val +#define tcp_rev_src_routes tcp_param_arr[54].tcp_param_val +#define tcp_local_dack_interval tcp_param_arr[55].tcp_param_val +#define tcp_ndd_get_info_interval tcp_param_arr[56].tcp_param_val +#define tcp_local_dacks_max tcp_param_arr[57].tcp_param_val +#define tcp_ecn_permitted tcp_param_arr[58].tcp_param_val +#define tcp_rst_sent_rate_enabled tcp_param_arr[59].tcp_param_val +#define tcp_rst_sent_rate tcp_param_arr[60].tcp_param_val +#define tcp_push_timer_interval tcp_param_arr[61].tcp_param_val +#define tcp_use_smss_as_mss_opt tcp_param_arr[62].tcp_param_val +#define tcp_keepalive_abort_interval_high tcp_param_arr[63].tcp_param_max +#define tcp_keepalive_abort_interval tcp_param_arr[63].tcp_param_val +#define tcp_keepalive_abort_interval_low tcp_param_arr[63].tcp_param_min + +/* Kstats */ +typedef struct tcp_stat { + kstat_named_t tcp_time_wait; + kstat_named_t tcp_time_wait_syn; + kstat_named_t tcp_time_wait_syn_success; + kstat_named_t tcp_time_wait_syn_fail; + kstat_named_t tcp_reinput_syn; + kstat_named_t tcp_ip_output; + kstat_named_t tcp_detach_non_time_wait; + kstat_named_t tcp_detach_time_wait; + kstat_named_t tcp_time_wait_reap; + kstat_named_t tcp_clean_death_nondetached; + kstat_named_t tcp_reinit_calls; + kstat_named_t tcp_eager_err1; + kstat_named_t tcp_eager_err2; + kstat_named_t tcp_eager_blowoff_calls; + kstat_named_t tcp_eager_blowoff_q; + kstat_named_t tcp_eager_blowoff_q0; + kstat_named_t tcp_not_hard_bound; + kstat_named_t tcp_no_listener; + kstat_named_t tcp_found_eager; + kstat_named_t tcp_wrong_queue; + kstat_named_t tcp_found_eager_binding1; + kstat_named_t tcp_found_eager_bound1; + kstat_named_t tcp_eager_has_listener1; + kstat_named_t tcp_open_alloc; + kstat_named_t tcp_open_detached_alloc; + kstat_named_t tcp_rput_time_wait; + kstat_named_t tcp_listendrop; + kstat_named_t tcp_listendropq0; + kstat_named_t tcp_wrong_rq; + kstat_named_t tcp_rsrv_calls; + kstat_named_t tcp_eagerfree2; + kstat_named_t tcp_eagerfree3; + kstat_named_t tcp_eagerfree4; + kstat_named_t tcp_eagerfree5; + kstat_named_t tcp_timewait_syn_fail; + kstat_named_t tcp_listen_badflags; + kstat_named_t tcp_timeout_calls; + kstat_named_t tcp_timeout_cached_alloc; + kstat_named_t tcp_timeout_cancel_reqs; + kstat_named_t tcp_timeout_canceled; + kstat_named_t tcp_timermp_alloced; + kstat_named_t tcp_timermp_freed; + kstat_named_t tcp_timermp_allocfail; + kstat_named_t tcp_timermp_allocdblfail; + kstat_named_t tcp_push_timer_cnt; + kstat_named_t tcp_ack_timer_cnt; + kstat_named_t tcp_ire_null1; + kstat_named_t tcp_ire_null; + kstat_named_t tcp_ip_send; + kstat_named_t tcp_ip_ire_send; + kstat_named_t tcp_wsrv_called; + kstat_named_t tcp_flwctl_on; + kstat_named_t tcp_timer_fire_early; + kstat_named_t tcp_timer_fire_miss; + kstat_named_t tcp_freelist_cleanup; + kstat_named_t tcp_rput_v6_error; + kstat_named_t tcp_out_sw_cksum; + kstat_named_t tcp_out_sw_cksum_bytes; + kstat_named_t tcp_zcopy_on; + kstat_named_t tcp_zcopy_off; + kstat_named_t tcp_zcopy_backoff; + kstat_named_t tcp_zcopy_disable; + kstat_named_t tcp_mdt_pkt_out; + kstat_named_t tcp_mdt_pkt_out_v4; + kstat_named_t tcp_mdt_pkt_out_v6; + kstat_named_t tcp_mdt_discarded; + kstat_named_t tcp_mdt_conn_halted1; + kstat_named_t tcp_mdt_conn_halted2; + kstat_named_t tcp_mdt_conn_halted3; + kstat_named_t tcp_mdt_conn_resumed1; + kstat_named_t tcp_mdt_conn_resumed2; + kstat_named_t tcp_mdt_legacy_small; + kstat_named_t tcp_mdt_legacy_all; + kstat_named_t tcp_mdt_legacy_ret; + kstat_named_t tcp_mdt_allocfail; + kstat_named_t tcp_mdt_addpdescfail; + kstat_named_t tcp_mdt_allocd; + kstat_named_t tcp_mdt_linked; + kstat_named_t tcp_fusion_flowctl; + kstat_named_t tcp_fusion_backenabled; + kstat_named_t tcp_fusion_urg; + kstat_named_t tcp_fusion_putnext; + kstat_named_t tcp_fusion_unfusable; + kstat_named_t tcp_fusion_aborted; + kstat_named_t tcp_fusion_unqualified; + kstat_named_t tcp_fusion_rrw_busy; + kstat_named_t tcp_fusion_rrw_msgcnt; + kstat_named_t tcp_in_ack_unsent_drop; + kstat_named_t tcp_sock_fallback; +} tcp_stat_t; + +extern tcp_stat_t tcp_statistics; + +#define TCP_STAT(x) (tcp_statistics.x.value.ui64++) +#define TCP_STAT_UPDATE(x, n) (tcp_statistics.x.value.ui64 += (n)) +#define TCP_STAT_SET(x, n) (tcp_statistics.x.value.ui64 = (n)) + +extern struct qinit tcp_loopback_rinit, tcp_rinit; +extern boolean_t do_tcp_fusion; + +extern int tcp_maxpsz_set(tcp_t *, boolean_t); +extern void tcp_timers_stop(tcp_t *); +extern void tcp_rcv_enqueue(tcp_t *, mblk_t *, uint_t); +extern void tcp_push_timer(void *); +extern timeout_id_t tcp_timeout(conn_t *, void (*)(void *), clock_t); +extern clock_t tcp_timeout_cancel(conn_t *, timeout_id_t); + +extern void tcp_fuse(tcp_t *, uchar_t *, tcph_t *); +extern void tcp_unfuse(tcp_t *); +extern boolean_t tcp_fuse_output(tcp_t *, mblk_t *, uint32_t); +extern void tcp_fuse_output_urg(tcp_t *, mblk_t *); +extern boolean_t tcp_fuse_rcv_drain(queue_t *, tcp_t *, mblk_t **); +extern void tcp_fuse_syncstr_enable_pair(tcp_t *); +extern void tcp_fuse_disable_pair(tcp_t *, boolean_t); +extern int tcp_fuse_rrw(queue_t *, struiod_t *); +extern int tcp_fuse_rinfop(queue_t *, infod_t *); +extern size_t tcp_fuse_set_rcv_hiwat(tcp_t *, size_t); +extern int tcp_fuse_maxpsz_set(tcp_t *); + +#endif /* _KERNEL */ + +#ifdef __cplusplus +} +#endif + +#endif /* _INET_TCP_IMPL_H */ |