+/***********************************************************
+ Copyright IBM Corporation 1987
+
+ All Rights Reserved
+
+Permission to use, copy, modify, and distribute this software and its
+documentation for any purpose and without fee is hereby granted,
+provided that the above copyright notice appear in all copies and that
+both that copyright notice and this permission notice appear in
+supporting documentation, and that the name of IBM not be
+used in advertising or publicity pertaining to distribution of the
+software without specific, written prior permission.
+
+IBM DISCLAIMS ALL WARRANTIES WITH REGARD TO THIS SOFTWARE, INCLUDING
+ALL IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS, IN NO EVENT SHALL
+IBM BE LIABLE FOR ANY SPECIAL, INDIRECT OR CONSEQUENTIAL DAMAGES OR
+ANY DAMAGES WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS,
+WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION,
+ARISING OUT OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS
+SOFTWARE.
+
+******************************************************************/
+
+/*
+ * ARGO Project, Computer Sciences Dept., University of Wisconsin - Madison
+ */
+/*
+ * ARGO TP
+ *
+ * $Header: tp_pcb.h,v 5.2 88/11/18 17:09:32 nhall Exp $
+ * $Source: /usr/argo/sys/netiso/RCS/tp_pcb.h,v $
+ *
+ *
+ * This file defines the transport protocol control block (tpcb).
+ * and a bunch of #define values that are used in the tpcb.
+ */
+
+#ifndef __TP_PCB__
+#define __TP_PCB__
+
+#include "../netiso/tp_param.h"
+#include "../netiso/tp_timer.h"
+#include "../netiso/tp_user.h"
+#ifndef sblock
+#include "../h/socketvar.h"
+#endif sblock
+
+/* NOTE: the code depends on REF_CLOSED > REF_OPEN > the rest, and
+ * on REF_FREE being zero
+ *
+ * Possible improvement:
+ * think about merging the tp_ref w/ the tpcb and doing a search
+ * through the tpcb list, from tpb. This would slow down lookup
+ * during data transfer
+ * It would be a little nicer also to have something based on the
+ * clock (like top n bits of the reference is part of the clock, to
+ * minimize the likelihood of reuse after a crash)
+ * also, need to keep the timer servicing part to a minimum (although
+ * the cost of this is probably independent of whether the timers are
+ * in the pcb or in an array..
+ * Last, would have to make the number of timers a function of the amount of
+ * mbufs available, plus some for the frozen references.
+ *
+ * Possible improvement:
+ * Might not need the ref_state stuff either...
+ * REF_FREE could correspond to tp_state == CLOSED or nonexistend tpcb,
+ * REF_OPEN to tp_state anywhere from AK_WAIT or CR_SENT to CLOSING
+ * REF_OPENING could correspond to LISTENING, because that's the
+ * way it's used, not because the correspondence is exact.
+ * REF_CLOSED could correspond to REFWAIT
+ */
+#define REF_FROZEN 3 /* has ref timer only */
+#define REF_OPEN 2 /* has timers, possibly active */
+#define REF_OPENING 1 /* in use (has a pcb) but no timers */
+#define REF_FREE 0 /* free to reallocate */
+
+#define N_CTIMERS 4
+#define N_ETIMERS 2
+
+struct tp_ref {
+ u_char tpr_state; /* values REF_FROZEN, etc. above */
+ struct Ccallout tpr_callout[N_CTIMERS]; /* C timers */
+ struct Ecallout tpr_calltodo; /* list of active E timers */
+ struct tp_pcb *tpr_pcb; /* back ptr to PCB */
+};
+
+struct tp_param {
+ /* PER system stuff (one static structure instead of a bunch of names) */
+ unsigned tpp_configed:1; /* Has TP been initialized? */
+};
+
+
+/*
+ * retransmission control and performance measurement
+ */
+struct tp_rtc {
+ struct tp_rtc *tprt_next; /* ptr to next rtc structure in the list */
+ SeqNum tprt_seq; /* seq # of this TPDU */
+ int tprt_eot; /* Will this TPDU have the eot bit set? */
+ int tprt_octets;/* # octets in this TPDU */
+ struct mbuf *tprt_data; /* ptr to the octets of data */
+};
+
+extern
+struct nl_protosw {
+ int nlp_afamily; /* address family */
+ int (*nlp_putnetaddr)(); /* puts addresses in nl pcb */
+ int (*nlp_getnetaddr)(); /* gets addresses from nl pcb */
+ int (*nlp_putsufx)(); /* puts transport suffixes in nl pcb */
+ int (*nlp_getsufx)(); /* gets transport suffixes from nl pcb */
+ int (*nlp_recycle_suffix)();/* clears suffix from nl pcb */
+ int (*nlp_mtu)(); /* figures out mtu based on nl used */
+ int (*nlp_pcbbind)(); /* bind to pcb for net level */
+ int (*nlp_pcbconn)(); /* connect for net level */
+ int (*nlp_pcbdisc)(); /* disconnect net level */
+ int (*nlp_pcbdetach)(); /* detach net level pcb */
+ int (*nlp_pcballoc)(); /* allocate a net level pcb */
+ int (*nlp_output)(); /* prepare a packet to give to nl */
+ int (*nlp_dgoutput)(); /* prepare a packet to give to nl */
+ int (*nlp_ctloutput)(); /* hook for network set/get options */
+ caddr_t nlp_pcblist; /* list of xx_pcb's for connections */
+} nl_protosw[];
+
+struct tp_pcb_aux {
+ /* addressing */
+ u_short tpa_domain; /* domain (INET, ISO) */
+ /* for compatibility with the *old* way and with INET, be sure that
+ * that lsuffix and fsuffix are aligned to a short addr.
+ * having them follow the u_short *suffixlen should suffice (choke)
+ */
+ u_short tpa_fsuffixlen; /* foreign suffix */
+ u_char tpa_fsuffix[MAX_TSAP_SEL_LEN];
+ u_short tpa_lsuffixlen; /* local suffix */
+ u_char tpa_lsuffix[MAX_TSAP_SEL_LEN];
+#define SHORT_LSUFXP(tpcb) ((short *)((tpcb)->tp_aux->tpa_lsuffix))
+#define SHORT_FSUFXP(tpcb) ((short *)((tpcb)->tp_aux->tpa_fsuffix))
+
+ u_char tpa_vers; /* protocol version */
+ u_char tpa_peer_acktime; /* used to compute DT retrans time */
+
+ struct sockbuf tpa_Xsnd; /* for expedited data */
+ struct sockbuf tpa_Xrcv; /* for expedited data */
+ SeqNum tpa_Xsndnxt; /* next XPD seq # to send */
+ SeqNum tpa_Xuna; /* seq # of unacked XPD */
+ SeqNum tpa_Xrcvnxt; /* next XPD seq # expect to recv */
+
+ /* AK subsequencing */
+ u_short tpa_s_subseq; /* next subseq to send */
+ u_short tpa_r_subseq; /* highest recv subseq */
+
+};
+
+struct tp_pcb {
+ u_short tp_state; /* state of fsm */
+ short tp_retrans; /* # times can still retrans */
+ struct tp_ref *tp_refp; /* rest of pcb */
+ struct tp_pcb_aux *tp_aux; /* second half of the tpcb */
+ caddr_t tp_npcb; /* to lower layer pcb */
+ struct nl_protosw *tp_nlproto; /* lower-layer dependent routines */
+ struct socket *tp_sock; /* back ptr */
+
+#define tp_Xsnd tp_aux->tpa_Xsnd
+#define tp_Xrcv tp_aux->tpa_Xrcv
+
+ RefNum tp_lref; /* local reference */
+ RefNum tp_fref; /* foreign reference */
+
+ u_int tp_seqmask; /* mask for seq space */
+ u_int tp_seqbit; /* bit for seq number wraparound */
+ u_int tp_seqhalf; /* half the seq space */
+
+#define tp_vers tp_aux->tpa_vers
+#define tp_peer_acktime tp_aux->tpa_peer_acktime
+
+ /* credit & sequencing info for SENDING */
+ u_short tp_fcredit; /* current remote credit in # packets */
+
+ u_short tp_cong_win; /* congestion window : set to 1 on
+ * source quench
+ * Minimizes the amount of retrans-
+ * missions (independently of the
+ * retrans strategy). Increased
+ * by one for each good ack received.
+ * Minimizes the amount sent in a
+ * regular tp_send() also.
+ */
+#define tp_Xsndnxt tp_aux->tpa_Xsndnxt
+#define tp_Xuna tp_aux->tpa_Xuna
+ SeqNum tp_snduna; /* seq # of lowest unacked DT */
+ struct tp_rtc *tp_snduna_rtc; /* lowest unacked stuff sent so far */
+ SeqNum tp_sndhiwat; /* highest seq # sent so far */
+ struct tp_rtc *tp_sndhiwat_rtc; /* last stuff sent so far */
+ int tp_Nwindow; /* for perf. measurement */
+
+ /* credit & sequencing info for RECEIVING */
+ SeqNum tp_sent_lcdt; /* cdt according to last ack sent */
+ SeqNum tp_sent_uwe; /* uwe according to last ack sent */
+ SeqNum tp_sent_rcvnxt; /* rcvnxt according to last ack sent
+ * needed for perf measurements only
+ */
+ u_short tp_lcredit; /* current local credit in # packets */
+ SeqNum tp_rcvnxt; /* next DT seq # expect to recv */
+ struct tp_rtc *tp_rcvnxt_rtc; /* unacked stuff recvd out of order */
+#define tp_Xrcvnxt tp_aux->tpa_Xrcvnxt
+#define tp_domain tp_aux->tpa_domain
+#define tp_fsuffix tp_aux->tpa_fsuffix
+#define tp_fsuffixlen tp_aux->tpa_fsuffixlen
+#define tp_lsuffix tp_aux->tpa_lsuffix
+#define tp_lsuffixlen tp_aux->tpa_lsuffixlen
+
+ /* parameters per-connection controllable by user */
+ struct tp_conn_param _tp_param;
+
+#define tp_Nretrans _tp_param.p_Nretrans
+#define tp_dr_ticks _tp_param.p_dr_ticks
+#define tp_cc_ticks _tp_param.p_cc_ticks
+#define tp_dt_ticks _tp_param.p_dt_ticks
+#define tp_xpd_ticks _tp_param.p_x_ticks
+#define tp_cr_ticks _tp_param.p_cr_ticks
+#define tp_keepalive_ticks _tp_param.p_keepalive_ticks
+#define tp_sendack_ticks _tp_param.p_sendack_ticks
+#define tp_refer_ticks _tp_param.p_ref_ticks
+#define tp_inact_ticks _tp_param.p_inact_ticks
+#define tp_xtd_format _tp_param.p_xtd_format
+#define tp_xpd_service _tp_param.p_xpd_service
+#define tp_ack_strat _tp_param.p_ack_strat
+#define tp_rx_strat _tp_param.p_rx_strat
+#define tp_use_checksum _tp_param.p_use_checksum
+#define tp_use_efc _tp_param.p_use_efc
+#define tp_use_nxpd _tp_param.p_use_nxpd
+#define tp_use_rcc _tp_param.p_use_rcc
+#define tp_tpdusize _tp_param.p_tpdusize
+#define tp_class _tp_param.p_class
+#define tp_winsize _tp_param.p_winsize
+#define tp_no_disc_indications _tp_param.p_no_disc_indications
+#define tp_dont_change_params _tp_param.p_dont_change_params
+#define tp_netservice _tp_param.p_netservice
+
+ int tp_l_tpdusize;
+ /* whereas tp_tpdusize is log2(the negotiated max size)
+ * l_tpdusize is the size we'll use when sending, in # chars
+ */
+
+ struct timeval tp_rtv; /* max round-trip time variance */
+ struct timeval tp_rtt; /* smoothed round-trip time */
+ struct timeval tp_rttemit[ TP_RTT_NUM + 1 ];
+ /* times that the last TP_RTT_NUM DT_TPDUs were emitted */
+ unsigned
+ tp_sendfcc:1, /* shall next ack include FCC parameter? */
+ tp_trace:1, /* is this pcb being traced? (not used yet) */
+ tp_perf_on:1, /* 0/1 -> performance measuring on */
+ tp_reneged:1, /* have we reneged on cdt since last ack? */
+ tp_decbit:4, /* dec bit was set, we're in reneg mode */
+ tp_flags:8, /* values: */
+#define TPF_CONN_DATA_OUT TPFLAG_CONN_DATA_OUT
+#define TPF_CONN_DATA_IN TPFLAG_CONN_DATA_IN
+#define TPF_DISC_DATA_IN TPFLAG_DISC_DATA_IN
+#define TPF_DISC_DATA_OUT TPFLAG_DISC_DATA_OUT
+#define TPF_XPD_PRESENT TPFLAG_XPD_PRESENT
+#define TPF_NLQOS_PDN TPFLAG_NLQOS_PDN
+#define TPF_PEER_ON_SAMENET TPFLAG_PEER_ON_SAMENET
+
+#define PEER_IS_LOCAL(t) \
+ (((t)->tp_flags & TPF_PEER_ON_SAME_NET)==TPF_PEER_ON_SAME_NET)
+#define USES_PDN(t) \
+ (((t)->tp_flags & TPF_NLQOS_PDN)==TPF_NLQOS_PDN)
+
+ tp_unused:16;
+
+#define tp_s_subseq tp_aux->tpa_s_subseq
+#define tp_r_subseq tp_aux->tpa_r_subseq
+
+#ifdef TP_PERF_MEAS
+ /* performance stats - see tp_stat.h */
+ struct tp_pmeas *tp_p_meas;
+#endif TP_PERF_MEAS
+};
+
+extern struct timeval time;
+extern struct tp_ref tp_ref[];
+extern struct tp_param tp_param;
+
+#ifdef lint
+#define sototpcb(so) ((struct tp_pcb *)0)
+#define sototpref(so) ((struct tp_ref *)0)
+#define tpcbtoso(tp) ((struct socket *)0)
+#define tpcbtoref(tp) ((struct tp_ref *)0)
+#else
+#define sototpcb(so) ((struct tp_pcb *)(so->so_tpcb))
+#define sototpref(so) ((struct tp_ref *)((so)->so_tpcb->tp_ref))
+#define tpcbtoso(tp) ((struct socket *)((tp)->tp_sock))
+#define tpcbtoref(tp) ((struct tp_ref *)((tp)->tp_ref))
+#endif
+
+#endif __TP_PCB__
projects / unix-history / commitdiff