bsd/netat/adsp_Close.c

161  *		pb	a remove param block to complete when done
167 void RemoveCCB(sp, pb)		/* (CCBPtr sp, DSPPBPtr pb) */
169     struct adspcmd *pb;
180     if (pb) {
181 	pb->ioResult = 0;
182 	if (pb->ioc)		/* is this a current or queued request */
183 	    adspioc_ack(0, (gbuf_t *)pb->ioc, pb->gref);	/* current */
185 	    completepb(sp, pb);	/* queued */
188 	if (sp->opb && (pb != sp->opb)) { /* if the pb requested is not the */
189 	    pb = sp->opb;		/* waiting open pb, complete it too */
191 	    pb->ioResult = 0;
192 	    completepb(sp, pb);
265     register struct adspcmd *pb, *np;
288     while ((pb = np)) {		/* Handle all of the close/remove param blks */
289 	np = (struct adspcmd *)pb->qLink; /* Get next guy (if any) */
290 	pb->qLink = 0;
291 	pb->ioResult = err;
292 	completepb(sp, pb);
322 	        pb = (struct adspcmd *)gbuf_rptr(mp);
325 		bzero((caddr_t) pb, sizeof(struct adspcmd));
326 		pb->mp = mp;
327 		pb->csCode = dspRead;
328 		pb->ioResult = errAborted;
329 		completepb(sp, pb);		/* send fake read completion */
356 int adspClose(sp, pb)		/* (DSPPBPtr pb) */
358     register struct adspcmd *pb;
372 	pb->ioResult = errRefNum;
379     if (pb->csCode == (short)dspCLRemove) { /* Remove connection listener */
381 	    pb->ioResult = errState;
385 	RemoveCCB(sp, pb);	/* Will call completion routine */
396 	pb->ioResult = errState;
410     if (pb->csCode == (short)dspClose) {
414 	    pb->ioResult = 0;
415 	    adspioc_ack(0, (gbuf_t *)pb->ioc, pb->gref);
420 	    pb->ioResult = 0;
421 	    adspioc_ack(0, (gbuf_t *)pb->ioc, pb->gref);
425 	    pb->ioResult = errState;
447     if (pb->u.closeParams.abort || CheckOkToClose(sp)) /* going to close */
453     pb->ioResult = 1;
454     if ( (mp = gbuf_copym(pb->mp)) ) {	/* duplicate user request */
455 	    adspioc_ack(0, (gbuf_t *)pb->ioc, pb->gref); /* release user */
456 	    pb = (struct adspcmd *)gbuf_rptr(mp); /* get new parameter block */
457 	    pb->ioc = 0;
458 	    pb->mp = mp;
459 	    qAddToEnd((struct qlink **)&sp->opb, (struct qlink *)pb);	/* and save it */
461 	    pb->ioResult = 0;
462 	    adspioc_ack(0, (gbuf_t *)pb->ioc, pb->gref); /* release user, and keep no copy
490     register struct adspcmd *pb;
499         pb = (struct adspcmd *)gbuf_rptr(mp);
501 	pb->ioc = 0;
502 	pb->mp = mp;
504 	pb->csCode = dspClose;
505 	pb->ioResult = 0;
506 	completepb(sp, pb);		/* send close completion */