1990/0315/port/sturp.c (diff list | history)

1990/0312/sys/src/9/port/sturp.c:123,128 – 1990/0315/sys/src/9/port/sturp.c:123,130 (short | long | prev | next)
1990/0227		int i;
1990/0312		char name[128];
1990/0227
1990/0315		DPRINT("urpopen\n");
1990/0227		/* * find a free urp structure */
1990/0312/sys/src/9/port/sturp.c:379,385 – 1990/0315/sys/src/9/port/sturp.c:381,387
1990/0227		case 0: break; case ENQ:
1990/0312		print("rENQ\n");
1990/0315		print("rENQ %uo %uo\n", up->lastecho, ACK+up->iseq);
1990/0227		urpstat.enqsr++;
1990/0312		sendctl(up, up->lastecho); sendctl(up, ACK+up->iseq);
1990/0312/sys/src/9/port/sturp.c:443,461 – 1990/0315/sys/src/9/port/sturp.c:445,463
1990/0227		if(up->trx != 3){ urpstat.rjtrs++; flushinput(up);
1990/0312		print("sREJ\n");
1990/0315		print("sREJ1 %d\n", up->iseq);
1990/0312		sendctl(up, up->lastecho = REJ+up->iseq);
1990/0227		break; } else if(q->len != up->trbuf[1] + (up->trbuf[2]<<8)){ urpstat.rjpks++; flushinput(up);
1990/0312		print("sREJ\n");
1990/0315		print("sREJ2 %d\n", up->iseq);
1990/0312		sendctl(up, up->lastecho = REJ+up->iseq);
1990/0227		break;
1990/0312		} else if(i != ((up->iseq+1)&Nmask)) {
1990/0227		urpstat.rjseq++; flushinput(up);
1990/0312		print("sREJ\n");
1990/0315		print("sREJ3 %d %d\n", i, up->iseq);
1990/0312		sendctl(up, up->lastecho = REJ+up->iseq);
1990/0227		break; }
1990/0312/sys/src/9/port/sturp.c:780,785 – 1990/0315/sys/src/9/port/sturp.c:782,788
1990/0312		qlock(&up->xl[i]); if(up->xb[i]) freeb(up->xb[i]);
1990/0315		up->xb[i] = 0;
1990/0312		qunlock(&up->xl[i]); }
1990/0312/sys/src/9/port/sturp.c:823,828 – 1990/0315/sys/src/9/port/sturp.c:826,832
1990/0312		Urp *up; up = (Urp *)arg;
1990/0315		DPRINT("urpkproc started\n");
1990/0312		for(;;){ if(up->state & (HUNGUP|CLOSING)){