1991/0424/port/tcpif.c (diff list | history)

port/tcpif.c on 1991/0424
1991/0424		#include "u.h" #include "lib.h" #include "mem.h" #include "dat.h" #include "fns.h" #include "errno.h" #include "arp.h" #include "ipdat.h" extern int tcpdbg; #define DPRINT if(tcpdbg) print void state_upcall(Ipconv *s, char oldstate, char newstate) { Block *bp; int len; char *ptr = 0; SET(len); DPRINT("state_upcall: %s -> %s err %d\n", tcpstate[oldstate], tcpstate[newstate], s->err); if(oldstate == newstate) return; switch(newstate) { case CLOSED: s->psrc = 0; s->pdst = 0; s->dst = 0; case CLOSE_WAIT: /* Remote closes */ if(s->readq == 0) break; if(s->err) { ptr = errstrtab[s->err]; len = strlen(ptr)+1; bp = allocb(len); } else bp = allocb(0); if(bp) { if(ptr) { strcpy((char *)bp->wptr, ptr); bp->wptr += len; } bp->flags |= S_DELIM; bp->type = M_HANGUP; PUTNEXT(s->readq, bp); } } } void open_tcp(Ipconv *s, int mode, ushort window, char tos) { Tcpctl *tcb = &s->tcpctl; if(tcb->state != CLOSED) return; init_tcpctl(s); tcb->window = tcb->rcv.wnd = window; tcb->tos = tos; switch(mode){ case TCP_PASSIVE: tcb->flags |= CLONE; setstate(s, LISTEN); break; case TCP_ACTIVE: /* Send SYN, go into SYN_SENT state */ tcb->flags |= ACTIVE; qlock(tcb); send_syn(tcb); setstate(s, SYN_SENT); tcp_output(s); qunlock(tcb); break; } }