+++ /dev/null
-/*
- * Copyright (c) 2000 Apple Computer, Inc. All rights reserved.
- *
- * @APPLE_OSREFERENCE_LICENSE_HEADER_START@
- *
- * This file contains Original Code and/or Modifications of Original Code
- * as defined in and that are subject to the Apple Public Source License
- * Version 2.0 (the 'License'). You may not use this file except in
- * compliance with the License. The rights granted to you under the License
- * may not be used to create, or enable the creation or redistribution of,
- * unlawful or unlicensed copies of an Apple operating system, or to
- * circumvent, violate, or enable the circumvention or violation of, any
- * terms of an Apple operating system software license agreement.
- *
- * Please obtain a copy of the License at
- * http://www.opensource.apple.com/apsl/ and read it before using this file.
- *
- * The Original Code and all software distributed under the License are
- * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
- * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
- * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
- * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
- * Please see the License for the specific language governing rights and
- * limitations under the License.
- *
- * @APPLE_OSREFERENCE_LICENSE_HEADER_END@
- */
-/*
- * Copyright (c) 1990, 1996-1998 Apple Computer, Inc.
- * All Rights Reserved.
- */
-
-/*
- * Timer.c
- *
- * From v01.12 06/22/90 mbs
- * Modified for MP, 1996 by Tuyen Nguyen
- * Modified, April 9, 1997 by Tuyen Nguyen for MacOSX.
- */
-
-#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 <net/if.h>
-
-#include <netat/sysglue.h>
-#include <netat/appletalk.h>
-#include <netat/at_pcb.h>
-#include <netat/at_var.h>
-#include <netat/debug.h>
-#include <netat/adsp.h>
-#include <netat/adsp_internal.h>
-
-
-/*
- * TrashSession
- *
- * Cleanly abort a session that might be open. Called if probe timer expires,
- * or from AppleTalk event handler (close or network gone away)
- *
- * Only call if the session is active (I.e. not for closed or listeners)
- *
- * INPUTS:
- * session pointer
- * OUTPUTS:
- * none
- */
-void TrashSession(CCBPtr);
-
-void TrashSession(sp) /* (CCBPtr sp) */
- CCBPtr sp;
-{
-
- sp->userFlags |= eTearDown;
- sp->removing = 1;
- sp->state = sClosed;
-
- DoClose(sp, errAborted, 1);
-}
-
-
-/*
- * DoTimerElem
- *
- * INPUTS:
- *
- * OUTPUTS:
- *
- */
-void DoTimerElem(TimerElemPtr);
-
-void DoTimerElem(t) /* (TimerElemPtr t) */
- TimerElemPtr t;
-{
- CCBPtr sp;
-
- sp = (CCBPtr)((Ptr)t - t->type); /* Recover stream pointer for this guy */
-
- if (t->type == kFlushTimerType) { /* flush write data time just fired */
- if (sp->sData) { /* If there's any data, flush it. */
- sp->writeFlush = 1;
- goto send;
- }
- } else if (t->type == kRetryTimerType) {
- if (sp->waitingAck) {
-
- sp->waitingAck = 0;
- sp->sendSeq = sp->firstRtmtSeq;
- sp->pktSendCnt = 0;
- sp->resentData = 1; /* Had to resend data */
- sp->noXmitFlow = 1; /* Don't incr. max packets. */
-
- if ((sp->pktSendMax /= 2) == 0) /* Back off on max # packets
- * sent */
- sp->pktSendMax = 1;
-
- if ((sp->roundTrip *= 2) > sp->probeInterval)
- sp->roundTrip = sp->probeInterval;
- sp->rtmtInterval = sp->roundTrip + ((short)2 *
- (short)sp->deviation);
- goto send;
- }
- } else if (t->type == kAttnTimerType) {
- if (sp->sapb) { /* Unacknowledged attn pkt */
- sp->sendAttnData = 1;
- goto send;
- }
- } else if (t->type == kResetTimerType) {
- if (sp->frpb) { /* Unacknowledged forward reset */
- sp->sendCtl |= B_CTL_FRESET;
- goto send;
- }
- } else if (t->type == kProbeTimerType) {
- if (sp->state == sOpen || sp->state == sClosing) {
- if (--sp->probeCntr == 0) { /* Connection died */
- TrashSession(sp);
- return;
- } else {
- InsertTimerElem(&adspGlobal.slowTimers, &sp->ProbeTimer,
- sp->probeInterval);
- sp->sendCtl |= B_CTL_PROBE;
- goto send;
- }
- } else if (sp->state == sOpening) {
- if ((sp->openState == O_STATE_OPENWAIT) ||
- (sp->openState == O_STATE_ESTABLISHED))
- {
- if (--sp->openRetrys == 0) { /* Oops, didn't open */
- sp->state = sClosed;
- DoClose(sp, errOpening, 1);
- return;
- } /* open failed */
- else /* Send packet again */
- {
- sp->sendCtl |= (sp->openState == O_STATE_OPENWAIT) ?
- B_CTL_OREQ : B_CTL_OREQACK;
- goto send;
- }
- } /* we're opening */
- }
- }
-
- else {
- dPrintf(D_M_ADSP, D_L_ERROR, ("DoTimerElem:Unknown timer type!\n"));
- }
-
- return;
-
-send:
- CheckSend(sp);
-}
-
-void TimerTick_funnel(void *arg);
-
-void TimerTick_funnel(__unused void *arg)
-{
- atalk_lock();
- TimerTick();
- atalk_unlock();
-}
-
-static int StopTimer;
-
-/*
- * TimerTick
- *
- * Called 6 times per second
- * INPUTS:
- *
- * OUTPUTS:
- *
- */
-void TimerTick() /* (void) */
-{
-
- if (StopTimer) {
- return;
- }
- TimerQueueTick(&adspGlobal.slowTimers);
- TimerQueueTick(&adspGlobal.fastTimers);
- timeout(TimerTick_funnel, (caddr_t)0, HZ/6);
-}
-
-void TimerStop()
-{
- StopTimer = 1;
- untimeout(TimerTick_funnel, (caddr_t) 0);
-}
projects / apple / xnu.git / blobdiff