OTF2_OpenMP_Locks.h

Go to the documentation of this file.

/*
 * This file is part of the Score-P software (http://www.score-p.org)
 *
 * Copyright (c) 2014,
 * Technische Universitaet Dresden, Germany
 *
 * This software may be modified and distributed under the terms of
 * a BSD-style license.  See the COPYING file in the package base
 * directory for details.
 *
 */



#ifndef OTF2_OPENMP_LOCKS_H
#define OTF2_OPENMP_LOCKS_H


#include <stdlib.h>


#include <otf2/otf2.h>


#include <omp.h>


static OTF2_ErrorCode
OTF2_OpenMP_Archive_SetLockingCallbacks( OTF2_Archive* archive );


static OTF2_ErrorCode
OTF2_OpenMP_Reader_SetLockingCallbacks( OTF2_Reader* reader );


struct OTF2_LockObject
{
    omp_lock_t lock;
};


static OTF2_CallbackCode
otf2_openmp_lock_create( void*      userData,
                         OTF2_Lock* lock )
{
    if ( !lock )
    {
        return OTF2_CALLBACK_ERROR;
    }

    *lock = (  OTF2_Lock )malloc( sizeof( **lock ) );
    if ( !*lock )
    {
        return OTF2_CALLBACK_ERROR;
    }

    omp_init_lock( &( *lock )->lock );

    return OTF2_CALLBACK_SUCCESS;
}


static OTF2_CallbackCode
otf2_openmp_lock_destroy( void*     userData,
                          OTF2_Lock lock )
{
    if ( !lock )
    {
        return OTF2_CALLBACK_ERROR;
    }

    omp_destroy_lock( &lock->lock );

    return OTF2_CALLBACK_SUCCESS;
}


static OTF2_CallbackCode
otf2_openmp_lock_lock( void*     userData,
                       OTF2_Lock lock )
{
    if ( !lock )
    {
        return OTF2_CALLBACK_ERROR;
    }

    omp_set_lock( &lock->lock );

    return OTF2_CALLBACK_SUCCESS;
}


static OTF2_CallbackCode
otf2_openmp_lock_unlock( void*     userData,
                         OTF2_Lock lock )
{
    if ( !lock )
    {
        return OTF2_CALLBACK_ERROR;
    }

    omp_unset_lock( &lock->lock );

    return OTF2_CALLBACK_SUCCESS;
}


static const OTF2_LockingCallbacks otf2_openmp_locking_callbacks =
{
    NULL,
    otf2_openmp_lock_create,
    otf2_openmp_lock_destroy,
    otf2_openmp_lock_lock,
    otf2_openmp_lock_unlock
};


static OTF2_ErrorCode
OTF2_OpenMP_Archive_SetLockingCallbacks( OTF2_Archive* archive )
{
    ( void )OTF2_OpenMP_Reader_SetLockingCallbacks;

    if ( !archive )
    {
        return OTF2_ERROR_INVALID_ARGUMENT;
    }

    return OTF2_Archive_SetLockingCallbacks( archive,
                                             &otf2_openmp_locking_callbacks,
                                             NULL );
}


static OTF2_ErrorCode
OTF2_OpenMP_Reader_SetLockingCallbacks( OTF2_Reader* reader )
{
    ( void )OTF2_OpenMP_Archive_SetLockingCallbacks;

    if ( !reader )
    {
        return OTF2_ERROR_INVALID_ARGUMENT;
    }

    return OTF2_Reader_SetLockingCallbacks( reader,
                                            &otf2_openmp_locking_callbacks,
                                            NULL );
}


#endif /* OTF2_OPENMP_LOCKS_H */