Lines Matching defs:atp
57 #include <netat/atp.h>
134 register struct atp_state *atp;
172 * If no atp structure available return failure
175 if ((atp = atp_free_list) == NULL)
182 atp_free_list = atp->atp_trans_waiting;
188 atp->dflag = 0;
189 atp->atp_trans_wait.head = NULL;
190 atp->atp_trans_waiting = NULL;
191 atp->atp_gref = gref;
192 atp->atp_retry = 10;
193 atp->atp_timeout = HZ/8;
194 atp->atp_rcb_waiting = NULL;
195 atp->atp_rcb.head = NULL;
196 atp->atp_attached.head = NULL;
197 atp->atp_flags = T_MPSAFE;
198 atp->atp_socket_no = -1;
199 atp->atp_pid = gref->pid;
200 atp->atp_msgq = 0;
201 ATEVENTINIT(atp->atp_event);
202 ATEVENTINIT(atp->atp_delay_event);
203 gref->info = (void *)atp;
210 if ((atp->atp_trans_waiting = atp_used_list) != 0)
211 atp->atp_trans_waiting->atp_rcb_waiting = atp;
212 atp_used_list = atp;
226 register struct atp_state *atp;
232 atp = (struct atp_state *)gref->info;
233 if (atp->dflag)
234 atp = (struct atp_state *)atp->atp_msgq;
235 if (atp->atp_msgq) {
236 gbuf_freem(atp->atp_msgq);
237 atp->atp_msgq = 0;
240 atp->atp_flags |= ATP_CLOSING;
241 socket = atp->atp_socket_no;
248 for (trp = atp->atp_trans_wait.head; trp; trp = trp->tr_list.next)
254 while ((trp = atp->atp_trans_wait.head))
256 while ((rcbp = atp->atp_rcb.head))
258 while ((rcbp = atp->atp_attached.head))
262 atp_dequeue_atp(atp);
267 atp->atp_socket_no = -1;
268 atp->atp_trans_waiting = atp_free_list;
269 atp_free_list = atp;