Subversion Repositories shark

/*

 * Project: S.Ha.R.K.

 *

 * Coordinators:

 *   Giorgio Buttazzo    <giorgio@sssup.it>

 *   Paolo Gai           <pj@gandalf.sssup.it>

 *

 * Authors     :

 *   Giacomo Guidi       <giacomo@gandalf.sssup.it>

 *

 * ReTiS Lab (Scuola Superiore S.Anna - Pisa - Italy)

 *

 * http://www.sssup.it

 * http://retis.sssup.it

 * http://shark.sssup.it

 */

#ifndef __TRACER_H__

#define __TRACER_H__

#ifdef __OLD_TRACER__

#include <ll/sys/types.h>

#include "types.h"

#include "trace.h"

#include "FTrace.h"

#define TRACER_LOGEVENT oldtrace

extern int (*trc_register_eventclass)

     (int class,int num,int(*func)(trc_event_t *, int event, void *ptr));

extern void (*trc_logevent)(int event, void *ptr);

extern int (*trc_resume)(void);

extern int (*trc_suspend)(void);

#define NOT_DEFINED 0xFF

extern __inline__ void oldtrace(BYTE type, BYTE flag, DWORD par1, DWORD par2)

{

  static int oldtype;

  static int oldpar;

  extern BYTE conv[256]; // Conversion table: ctable.c

  BYTE ttype = 0;

  ttype = type & 0x0F;

  type = type >> 4;

  type |= (ttype << 4);

  oldtype = conv[type];

  if (oldtype != NOT_DEFINED) trc_logevent(oldtype,&oldpar);

}

#else

#ifdef __NEW_TRACER__

#include <ll/sys/types.h>

#include <ll/i386/hw-instr.h>

#include <kernel/kern.h>

#include "FTrace.h"

#define TRACER_NO_OUTPUT  0

#define TRACER_UDP_OUTPUT 1

#define TRACER_LOGEVENT fast_logevent

int tracer_initialize(int MemorySize);

void tracer_enable();

void tracer_disable();

void tracer_print_statistics();

int tracer_send_logged_events(int NumberOfEvents);

void tracer_flush_sent_events();

//UDP

int tracer_init_udp(int flag, char *local_ip, char *target_ip);

int tracer_create_udp_task(TASK_MODEL *m, int EventsForPeriod);

#define TRACER_SERIALIZE

/* Save bytes => 1(type) + 4(tsc_high) + 4(tsc_low) + 1(size)

                if (flag & 1) + 4(par1)

                if (flag & 3) + 4(par2)

 * Return 0 -> Success

 * Return 1 -> Inactive

 * Return 2 -> Error

 */

extern __inline__ int fast_logevent(BYTE type, BYTE flag, DWORD par1, DWORD par2)

{

  extern void *StartTracerBuffer;

  extern void *EndTracerBuffer;

  extern void *LastBeforeEndTracerBuffer;

  extern void *CurrentTracerBuffer;

  extern void *FirstTracerBuffer;

  extern int TracerActive;

  extern unsigned long long TracerEventsRecorded;

  extern unsigned int TracerEventsPresent;

  SYS_FLAGS f;

  DWORD tsc_low, tsc_high;

  BYTE size = 10;

  f = ll_fsave();

  if (!TracerActive) {

    ll_frestore(f);

    return 1;

  }

  #ifdef TRACER_SERIALIZE

    __asm__("xorl %%eax,%%eax\n\t"

            "cpuid\n\t"

            "rdtsc\n\t"

            :"=a" (tsc_low), "=d" (tsc_high)

            :

            :"ebx","ecx");

  #else

    __asm__("rdtsc\n\t"

            :"=a" (tsc_low), "=d" (tsc_high)

            ::);

  #endif

  if (flag & 1) size += 4;

  if (flag & 3) size += 4;

  // Adjust FirstTracerBuffer

  if (FirstTracerBuffer >= CurrentTracerBuffer && TracerEventsPresent != 0) {

    while ((CurrentTracerBuffer + size - 1) >= FirstTracerBuffer &&

            FirstTracerBuffer != StartTracerBuffer) {

      FirstTracerBuffer += *(BYTE *)(FirstTracerBuffer + 9);

      if (FirstTracerBuffer >= LastBeforeEndTracerBuffer) FirstTracerBuffer = StartTracerBuffer;

    }

  } else {

    TracerEventsPresent++;

  }

  // Check if we overcome EndTracerBuffer

  if ((CurrentTracerBuffer + size - 1) > EndTracerBuffer) {

    //Cyclical Buffer implementation

    LastBeforeEndTracerBuffer = CurrentTracerBuffer;

    CurrentTracerBuffer = StartTracerBuffer;

    //Set the First Event

    while ((CurrentTracerBuffer + size - 1) >= FirstTracerBuffer) {

      FirstTracerBuffer += *(BYTE *)(FirstTracerBuffer + 9);

      if (FirstTracerBuffer >= LastBeforeEndTracerBuffer) FirstTracerBuffer = StartTracerBuffer;

    }

  }

  // Add the new event

  *(BYTE *)CurrentTracerBuffer = type;

  CurrentTracerBuffer++;

  *(DWORD *)(CurrentTracerBuffer) = tsc_high;

  CurrentTracerBuffer+=4;

  *(DWORD *)(CurrentTracerBuffer) = tsc_low;

  CurrentTracerBuffer+=4;

  *(BYTE *)(CurrentTracerBuffer) = size;

  CurrentTracerBuffer++;

  if (flag & 1) {

    *(DWORD *)(CurrentTracerBuffer) = par1;

    CurrentTracerBuffer+=4;

  }

  if (flag & 3) {

    *(DWORD *)(CurrentTracerBuffer) = par2;

    CurrentTracerBuffer+=4;

  }

  if (CurrentTracerBuffer > EndTracerBuffer) {

    ll_frestore(f);

    return 2;

  }

  TracerEventsRecorded++;

  ll_frestore(f);

  return 0;

}

#else

#define TRACER_LOGEVENT(a,b,c,d)

#endif

#endif

#endif