Posix_Wrapp.c

Go to the documentation of this file.

/* ############################ MALP License ############################## */
/* # Fri Jan 18 14:00:00 CET 2013                                         # */
/* # Copyright or (C) or Copr. Commissariat a l'Energie Atomique          # */
/* #                                                                      # */
/* # This software is governed by the CeCILL-C license under French law   # */
/* # and abiding by the rules of distribution of free software.  You can  # */
/* # use, modify and/ or redistribute the software under the terms of     # */
/* # the CeCILL-C license as circulated by CEA, CNRS and INRIA at the     # */
/* # following URL http://www.cecill.info.                                # */
/* #                                                                      # */
/* # The fact that you are presently reading this means that you have     # */
/* # had knowledge of the CeCILL-C license and that you accept its        # */
/* # terms.                                                               # */
/* #                                                                      # */
/* # Authors:                                                             # */
/* #   - BESNARD Jean-Baptiste jean-baptiste.besnard@cea.fr               # */
/* #                                                                      # */
/* ######################################################################## */
#include "Posix_Wrapp.h"

#define _GNU_SOURCE
#include <getopt.h>


#include "Timer.h"
#include "Event_Desc.h"
#include "Event_Pack.h"
#include "VMPI.h"
#include "Stream_MGR.h"
#include "Posix_Profile.h"
#include "MALP_Config.h"

#include <stdarg.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>


/* Interception table */
union function_table_elem Tracelib_symbol_table[T_POSIX_COUNT];

static int posix_wrap_gate = 0;

void Wrapp_enable()
{
        posix_wrap_gate = 1;
}


void Wrapp_disable()
{
        posix_wrap_gate = 0;
}

void ___TEST_LOAD_SYMBOL( Wrapped_symbol symb, const char * const symbol )
{
        if( Tracelib_symbol_table[ symb ].p == NULL )
        {
                Tracelib_symbol_table[ symb ].p =  dlsym( RTLD_NEXT , symbol ); 
                if( Tracelib_symbol_table[ symb ].p == NULL )
                {
                        return;
                }
        }
}



void Posix_Wrapp_init()
{
        TEST_LOAD_SYMBOL(calloc);
        POSIX_profile_init();
        
        int i;
        
        for( i = 0 ; i < T_POSIX_COUNT ; i++ )
        {
                ___TEST_LOAD_SYMBOL( i, Wrapped_symbol_names[i] );
        }
        
}



static inline void Wrapp_Format( struct MALP_Trace_Event * event, Wrapped_symbol s, uint64_t start  , uint64_t  duration, int64_t size, void * ptr )
{
        MALP_Trace_Event_fill( event, MALP_EVENT_WRAPPED, start, duration );

        event->event.wrapped_event.type = s;
        event->event.wrapped_event.size = size;
        event->event.wrapped_event.ptr = ptr;

}


static inline void Wrap_Submit( struct MALP_Trace_Event * event )
{
        if( (event->type == MALP_EVENT_NONE) || !Stream_desc_get() )
                return;

        Event_Packer_push(event);
}

static inline void Wrapp_OTF_enter( uint64_t timestamp, Wrapped_symbol symbol )
{
        /********************************/
        /* EMIT OTF ENTER              */
        /********************************/
        
        struct MALP_Trace_Event otf_event;

        uint64_t _begin =  Timer_tsc ();

        MALP_Trace_Event_fill( &otf_event, MALP_EVENT_OTF, timestamp, 0);
        OTF_Event_forge( &otf_event, OTF_EVENT_ENTER,
                                         MALP_EVENT_WRAPPED, symbol );
        Wrap_Submit(&otf_event);
}

static inline void Wrapp_OTF_leave( uint64_t end, uint64_t start, Wrapped_symbol symbol )
{
        /********************************/
        /* EMIT OTF LEAVE               */
        /********************************/
        
        struct MALP_Trace_Event otf_event;

        uint64_t _begin =  Timer_tsc ();

        MALP_Trace_Event_fill( &otf_event, MALP_EVENT_OTF, end, end - start);
        OTF_Event_forge( &otf_event, OTF_EVENT_LEAVE,
                                         MALP_EVENT_WRAPPED, symbol );
        Wrap_Submit(&otf_event);        
}