bsd/netat/adsp_stream.c

88 	CCBPtr sp;
95 		sp = adsp_inputQ[p->dst_socket];
96 		if ((sp == 0) || (sp->gref==0) || (sp->state==sClosed))
101 		else if (sp->otccbLink != 0) {
103 				if ((sp->remoteAddress.a.node == p->src_node)
104 					&& (sp->remoteAddress.a.socket == p->src_socket)
105 				&& (sp->remoteAddress.a.net == NET_VALUE(p->src_net)))
107 			} while ((sp = sp->otccbLink) != 0);
108 			if (sp == 0)
114 		if (sp->lockFlag) {
116 			if (sp->deferred_mb) {
117 				for (mb=sp->deferred_mb; gbuf_next(mb); mb=gbuf_next(mb)) ;
120 				sp->deferred_mb = mp;
123 		sp->lockFlag = 1;
125 			adsp_rput(sp->gref, mp);
126 			if ((mp = sp->deferred_mb) != 0) {
127 				sp->deferred_mb = gbuf_next(mp);
131 		sp->lockFlag = 0;
160 	CCBPtr sp;
174 	sp = (CCBPtr)gbuf_rptr(((gbuf_t *)gref->info));
175 	rc = sp->rData;
185 	CCBPtr sp;
199 	sp = (CCBPtr)gbuf_rptr(((gbuf_t *)gref->info));
200 	rc = CalcSendQFree(sp);
227     register CCBPtr sp;
235 	sp = (CCBPtr)gbuf_rptr(((gbuf_t *)gref->info));
238 	if ((sp->otccbLink = ccb_used_list) != 0)
239 		sp->otccbLink->ccbLink = sp;
240 	ccb_used_list = sp;
251 	CCBPtr sp = (CCBPtr)gbuf_rptr(((gbuf_t *)gref->info));
252 	localSocket = sp->localSocket;
257 		adsp_dequeue_ccb(sp);
328 	CCBPtr sp;
331 		sp = (CCBPtr)gbuf_rptr(((gbuf_t *)gref->info));
333 		sp = 0;
362 					adsp_inputQ[v] = sp;
363 					adsp_pidM[v] = sp->pid;
364 					adsp_dequeue_ccb(sp);
367 				sp->localSocket = v;
393 				addr->socket = (sp)? sp->localSocket: 0;
395 				if (sp)
396 					*addr = sp->remoteAddress.a;
423 			  cfgp->inet.socket = (sp)? sp->localSocket: 0;
519 	CCBPtr sp;
542 	sp = (CCBPtr)gbuf_rptr(((gbuf_t *)gref->info));
543 	adsp_dequeue_ccb(sp);
545 	sp->otccbLink = adsp_inputQ[sVal];
546 	adsp_inputQ[sVal] = sp;
548 		adsp_pidM[sVal] = sp->pid;
553 adspDeassignSocket(sp)
554 	CCBPtr sp;
562 		sp->pid, sp->localSocket));
563 	sVal = sp->localSocket;
566 		while (curr_sp != sp) {
572 				prev_sp->otccbLink = sp->otccbLink;
574 				adsp_inputQ[sVal] = sp->otccbLink;
582 			sp->ccbLink = 0;
583 			sp->otccbLink = 0;
584 			sp->localSocket = 0;
598 adsp_dequeue_ccb(sp)
599 	CCB *sp;
602 	if (sp == ccb_used_list) {
603 		if ((ccb_used_list = sp->otccbLink) != 0)
604 			sp->otccbLink->ccbLink = 0;
605 	} else if (sp->ccbLink) {
606 		if ((sp->ccbLink->otccbLink = sp->otccbLink) != 0)
607 			sp->otccbLink->ccbLink = sp->ccbLink;
610 	sp->otccbLink = 0;
611 	sp->ccbLink = 0;