bsd/netat/atp_read.c

143 		register struct atp_trans *trp;
151 		for (trp = atp->atp_trans_wait.head; trp; trp = trp->tr_list.next) {
152 		    if (trp->tr_tid == UAS_VALUE_NTOH(athp->tid))
170 		if (trp == NULL) {
173 		("atp_rput: dropping TRESP, no trp,tid=%d,loc=%d,rem=%d.%d,seqno=%u\n",
183 		if (trp->tr_state == TRANS_FAILED) {
186 		("atp_rput: dropping TRESP, failed trp,tid=%d,loc=%d,rem=%d.%d\n",
196 		if (!(trp->tr_bitmap&atp_mask[seqno]) || trp->tr_rcv[seqno]) {
210 		    trp->tr_bitmap &= atp_lomask[seqno];
212 		    trp->tr_bitmap &= ~atp_mask[seqno];
217 		trp->tr_rcv[seqno] = m;
230 		if (trp->tr_bitmap == 0) {
236 		    atp_untimout(atp_req_timeout, trp);
241 		    atp_x_done(trp);
248 		    atp_untimout(atp_req_timeout, trp);
249 		    atp_send(trp);
460 atp_x_done_locked(trp)
461 void *trp;
464 	atp_x_done((struct atp_trans *)trp);
470 atp_x_done(trp)
471 register struct atp_trans *trp;
477 	if ( !trp->tr_xo)
478 	        atp_trans_complete(trp);
483 	        if ((m = (gbuf_t *)atp_build_release(trp)) != NULL) {
485 		            trp->tr_queue)->atp_socket_no;
491 			atp_trans_complete(trp);
494 			atp = trp->tr_queue;
495 			trp->tr_state = TRANS_RELEASE;
496 			timeout(atp_x_done_locked, trp, 10);
502 atp_trans_complete(trp)
503 register struct atp_trans *trp;
508 	/* we could gbuf_freem(trp->tr_xmt) here if were not planning to
510 	m = trp->tr_xmt;
511 	trp->tr_xmt = NULL;
512 	trp->tr_state = TRANS_DONE;
524 	dPrintf(D_M_ATP_LOW, D_L_INPUT, ("atp_trans_comp: trp=0x%x type = %s\n",
525 		(u_int) trp,
532 	 atp = trp->tr_queue;
536 		((ioc_t *)gbuf_rptr(m))->ioc_rval = trp->tr_tid;
539 		atp_rsp_ind(trp, m);
541 	  if (trp->tr_bdsp == NULL) {
543 		if (trp->tr_rsp_wait)
544 			wakeup(&trp->tr_event);
550 		atalk_putnext(trp->tr_queue->atp_gref, m);
559 		atalk_putnext(trp->tr_queue->atp_gref, m);