/*
** $VER: track.c 1.2 (20 Aug 1995)
**
** magplip.device - Parallel Line Internet Protocol
**
** Original code written by Oliver Wagner and Michael Balzer.
**
** This version has been completely reworked by Marius Gröger,
** introducing slight protocol changes. The new source is
** a lot better organized and maintainable.
**
** (C) Copyright 1993-1994 Oliver Wagner & Michael Balzer
** (C) Copyright 1995 Marius Gröger
**     All Rights Reserved
**
** $HISTORY:
**
** 05 Mar 1995 : 001.001 :  couldn't any longer stand the original, unstructured code
** 12 Feb 1995 : 001.000 :  reworked original
*/

/*F*/ /* includes */
#ifndef CLIB_EXEC_PROTOS_H
#include <clib/exec_protos.h>
#include <pragmas/exec_sysbase_pragmas.h>
#endif

#ifndef EXEC_MEMORY_H
#include <exec/memory.h>
#endif
#ifndef EXEC_LISTS_H
#include <exec/lists.h>
#endif
#ifndef EXEC_NODES_H
#include <exec/nodes.h>
#endif

#ifndef _STRING_H
#include <string.h>
#endif

#ifndef __MAGPLIP_H
#include "magplip.h"
#endif

#ifndef __DEBUG_H
#include "debug.h"
#endif

/*E*/

/*F*/ /* exports */
extern BOOL addtracktype(BASEPTR, ULONG type);
extern BOOL remtracktype(BASEPTR, ULONG type);
extern VOID dotracktype(BASEPTR, ULONG type, ULONG ps, ULONG pr, ULONG bs, ULONG br, ULONG pd);
extern BOOL gettrackrec(BASEPTR, ULONG type, APTR info);
extern VOID freetracktypes(BASEPTR);
/*E*/

/*F*/ /* statics */
static struct TrackRec *findtracktype(BASEPTR, ULONG type);
/*E*/

/*F*/ static struct TrackRec *findtracktype(BASEPTR, ULONG type)
{
   struct TrackRec * tr;

   for (tr = (struct TrackRec *) pb->pb_TrackList.lh_Head; tr->tr_Link.mln_Succ;
                                                      tr = (struct TrackRec *) tr->tr_Link.mln_Succ)
   {
      if( tr->tr_PacketType == type )
         return( tr );
   }

   return( NULL );
}
/*E*/
/*F*/ extern BOOL addtracktype(BASEPTR, ULONG type)
{
   struct TrackRec *tr;
   BOOL rv = FALSE;

   ObtainSemaphore(&pb->pb_TrackListSem);
   if (!(tr = findtracktype(pb, type)))
   {
      if (tr = AllocVec(sizeof(*tr), MEMF_CLEAR))
      {
         tr->tr_PacketType = type;
         AddTail((struct List*)&pb->pb_TrackList, (struct Node *)tr);
         rv = TRUE;
      }
   }
   ReleaseSemaphore(&pb->pb_TrackListSem);

   return rv;
}
/*E*/
/*F*/ extern BOOL remtracktype(BASEPTR, ULONG type)
{
   struct TrackRec *tr;
   BOOL rv = FALSE;

   ObtainSemaphore( &pb->pb_TrackListSem );
   if (tr = findtracktype(pb, type))
   {
      Remove((struct Node *)tr);
      FreeVec(tr);
      rv = TRUE;
   }
   ReleaseSemaphore( &pb->pb_TrackListSem );

   return rv;
}
/*E*/
/*F*/ extern VOID dotracktype(BASEPTR, ULONG type, ULONG ps, ULONG pr, ULONG bs, ULONG br, ULONG pd)
{
   struct TrackRec * tr;

   ObtainSemaphore(&pb->pb_TrackListSem);
   if (tr = findtracktype(pb, type))
   {
      tr->tr_Sana2PacketTypeStats.PacketsSent += ps;
      tr->tr_Sana2PacketTypeStats.PacketsReceived += pr;
      tr->tr_Sana2PacketTypeStats.BytesSent += bs;
      tr->tr_Sana2PacketTypeStats.BytesReceived += br;
      tr->tr_Sana2PacketTypeStats.PacketsDropped += pd;
   }
   ReleaseSemaphore(&pb->pb_TrackListSem);
}
/*E*/
/*F*/ extern BOOL gettrackrec(BASEPTR, ULONG type, APTR info)
{
   struct TrackRec * tr;
   BOOL rv = FALSE;

   ObtainSemaphoreShared( &pb->pb_TrackListSem );
   if (tr = findtracktype(pb, type))
   {
      memcpy(info, &tr->tr_Sana2PacketTypeStats, sizeof(tr->tr_Sana2PacketTypeStats));
      rv = TRUE;
   }
   ReleaseSemaphore( &pb->pb_TrackListSem );

   return rv;
}
/*E*/
/*F*/ extern VOID freetracktypes(BASEPTR)
{
   struct Node *tr;

   ObtainSemaphore(&pb->pb_TrackListSem);
   while(tr = RemHead((struct List*)&pb->pb_TrackList))
      FreeVec(tr);
   ReleaseSemaphore(&pb->pb_TrackListSem);
}
/*E*/