bsd/netat/atp_read.c

256 	    {   register struct atp_rcb *rcbp;
264 		for (rcbp = atp->atp_rcb.head; rcbp; rcbp = rcbp->rc_list.next) {
265 		    if (rcbp->rc_tid == UAS_VALUE_NTOH(athp->tid) &&
266 			rcbp->rc_socket.node == ddp->src_node &&
267 			rcbp->rc_socket.net == NET_VALUE(ddp->src_net) &&
268 			rcbp->rc_socket.socket == ddp->src_socket) {
272 			    rcbp->rc_not_sent_bitmap = 0;
273 		            if (rcbp->rc_state == RCB_SENDING)
274 			        rcbp->rc_state = RCB_RELEASED;
278 				atp_rcb_free(rcbp);
290 	   {    register struct atp_rcb *rcbp;
302 		for (rcbp = atp->atp_rcb.head; rcbp; rcbp = rcbp->rc_list.next) {
303 		    if (rcbp->rc_tid == UAS_VALUE_NTOH(athp->tid) &&
304 			rcbp->rc_socket.node == ddp->src_node &&
305 			rcbp->rc_socket.net == NET_VALUE(ddp->src_net) &&
306 			rcbp->rc_socket.socket == ddp->src_socket)
313 		if (rcbp == NULL) {
321 		    for (rcbp = atp->atp_attached.head; rcbp; rcbp = rcbp->rc_list.next) {
322 		        if (rcbp->rc_tid == UAS_VALUE_NTOH(athp->tid) &&
323 			    rcbp->rc_socket.node == ddp->src_node &&
324 			    rcbp->rc_socket.net == NET_VALUE(ddp->src_net) &&
325 			    rcbp->rc_socket.socket == ddp->src_socket) {
337 			if ((rcbp = atp_rcb_alloc(atp)) == NULL) {
341 			rcbp->rc_state = RCB_UNQUEUED;
343 		    rcbp->rc_local_node = ddp->dst_node;
345 		    NET_ASSIGN_NOSWAP(rcbp->rc_local_net, temp_net);
346 		    rcbp->rc_socket.socket = ddp->src_socket;
347 		    rcbp->rc_socket.node = ddp->src_node;
348 		    rcbp->rc_socket.net = NET_VALUE(ddp->src_net);
349 		    rcbp->rc_tid = UAS_VALUE_NTOH(athp->tid);
350 		    rcbp->rc_bitmap = athp->bitmap;
351 		    rcbp->rc_not_sent_bitmap = athp->bitmap;
352 		    rcbp->rc_xo = athp->xo;
376 			rcbp->rc_ioctl = m;
383 			rcbp->rc_state = RCB_PENDING;
384 			ATP_Q_APPEND(atp->atp_attached, rcbp, rc_list);
392 			    rcbp->rc_state));
398 		    switch (rcbp->rc_state) {
409 			if (rcbp->rc_timestamp) {
410 			  rcbp->rc_timestamp = timenow.tv_sec;
411 			  if (rcbp->rc_timestamp == 0)
412 			    rcbp->rc_timestamp = 1;
414 			rcbp->rc_bitmap = athp->bitmap;
415 			rcbp->rc_not_sent_bitmap = athp->bitmap;
417 			atp_reply(rcbp);