bsd/netat/adsp.c

64     register CCBPtr sp;
72     sp = (CCBPtr)gbuf_rptr(((gbuf_t *)gref->info));
74     sp->pid = gref->pid; /* save the caller process pointer */
75     sp->gref = gref;		/* save a back pointer to the WRITE queue */
76     sp->sp_mp = ccb_mp;		/* and its message block */
84     register CCBPtr sp;
87 	sp = (CCBPtr)gbuf_rptr(((gbuf_t *)gref->info));
91 	if (sp->state == sPassive || sp->state == sClosed ||
92 	    sp->state == sOpening || sp->state == sListening) {
93 	    if (sp->state == sListening)
94 		CompleteQueue(&sp->opb, errAborted);
95 	    sp->removing = 1;	/* Prevent allowing another dspClose. */
96 	    DoClose(sp, errAborted, 0); /* will remove CCB */
99 	    sp->state = sClosing;
102 	if (CheckOkToClose(sp)) { /* going to close */
103 	    sp->sendCtl = B_CTL_CLOSE; /* Send close advice */
105 		CheckSend(sp);	/* try one more time to send out data */
106 		if (sp->state != sClosed)
107 		    sp->sendCtl = B_CTL_CLOSE; /* Setup to send close advice */
109 	CheckSend(sp);		/* and force out the close */
110 	    sp->removing = 1;	/* Prevent allowing another dspClose. */
111 	    sp->state = sClosed;
112 	    DoClose(sp, errAborted, 0);  /* to closed and remove CCB */
128 	void *sp;
143 		sp = (void *)gbuf_rptr(((gbuf_t *)gref->info));
146 				if ((error = adspWrite(sp, ap)))
150 				if ((error = adspAttention(sp, (CCBPtr)ap)))
181 		sp = (void *)gbuf_rptr(((gbuf_t *)gref->info));
185 				ap->socket = ((CCBPtr)sp)->localSocket;
188 					if (adspDeassignSocket((CCBPtr)sp) >= 0)
198 				if ((error = adspInit(sp, ap)) == 0) {
203 					error = adspOpen(sp, ap);
208 					error = adspCLListen(sp, ap);
217 				if ((error = adspClose(sp, ap))) {
224 				error = adspClose(sp, ap);
229 				if ((error = adspCLDeny(sp, (CCBPtr)ap))) {
235 				if ((error = adspStatus(sp, ap))) {
241 				if ((error = adspRead(sp, ap))) {
247 				if ((error = adspReadAttention((CCBPtr)sp, ap))) {
253 				if ((error = adspOptions(sp, ap))) {
259 				if ((error = adspReset(sp, ap))) {
265 				if ((error = adspNewCID(sp, ap))) {
314  *      ret_status = adsp_sendddp(q, sp, mp, length, dstnetaddr, ddptype);
317  *	sp		Caller stream pointer
333 adsp_sendddp(sp, mp, length, dstnetaddr, ddptype)
334    CCBPtr sp;
360    if (sp) {
361 	if (sp->useCheckSum)
367    ddp->ddpx_source = sp ? sp->localSocket : ddp->ddpx_dest;
381 	__unused CCBPtr sp)
385     pidsig(sp->pid, SIGIO);
390     __unused CCBPtr sp)
393     pidsig(sp->pid, SIGURG);