-
-/*
- * Open routine, called to initialize newly created tcb fields.
- */
-tcp_open(tp, mode)
- register struct tcb *tp;
- int mode;
-{
- register struct ucb *up = tp->t_ucb;
-COUNT(TCP_OPEN);
-
- /*
- * Link in tcb queue and make
- * initialize empty reassembly queue.
- */
- tp->tcb_next = tcb.tcb_next;
- tcb.tcb_next->tcb_prev = tp;
- tp->tcb_prev = (struct tcb *)&tcb;
- tcb.tcb_next = tp;
- tp->t_rcv_next = tp->t_rcv_prev = (struct th *)tp;
-
- /*
- * Initialize sequence numbers and
- * round trip retransmit timer.
- * (Other fields were init'd to zero when tcb allocated.)
- */
- tp->t_xmtime = T_REXMT;
- tp->snd_end = tp->seq_fin = tp->snd_nxt = tp->snd_hi = tp->snd_una =
- tp->iss = tcp_iss;
- tp->snd_off = tp->iss + 1;
- tcp_iss += (ISSINCR >> 1) + 1;
-
- /*
- * Set timeout for open.
- * SHOULD THIS BE A HIGHER LEVEL FUNCTION!?! THINK SO.
- */
- if (up->uc_timeo)
- tp->t_init = up->uc_timeo;
- else if (mode == ACTIVE)
- tp->t_init = T_INIT;
- /* else
- tp->t_init = 0; */
- up->uc_timeo = 0; /* ### */
-}
-
-/*
- * Internal close of a connection, shutting down the tcb.
- */
-tcp_close(tp, state)
- register struct tcb *tp;
- short state;
-{
- register struct ucb *up = tp->t_ucb;
- register struct th *t;
- register struct mbuf *m;
-COUNT(TCP_CLOSE);
-
- /*
- * Cancel all timers.
- * SHOULD LOOP HERE !?!
- */
- tp->t_init = tp->t_rexmt = tp->t_rexmttl = tp->t_persist =
- tp->t_finack = 0;
-
- /*
- * Remque the tcb
- */
- tp->tcb_prev->tcb_next = tp->tcb_next;
- tp->tcb_next->tcb_prev = tp->tcb_prev;
-
- /*
- * Discard all buffers...
- *
- * SHOULD COUNT EACH RESOURCE TO 0 AND PANIC IF CONFUSED
- */
- for (t = tp->t_rcv_next; t != (struct th *)tp; t = t->t_next)
- m_freem(dtom(t));
- if (up->uc_rbuf != NULL) {
- m_freem(up->uc_rbuf);
- up->uc_rbuf = NULL;
- }
- up->uc_rcc = 0;
- if (up->uc_sbuf != NULL) {
- m_freem(up->uc_sbuf);
- up->uc_sbuf = NULL;
- }
- up->uc_ssize = 0;
- for (m = tp->t_rcv_unack; m != NULL; m = m->m_act) {
- m_freem(m);
- tp->t_rcv_unack = NULL;
- }
-
- /*
- * Free tcp send template.
- */
- if (up->uc_template) {
- m_free(dtom(up->uc_template));
- up->uc_template = 0;
- }
-
- /*
- * Free the tcb
- * WOULD THIS BETTER BE DONE AT USER CLOSE?
- */
- wmemfree((caddr_t)tp, 1024);
- up->uc_tcb = NULL;
-
- /*
- * Lower buffer allocation.
- * SHOULD BE A M_ROUTINE CALL.
- */
- mbstat.m_lowat -= up->uc_snd + (up->uc_rhiwat/MSIZE) + 2;
- mbstat.m_hiwat = 2 * mbstat.m_lowat;
-
- /*
- * Free routing table entry.
- */
- if (up->uc_host != NULL) {
- h_free(up->uc_host);
- up->uc_host = NULL;
- }
-
- /*
- * If user has initiated close (via close call), delete ucb
- * entry, otherwise just wakeup so user can issue close call
- */
- if (tp->tc_flags&TC_USR_ABORT)
- up->uc_proc = NULL;
- else
- to_user(up, state); /* ### */
-}
-
-/*
- * User routine to send data queue headed by m0 into the protocol.
- */
-tcp_usrsend(tp, m0)
- register struct tcb *tp;
- struct mbuf *m0;
-{
- register struct mbuf *m, *n;
- register struct ucb *up = tp->t_ucb;
- register off;
- seq_t last;
-COUNT(TCP_USRSEND);
-
- last = tp->snd_off;
- for (m = n = m0; m != NULL; m = m->m_next) {
- up->uc_ssize++;
- if (m->m_off > MMAXOFF)
- up->uc_ssize += NMBPG;
- last += m->m_len;
- }
- if ((m = up->uc_sbuf) == NULL)
- up->uc_sbuf = n;
- else {
- while (m->m_next != NULL) {
- m = m->m_next;
- last += m->m_len;
- }
- if (m->m_off <= MMAXOFF) {
- last += m->m_len;
- off = m->m_off + m->m_len;
- while (n && n->m_off <= MMAXOFF &&
- (MMAXOFF - off) >= n->m_len) {
- bcopy((caddr_t)((int)n + n->m_off),
- (caddr_t)((int)m + off), n->m_len);
- m->m_len += n->m_len;
- off += n->m_len;
- up->uc_ssize--;
- n = m_free(n);
- }
- }
- m->m_next = n;
- }
- if (up->uc_flags & UEOL)
- tp->snd_end = last;
- if (up->uc_flags & UURG) {
- tp->snd_urp = last+1;
- tp->tc_flags |= TC_SND_URG;
- }
- tcp_send(tp);
- return (SAME);
-}
-
-/*
- * TCP timer went off processing.
- */
-tcp_timers(tp, timertype)
- register struct tcb *tp;
- int timertype;
-{
-
-COUNT(TCP_TIMERS);
- switch (timertype) {
-
- case TINIT: /* initialization timer */
- if ((tp->tc_flags&TC_SYN_ACKED) == 0) { /* 35 */
- tcp_close(tp, UINTIMO);
- return (CLOSED);
- }
- return (SAME);
-
- case TFINACK: /* fin-ack timer */
- switch (tp->t_state) {
-
- case TIME_WAIT:
- /*
- * We can be sure our ACK of foreign FIN was rcvd,
- * and can close if no data left for user.
- */
- if (rcv_empty(tp)) {
- tcp_close(tp, UCLOSED); /* 14 */
- return (CLOSED);
- }
- return (RCV_WAIT); /* 17 */
-
- case CLOSING:
- tp->tc_flags |= TC_WAITED_2_ML;
- return (SAME);
-
- default:
- return (SAME);
- }
-
- case TREXMT: /* retransmission timer */
- if (tp->t_rexmt_val > tp->snd_una) { /* 34 */
- /*
- * Set up for a retransmission, increase rexmt time
- * in case of multiple retransmissions.
- */
- tp->snd_nxt = tp->snd_una;
- tp->tc_flags |= TC_REXMT;
- tp->t_xmtime = tp->t_xmtime << 1;
- if (tp->t_xmtime > T_REMAX)
- tp->t_xmtime = T_REMAX;
- tcp_send(tp);
- }
- return (SAME);
-
- case TREXMTTL: /* retransmit too long */
- if (tp->t_rtl_val > tp->snd_una) /* 36 */
- to_user(tp->t_ucb, URXTIMO);
- /*
- * If user has already closed, abort the connection.
- */
- if (tp->tc_flags & TC_USR_CLOSED) {
- tcp_close(tp, URXTIMO);
- return (CLOSED);
- }
- return (SAME);
-
- case TPERSIST: /* persist timer */
- /*
- * Force a byte send through closed window.
- */
- tp->tc_flags |= TC_FORCE_ONE;
- tcp_send(tp);
- return (SAME);
- }
- panic("tcp_timers");
-}
-
-/* THIS ROUTINE IS A CROCK */
-to_user(up, state)
- register struct ucb *up;
- register short state;
-{
-COUNT(TO_USER);
-
- up->uc_state |= state;
- netwakeup(up);
- if (state == UURGENT)
- psignal(up->uc_proc, SIGURG);
-}
-
-#ifdef TCPDEBUG
-/*
- * TCP debugging utility subroutines.
- * THE NAMES OF THE FIELDS USED BY THESE ROUTINES ARE STUPID.
- */
-tdb_setup(tp, n, input, tdp)
- struct tcb *tp;
- register struct th *n;
- int input;
- register struct tcp_debug *tdp;
-{
-
-COUNT(TDB_SETUP);
- tdp->td_tod = time;
- tdp->td_tcb = tp;
- tdp->td_old = tp->t_state;
- tdp->td_inp = input;
- tdp->td_tim = 0;
- tdp->td_new = -1;
- if (n) {
- tdp->td_sno = n->t_seq;
- tdp->td_ano = n->t_ackno;
- tdp->td_wno = n->t_win;
- tdp->td_lno = n->t_len;
- tdp->td_flg = n->th_flags;
- } else
- tdp->td_sno = tdp->td_ano = tdp->td_wno = tdp->td_lno =
- tdp->td_flg = 0;
-}
-
-tdb_stuff(tdp, nstate)
- struct tcp_debug *tdp;
- int nstate;
-{
-COUNT(TDB_STUFF);
-
- tdp->td_new = nstate;
- tcp_debug[tdbx++ % TDBSIZE] = *tdp;
- if (tcpconsdebug & 2)
- tcp_prt(tdp);
-}
-
-tcp_prt(tdp)
- register struct tcp_debug *tdp;
-{
-COUNT(TCP_PRT);
-
- printf("%x ", ((int)tdp->td_tcb)&0xffffff);
- if (tdp->td_inp == INSEND) {
- printf("SEND #%x", tdp->td_sno);
- tdp->td_lno = ntohs(tdp->td_lno);
- tdp->td_wno = ntohs(tdp->td_wno);
- } else {
- if (tdp->td_inp == INRECV)
- printf("RCV #%x ", tdp->td_sno);
- printf("%s.%s",
- tcpstates[tdp->td_old], tcpinputs[tdp->td_inp]);
- if (tdp->td_inp == ISTIMER)
- printf("(%s)", tcptimers[tdp->td_tim]);
- printf(" -> %s",
- tcpstates[(tdp->td_new > 0) ? tdp->td_new : tdp->td_old]);
- if (tdp->td_new == -1)
- printf(" (FAILED)");
- }
- /* GROSS... DEPENDS ON SIGN EXTENSION OF CHARACTERS */
- if (tdp->td_lno)
- printf(" len=%d", tdp->td_lno);
- if (tdp->td_wno)
- printf(" win=%d", tdp->td_wno);
- if (tdp->td_flg & TH_FIN) printf(" FIN");
- if (tdp->td_flg & TH_SYN) printf(" SYN");
- if (tdp->td_flg & TH_RST) printf(" RST");
- if (tdp->td_flg & TH_EOL) printf(" EOL");
- if (tdp->td_flg & TH_ACK) printf(" ACK %x", tdp->td_ano);
- if (tdp->td_flg & TH_URG) printf(" URG");
- printf("\n");
-}
-#endif
projects / unix-history / blobdiff