[apple/xnu.git] / bsd / netat / atp_misc.c

/*
 * Copyright (c) 2000 Apple Computer, Inc. All rights reserved.
 *
 * @APPLE_OSREFERENCE_LICENSE_HEADER_START@
 * 
 * This file contains Original Code and/or Modifications of Original Code
 * as defined in and that are subject to the Apple Public Source License
 * Version 2.0 (the 'License'). You may not use this file except in
 * compliance with the License. The rights granted to you under the License
 * may not be used to create, or enable the creation or redistribution of,
 * unlawful or unlicensed copies of an Apple operating system, or to
 * circumvent, violate, or enable the circumvention or violation of, any
 * terms of an Apple operating system software license agreement.
 * 
 * Please obtain a copy of the License at
 * http://www.opensource.apple.com/apsl/ and read it before using this file.
 * 
 * The Original Code and all software distributed under the License are
 * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
 * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
 * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
 * Please see the License for the specific language governing rights and
 * limitations under the License.
 * 
 * @APPLE_OSREFERENCE_LICENSE_HEADER_END@
 */
/*
 *	Copyright (c) 1996-1998 Apple Computer, Inc.
 *	All Rights Reserved.
 */

/*    Modified for MP, 1996 by Tuyen Nguyen
 *   Modified, March 17, 1997 by Tuyen Nguyen for MacOSX.
 */
#include <sys/errno.h>
#include <sys/types.h>
#include <sys/param.h>
#include <machine/spl.h>
#include <sys/systm.h>
#include <sys/kernel.h>
#include <sys/proc.h>
#include <sys/filedesc.h>
#include <sys/fcntl.h>
#include <sys/mbuf.h>
#include <sys/ioctl.h>
#include <sys/malloc.h>
#include <sys/socket.h>

#include <netat/sysglue.h>
#include <netat/appletalk.h>
#include <netat/ddp.h>
#include <netat/at_pcb.h>
#include <netat/atp.h>
#include <netat/debug.h>

extern atlock_t atpgen_lock;
void atp_free();
void atp_send(struct atp_trans *);

/*
 *	The request timer retries a request, if all retries are used up
 *		it returns a NAK
 */

void
atp_req_timeout(trp)
register struct atp_trans *trp;
{
	int s;
	register gbuf_t *m;
	gref_t *gref;
	struct atp_state *atp;
	struct atp_trans *ctrp;

	if ((atp = trp->tr_queue) == 0)
		return;
	ATDISABLE(s, atp->atp_lock);
	if (atp->atp_flags & ATP_CLOSING) {
		ATENABLE(s, atp->atp_lock);
		return;
	}
	for (ctrp = atp->atp_trans_wait.head; ctrp; ctrp = ctrp->tr_list.next) {
		if (ctrp == trp)
			break;
	}
	if (ctrp != trp) {
		ATENABLE(s, atp->atp_lock);
		return;
	}

	if ((m = gbuf_cont(trp->tr_xmt)) == NULL)
	        m = trp->tr_xmt;               /* issued via the new interface */

	if (trp->tr_retry == 0) {
		trp->tr_state = TRANS_FAILED;
		if (m == trp->tr_xmt) {
			trp->tr_xmt = NULL;
l_notify:
				gbuf_wset(m,1);
				*gbuf_rptr(m) = 99;
				gbuf_set_type(m, MSG_DATA);
				gref = trp->tr_queue->atp_gref;
				ATENABLE(s, atp->atp_lock);
				atalk_putnext(gref, m);

			return;
		}
		dPrintf(D_M_ATP_LOW,D_L_INFO, ("atp_req_timeout: skt=%d\n",
			trp->tr_local_socket));
		m = trp->tr_xmt;
		switch(((ioc_t *)(gbuf_rptr(trp->tr_xmt)))->ioc_cmd) {
		case AT_ATP_ISSUE_REQUEST:
			trp->tr_xmt = NULL;
			if (trp->tr_queue->dflag)
				((ioc_t *)gbuf_rptr(m))->ioc_cmd = AT_ATP_REQUEST_COMPLETE;
			else if (trp->tr_bdsp == NULL) {
				ATENABLE(s, atp->atp_lock);
				gbuf_freem(m);
				if (trp->tr_rsp_wait)
					wakeup(&trp->tr_event);
				break;
			}
			ATENABLE(s, atp->atp_lock);
			atp_iocnak(trp->tr_queue, m, ETIMEDOUT);
			atp_free(trp);
			return;

		case AT_ATP_ISSUE_REQUEST_NOTE:
		case AT_ATP_ISSUE_REQUEST_TICKLE:
			trp->tr_xmt = gbuf_cont(m);
			gbuf_cont(m) = NULL;
			goto l_notify;
		}
	} else {
		(AT_ATP_HDR(m))->bitmap = trp->tr_bitmap;

		if (trp->tr_retry != (unsigned int) ATP_INFINITE_RETRIES)
			trp->tr_retry--;
		ATENABLE(s, atp->atp_lock);
		atp_send(trp);
	}
}


/*
 *	atp_free frees up a request, cleaning up the queues and freeing
 *		the request packet
 *      always called at 'lock'
 */

void atp_free(trp)
register struct atp_trans *trp;
{	
	register struct atp_state *atp;
	register int i;
	int s;
	
	dPrintf(D_M_ATP_LOW, D_L_TRACE,
		("atp_free: freeing trp 0x%x\n", (u_int) trp));

	ATDISABLE(s, atpgen_lock);

	if (trp->tr_state == TRANS_ABORTING) {
		ATP_Q_REMOVE(atp_trans_abort, trp, tr_list);
		trp->tr_state = TRANS_DONE;
	}
	else {
		if (trp->tr_tmo_func)
	        atp_untimout(atp_req_timeout, trp);

		atp = trp->tr_queue;
		ATP_Q_REMOVE(atp->atp_trans_wait, trp, tr_list);
	
		if (trp->tr_xmt) {
		  	gbuf_freem(trp->tr_xmt);
			trp->tr_xmt = NULL;
		}
		for (i = 0; i < 8; i++) {
		        if (trp->tr_rcv[i]) {
			        gbuf_freem(trp->tr_rcv[i]);
				trp->tr_rcv[i] = NULL;
			}
		}
		if (trp->tr_bdsp) {
			gbuf_freem(trp->tr_bdsp);
			trp->tr_bdsp = NULL;
		}
		
		if (trp->tr_rsp_wait) {
			trp->tr_state = TRANS_ABORTING;
			ATP_Q_APPEND(atp_trans_abort, trp, tr_list);
			wakeup(&trp->tr_event);
			ATENABLE(s, atpgen_lock);
			return;
		}
	}
	
	ATENABLE(s, atpgen_lock);
	atp_trans_free(trp);
} /* atp_free */


/*
 *	atp_send transmits a request packet by queuing it (if it isn't already) and
 *		scheduling the queue
 */

void atp_send(trp)
register struct atp_trans *trp;
{
	gbuf_t *m;
	struct atp_state *atp;

	dPrintf(D_M_ATP_LOW, D_L_OUTPUT, ("atp_send: trp=0x%x, loc=%d\n",
		(u_int) trp->tr_queue, trp->tr_local_socket));

	if ((atp = trp->tr_queue) != 0) {
	  if (trp->tr_state == TRANS_TIMEOUT) {
	    if ((m = gbuf_cont(trp->tr_xmt)) == NULL)
	        m = trp->tr_xmt;

	    /*
	     *	Now either release the transaction or start the timer
	     */
	    if (!trp->tr_retry && !trp->tr_bitmap && !trp->tr_xo) {
		m = (gbuf_t *)gbuf_copym(m);
		atp_x_done(trp);
	    } else {
		m = (gbuf_t *)gbuf_dupm(m);

		atp_timout(atp_req_timeout, trp, trp->tr_timeout);
	    }

	    if (m) {	
	        trace_mbufs(D_M_ATP_LOW, "  m", m);
		DDP_OUTPUT(m);
	    }
	}
  }
}


/*
 *	atp_reply sends all the available messages in the bitmap again
 *		by queueing us to the write service routine
 */

void atp_reply(rcbp)
register struct atp_rcb *rcbp;
{
	register struct atp_state *atp;
	register int i;
	int s;

  if ((atp = rcbp->rc_queue) != 0) {
	ATDISABLE(s, atp->atp_lock);
	for (i = 0; i < rcbp->rc_pktcnt; i++) {
		if (rcbp->rc_bitmap&atp_mask[i])
			rcbp->rc_snd[i] = 1;
		else
			rcbp->rc_snd[i] = 0;
	}
        if (rcbp->rc_rep_waiting == 0) {
	        rcbp->rc_state = RCB_SENDING;
	        rcbp->rc_rep_waiting = 1;
	        ATENABLE(s, atp->atp_lock);
	        atp_send_replies(atp, rcbp);
	} else
	ATENABLE(s, atp->atp_lock);
  }
}


/*
 *	The rcb timer just frees the rcb, this happens when we missed a release for XO
 */

void atp_rcb_timer()
{  
	int s;
        register struct atp_rcb *rcbp;
	register struct atp_rcb *next_rcbp;
	extern   struct atp_rcb_qhead atp_need_rel;
	extern struct atp_trans *trp_tmo_rcb;
	struct timeval timenow;

l_again:
	ATDISABLE(s, atpgen_lock);
	getmicrouptime(&timenow);
	for (rcbp = atp_need_rel.head; rcbp; rcbp = next_rcbp) {
	        next_rcbp = rcbp->rc_tlist.next;

	        if (abs(timenow.tv_sec - rcbp->rc_timestamp) > 30) {
		        ATENABLE(s, atpgen_lock);
		        atp_rcb_free(rcbp);
		        goto l_again;
		}
	}
	ATENABLE(s, atpgen_lock);
	atp_timout(atp_rcb_timer, trp_tmo_rcb, 10 * HZ);
}

atp_iocack(atp, m)
struct   atp_state *atp;
register gbuf_t *m;
{
	if (gbuf_type(m) == MSG_IOCTL)
		gbuf_set_type(m, MSG_IOCACK);
	if (gbuf_cont(m))
		((ioc_t *)gbuf_rptr(m))->ioc_count = gbuf_msgsize(gbuf_cont(m));
	else
		((ioc_t *)gbuf_rptr(m))->ioc_count = 0;

	if (atp->dflag)
		asp_ack_reply(atp->atp_gref, m);
	else
		atalk_putnext(atp->atp_gref, m);
}

atp_iocnak(atp, m, err)
struct   atp_state *atp;
register gbuf_t *m;
register int err;
{
	if (gbuf_type(m) == MSG_IOCTL)
		gbuf_set_type(m, MSG_IOCNAK);
	((ioc_t *)gbuf_rptr(m))->ioc_count = 0;
	((ioc_t *)gbuf_rptr(m))->ioc_error = err ? err : ENXIO;
	((ioc_t *)gbuf_rptr(m))->ioc_rval = -1;
	if (gbuf_cont(m)) {
		gbuf_freem(gbuf_cont(m));
		gbuf_cont(m) = NULL;
	}

	if (atp->dflag)
		asp_nak_reply(atp->atp_gref, m);
	else
		atalk_putnext(atp->atp_gref, m);
}

/*
 *	Generate a transaction id for a socket
 */
static int lasttid;
atp_tid(atp)
register struct atp_state *atp;
{
	register int i;
	register struct atp_trans *trp;
	int s;

	ATDISABLE(s, atpgen_lock);
	for (i = lasttid;;) {
		i = (i+1)&0xffff;

		for (trp = atp->atp_trans_wait.head; trp; trp = trp->tr_list.next) {
		        if (trp->tr_tid == i)
			        break;
		}
		if (trp == NULL) {
			lasttid = i;
			ATENABLE(s, atpgen_lock);
			return(i);
		}
	}
}
Commit	Line	Data
1c79356b	1	/*
5d5c5d0d A	2	* Copyright (c) 2000 Apple Computer, Inc. All rights reserved.
5d5c5d0d A	3	*
8f6c56a5	4	* @APPLE_OSREFERENCE_LICENSE_HEADER_START@
1c79356b	5	*
8f6c56a5 A	6	* This file contains Original Code and/or Modifications of Original Code
	7	* as defined in and that are subject to the Apple Public Source License
	8	* Version 2.0 (the 'License'). You may not use this file except in
	9	* compliance with the License. The rights granted to you under the License
	10	* may not be used to create, or enable the creation or redistribution of,
	11	* unlawful or unlicensed copies of an Apple operating system, or to
	12	* circumvent, violate, or enable the circumvention or violation of, any
	13	* terms of an Apple operating system software license agreement.
	14	*
	15	* Please obtain a copy of the License at
	16	* http://www.opensource.apple.com/apsl/ and read it before using this file.
	17	*
	18	* The Original Code and all software distributed under the License are
	19	* distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
	20	* EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
	21	* INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
	22	* FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
	23	* Please see the License for the specific language governing rights and
8ad349bb	24	* limitations under the License.
8f6c56a5 A	25	*
8f6c56a5 A	26	* @APPLE_OSREFERENCE_LICENSE_HEADER_END@
1c79356b A	27	*/
	28	/*
	29	* Copyright (c) 1996-1998 Apple Computer, Inc.
	30	* All Rights Reserved.
	31	*/
	32
	33	/* Modified for MP, 1996 by Tuyen Nguyen
	34	* Modified, March 17, 1997 by Tuyen Nguyen for MacOSX.
	35	*/
	36	#include <sys/errno.h>
	37	#include <sys/types.h>
	38	#include <sys/param.h>
	39	#include <machine/spl.h>
	40	#include <sys/systm.h>
	41	#include <sys/kernel.h>
	42	#include <sys/proc.h>
	43	#include <sys/filedesc.h>
	44	#include <sys/fcntl.h>
	45	#include <sys/mbuf.h>
	46	#include <sys/ioctl.h>
	47	#include <sys/malloc.h>
	48	#include <sys/socket.h>
	49
	50	#include <netat/sysglue.h>
	51	#include <netat/appletalk.h>
	52	#include <netat/ddp.h>
	53	#include <netat/at_pcb.h>
	54	#include <netat/atp.h>
	55	#include <netat/debug.h>
	56
8f6c56a5	57	extern atlock_t atpgen_lock;
1c79356b A	58	void atp_free();
	59	void atp_send(struct atp_trans *);
	60
	61	/*
	62	* The request timer retries a request, if all retries are used up
	63	* it returns a NAK
	64	*/
	65
	66	void
	67	atp_req_timeout(trp)
	68	register struct atp_trans *trp;
	69	{
8f6c56a5	70	int s;
1c79356b A	71	register gbuf_t *m;
	72	gref_t *gref;
	73	struct atp_state *atp;
	74	struct atp_trans *ctrp;
	75
	76	if ((atp = trp->tr_queue) == 0)
	77	return;
8f6c56a5 A	78	ATDISABLE(s, atp->atp_lock);
	79	if (atp->atp_flags & ATP_CLOSING) {
	80	ATENABLE(s, atp->atp_lock);
1c79356b	81	return;
8f6c56a5	82	}
1c79356b A	83	for (ctrp = atp->atp_trans_wait.head; ctrp; ctrp = ctrp->tr_list.next) {
	84	if (ctrp == trp)
	85	break;
	86	}
8f6c56a5 A	87	if (ctrp != trp) {
8f6c56a5 A	88	ATENABLE(s, atp->atp_lock);
1c79356b	89	return;
8f6c56a5	90	}
1c79356b A	91
	92	if ((m = gbuf_cont(trp->tr_xmt)) == NULL)
	93	m = trp->tr_xmt; /* issued via the new interface */
	94
	95	if (trp->tr_retry == 0) {
	96	trp->tr_state = TRANS_FAILED;
	97	if (m == trp->tr_xmt) {
	98	trp->tr_xmt = NULL;
	99	l_notify:
	100	gbuf_wset(m,1);
	101	*gbuf_rptr(m) = 99;
	102	gbuf_set_type(m, MSG_DATA);
	103	gref = trp->tr_queue->atp_gref;
8f6c56a5	104	ATENABLE(s, atp->atp_lock);
1c79356b A	105	atalk_putnext(gref, m);
	106
	107	return;
	108	}
	109	dPrintf(D_M_ATP_LOW,D_L_INFO, ("atp_req_timeout: skt=%d\n",
	110	trp->tr_local_socket));
	111	m = trp->tr_xmt;
	112	switch(((ioc_t *)(gbuf_rptr(trp->tr_xmt)))->ioc_cmd) {
	113	case AT_ATP_ISSUE_REQUEST:
	114	trp->tr_xmt = NULL;
	115	if (trp->tr_queue->dflag)
	116	((ioc_t *)gbuf_rptr(m))->ioc_cmd = AT_ATP_REQUEST_COMPLETE;
	117	else if (trp->tr_bdsp == NULL) {
8f6c56a5	118	ATENABLE(s, atp->atp_lock);
1c79356b A	119	gbuf_freem(m);
1c79356b A	120	if (trp->tr_rsp_wait)
9bccf70c	121	wakeup(&trp->tr_event);
1c79356b A	122	break;
1c79356b A	123	}
8f6c56a5	124	ATENABLE(s, atp->atp_lock);
1c79356b A	125	atp_iocnak(trp->tr_queue, m, ETIMEDOUT);
	126	atp_free(trp);
	127	return;
	128
	129	case AT_ATP_ISSUE_REQUEST_NOTE:
	130	case AT_ATP_ISSUE_REQUEST_TICKLE:
	131	trp->tr_xmt = gbuf_cont(m);
	132	gbuf_cont(m) = NULL;
	133	goto l_notify;
	134	}
	135	} else {
	136	(AT_ATP_HDR(m))->bitmap = trp->tr_bitmap;
	137
	138	if (trp->tr_retry != (unsigned int) ATP_INFINITE_RETRIES)
	139	trp->tr_retry--;
8f6c56a5	140	ATENABLE(s, atp->atp_lock);
1c79356b A	141	atp_send(trp);
	142	}
	143	}
	144
	145
	146	/*
	147	* atp_free frees up a request, cleaning up the queues and freeing
	148	* the request packet
	149	* always called at 'lock'
	150	*/
	151
	152	void atp_free(trp)
	153	register struct atp_trans *trp;
0b4e3aa0	154	{
1c79356b A	155	register struct atp_state *atp;
1c79356b A	156	register int i;
8f6c56a5	157	int s;
1c79356b A	158
	159	dPrintf(D_M_ATP_LOW, D_L_TRACE,
	160	("atp_free: freeing trp 0x%x\n", (u_int) trp));
1c79356b	161
8f6c56a5	162	ATDISABLE(s, atpgen_lock);
1c79356b	163
0b4e3aa0 A	164	if (trp->tr_state == TRANS_ABORTING) {
	165	ATP_Q_REMOVE(atp_trans_abort, trp, tr_list);
	166	trp->tr_state = TRANS_DONE;
1c79356b	167	}
0b4e3aa0 A	168	else {
	169	if (trp->tr_tmo_func)
	170	atp_untimout(atp_req_timeout, trp);
	171
	172	atp = trp->tr_queue;
	173	ATP_Q_REMOVE(atp->atp_trans_wait, trp, tr_list);
	174
	175	if (trp->tr_xmt) {
	176	gbuf_freem(trp->tr_xmt);
	177	trp->tr_xmt = NULL;
	178	}
	179	for (i = 0; i < 8; i++) {
	180	if (trp->tr_rcv[i]) {
	181	gbuf_freem(trp->tr_rcv[i]);
	182	trp->tr_rcv[i] = NULL;
	183	}
	184	}
	185	if (trp->tr_bdsp) {
	186	gbuf_freem(trp->tr_bdsp);
	187	trp->tr_bdsp = NULL;
	188	}
	189
	190	if (trp->tr_rsp_wait) {
	191	trp->tr_state = TRANS_ABORTING;
	192	ATP_Q_APPEND(atp_trans_abort, trp, tr_list);
9bccf70c	193	wakeup(&trp->tr_event);
8f6c56a5	194	ATENABLE(s, atpgen_lock);
0b4e3aa0	195	return;
1c79356b A	196	}
1c79356b A	197	}
0b4e3aa0	198
8f6c56a5	199	ATENABLE(s, atpgen_lock);
1c79356b	200	atp_trans_free(trp);
1c79356b A	201	} /* atp_free */
	202
	203
	204	/*
	205	* atp_send transmits a request packet by queuing it (if it isn't already) and
	206	* scheduling the queue
	207	*/
	208
	209	void atp_send(trp)
	210	register struct atp_trans *trp;
	211	{
	212	gbuf_t *m;
	213	struct atp_state *atp;
	214
	215	dPrintf(D_M_ATP_LOW, D_L_OUTPUT, ("atp_send: trp=0x%x, loc=%d\n",
	216	(u_int) trp->tr_queue, trp->tr_local_socket));
	217
	218	if ((atp = trp->tr_queue) != 0) {
	219	if (trp->tr_state == TRANS_TIMEOUT) {
	220	if ((m = gbuf_cont(trp->tr_xmt)) == NULL)
	221	m = trp->tr_xmt;
	222
	223	/*
	224	* Now either release the transaction or start the timer
	225	*/
	226	if (!trp->tr_retry && !trp->tr_bitmap && !trp->tr_xo) {
	227	m = (gbuf_t *)gbuf_copym(m);
	228	atp_x_done(trp);
	229	} else {
	230	m = (gbuf_t *)gbuf_dupm(m);
	231
	232	atp_timout(atp_req_timeout, trp, trp->tr_timeout);
	233	}
	234
	235	if (m) {
	236	trace_mbufs(D_M_ATP_LOW, " m", m);
	237	DDP_OUTPUT(m);
	238	}
	239	}
	240	}
	241	}
	242
	243
	244	/*
	245	* atp_reply sends all the available messages in the bitmap again
	246	* by queueing us to the write service routine
	247	*/
	248
	249	void atp_reply(rcbp)
	250	register struct atp_rcb *rcbp;
	251	{
	252	register struct atp_state *atp;
	253	register int i;
8f6c56a5	254	int s;
1c79356b A	255
1c79356b A	256	if ((atp = rcbp->rc_queue) != 0) {
8f6c56a5	257	ATDISABLE(s, atp->atp_lock);
1c79356b A	258	for (i = 0; i < rcbp->rc_pktcnt; i++) {
	259	if (rcbp->rc_bitmap&atp_mask[i])
	260	rcbp->rc_snd[i] = 1;
	261	else
	262	rcbp->rc_snd[i] = 0;
	263	}
	264	if (rcbp->rc_rep_waiting == 0) {
	265	rcbp->rc_state = RCB_SENDING;
	266	rcbp->rc_rep_waiting = 1;
8f6c56a5	267	ATENABLE(s, atp->atp_lock);
1c79356b	268	atp_send_replies(atp, rcbp);
8f6c56a5 A	269	} else
8f6c56a5 A	270	ATENABLE(s, atp->atp_lock);
1c79356b A	271	}
	272	}
	273
	274
	275	/*
	276	* The rcb timer just frees the rcb, this happens when we missed a release for XO
	277	*/
	278
	279	void atp_rcb_timer()
	280	{
8f6c56a5 A	281	int s;
8f6c56a5 A	282	register struct atp_rcb *rcbp;
1c79356b A	283	register struct atp_rcb *next_rcbp;
	284	extern struct atp_rcb_qhead atp_need_rel;
	285	extern struct atp_trans *trp_tmo_rcb;
91447636	286	struct timeval timenow;
1c79356b A	287
1c79356b A	288	l_again:
8f6c56a5	289	ATDISABLE(s, atpgen_lock);
91447636	290	getmicrouptime(&timenow);
1c79356b A	291	for (rcbp = atp_need_rel.head; rcbp; rcbp = next_rcbp) {
	292	next_rcbp = rcbp->rc_tlist.next;
	293
8f6c56a5 A	294	if (abs(timenow.tv_sec - rcbp->rc_timestamp) > 30) {
8f6c56a5 A	295	ATENABLE(s, atpgen_lock);
1c79356b A	296	atp_rcb_free(rcbp);
	297	goto l_again;
	298	}
	299	}
8f6c56a5	300	ATENABLE(s, atpgen_lock);
1c79356b A	301	atp_timout(atp_rcb_timer, trp_tmo_rcb, 10 * HZ);
	302	}
	303
	304	atp_iocack(atp, m)
	305	struct atp_state *atp;
	306	register gbuf_t *m;
	307	{
	308	if (gbuf_type(m) == MSG_IOCTL)
	309	gbuf_set_type(m, MSG_IOCACK);
	310	if (gbuf_cont(m))
	311	((ioc_t *)gbuf_rptr(m))->ioc_count = gbuf_msgsize(gbuf_cont(m));
	312	else
	313	((ioc_t *)gbuf_rptr(m))->ioc_count = 0;
	314
	315	if (atp->dflag)
	316	asp_ack_reply(atp->atp_gref, m);
	317	else
	318	atalk_putnext(atp->atp_gref, m);
	319	}
	320
	321	atp_iocnak(atp, m, err)
	322	struct atp_state *atp;
	323	register gbuf_t *m;
	324	register int err;
	325	{
	326	if (gbuf_type(m) == MSG_IOCTL)
	327	gbuf_set_type(m, MSG_IOCNAK);
	328	((ioc_t *)gbuf_rptr(m))->ioc_count = 0;
	329	((ioc_t *)gbuf_rptr(m))->ioc_error = err ? err : ENXIO;
	330	((ioc_t *)gbuf_rptr(m))->ioc_rval = -1;
	331	if (gbuf_cont(m)) {
	332	gbuf_freem(gbuf_cont(m));
	333	gbuf_cont(m) = NULL;
	334	}
	335
	336	if (atp->dflag)
	337	asp_nak_reply(atp->atp_gref, m);
	338	else
	339	atalk_putnext(atp->atp_gref, m);
	340	}
	341
	342	/*
	343	* Generate a transaction id for a socket
	344	*/
	345	static int lasttid;
	346	atp_tid(atp)
	347	register struct atp_state *atp;
	348	{
	349	register int i;
	350	register struct atp_trans *trp;
8f6c56a5	351	int s;
1c79356b	352
8f6c56a5	353	ATDISABLE(s, atpgen_lock);
1c79356b A	354	for (i = lasttid;;) {
	355	i = (i+1)&0xffff;
	356
	357	for (trp = atp->atp_trans_wait.head; trp; trp = trp->tr_list.next) {
	358	if (trp->tr_tid == i)
	359	break;
	360	}
	361	if (trp == NULL) {
	362	lasttid = i;
8f6c56a5	363	ATENABLE(s, atpgen_lock);
1c79356b A	364	return(i);
	365	}
	366	}
	367	}