#include <sys/errno.h>
#include <sys/types.h>
#include <sys/param.h>
#include <machine/spl.h>
#include <sys/systm.h>
#include <sys/kernel.h>
#include <sys/proc.h>
#include <sys/filedesc.h>
#include <sys/fcntl.h>
#include <sys/mbuf.h>
#include <sys/socket.h>
#include <sys/time.h>
#include <netat/sysglue.h>
#include <netat/appletalk.h>
#include <netat/at_pcb.h>
#include <netat/debug.h>
#include <netat/adsp.h>
#include <netat/adsp_internal.h>
int RXFReset(sp, f)
CCBPtr sp;
ADSP_FRAMEPtr f;
{
unsigned int pktFirstByteSeq;
unsigned int hi;
register gbuf_t *mp;
register struct adspcmd *pb;
int s;
ATDISABLE(s, sp->lock);
pktFirstByteSeq = netdw(UAL_VALUE(f->pktFirstByteSeq));
hi = sp->recvSeq + CalcRecvWdw(sp);
if (BETWEEN(sp->recvSeq, pktFirstByteSeq, hi))
{
sp->recvSeq = pktFirstByteSeq;
while (mp = sp->rbuf_mb) {
sp->rbuf_mb = gbuf_next(mp);
gbuf_freem(mp);
}
if (sp->crbuf_mb) {
gbuf_freem(sp->crbuf_mb);
sp->crbuf_mb = 0;
}
sp->rData = 0;
sp->rbufFull = 0;
sp->userFlags |= eFwdReset;
mp = gbuf_alloc(sizeof(struct adspcmd), PRI_HI);
pb = (struct adspcmd *)gbuf_rptr(mp);
gbuf_winc(mp,sizeof(struct adspcmd));
pb->ioc = 0;
pb->mp = mp;
pb->csCode = dspReset;
pb->ioResult = 0;
completepb(sp, pb);
sp->userFlags &= ~eFwdReset;
}
if (LTE(pktFirstByteSeq, hi)) {
sp->sendCtl |= B_CTL_FRESETACK;
sp->callSend = 1;
}
ATENABLE(s, sp->lock);
return 0;
}
int RXFResetAck(sp, f)
CCBPtr sp;
ADSP_FRAMEPtr f;
{
unsigned int PktNextRecvSeq;
int s;
if (sp->frpb == 0)
return 1;
ATDISABLE(s, sp->lock);
PktNextRecvSeq = netdw(UAL_VALUE(f->pktNextRecvSeq));
if (BETWEEN(sp->sendSeq, PktNextRecvSeq, sp->sendWdwSeq+1)) {
struct adspcmd *pb;
RemoveTimerElem(&adspGlobal.fastTimers, &sp->ResetTimer);
pb = sp->frpb;
sp->frpb = (struct adspcmd *)pb->qLink;
pb->ioResult = 0;
completepb(sp, pb);
if (sp->state == sClosing)
CheckOkToClose(sp);
if (sp->frpb)
{
sp->callSend = 1;
sp->sendCtl |= B_CTL_FRESET;
}
}
ATENABLE(s, sp->lock);
return 0;
}
int adspReset(sp, pb)
CCBPtr sp;
struct adspcmd *pb;
{
int s;
register gbuf_t *mp;
register struct adspcmd *rpb;
if (sp == 0) {
pb->ioResult = errRefNum;
return EINVAL;
}
if (sp->state != sOpen) {
pb->ioResult = errState;
return EINVAL;
}
ATDISABLE(s, sp->lock);
while (mp = sp->sbuf_mb) {
sp->sbuf_mb = gbuf_next(mp);
gbuf_freem(mp);
}
if (sp->csbuf_mb) {
gbuf_freem(sp->csbuf_mb);
sp->csbuf_mb = 0;
}
sp->sData = 0;
sp->writeFlush = 0;
sp->sendCtl |= B_CTL_FRESET;
sp->firstRtmtSeq = sp->sendSeq;
if (mp = gbuf_copym(pb->mp)) {
adspioc_ack(0, pb->ioc, pb->gref);
rpb = (struct adspcmd *)gbuf_rptr(mp);
rpb->ioc = 0;
rpb->mp = mp;
qAddToEnd(&sp->frpb, rpb);
} else {
adspioc_ack(0, pb->ioc, pb->gref);
}
ATENABLE(s, sp->lock);
CheckSend(sp);
return STR_IGNORE;
}