Data_Entry.h

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               # */
/* #                                                                      # */
/* ######################################################################## */
#ifndef DATA_ENTRY_H
#define DATA_ENTRY_H


#ifdef __cplusplus
  extern "C"
  {
#endif

#include <stddef.h>
#include "CRC64.h"
#include "Chained_List.h"
#include "Spinlock.h"

struct Data_entry
{
        uint64_t key;           
        uint64_t ref_count;     
        MALP_Spinlock lock;     
        short been_resubmitted; 
        size_t size;            
        char payload[0];        
};

struct Data_entry * Data_entry_init( uint64_t key, void *payload, size_t size );

struct Data_entry * Data_entry_clone( struct Data_entry *de );

void Data_entry_release( struct Data_entry *de );

static inline void Data_entry_reset_ref_count( struct Data_entry *de )
{
        MALP_Spinlock_lock( &de->lock );
        {
                de->ref_count = 0;
        }
        MALP_Spinlock_unlock( &de->lock );
}

static inline uint64_t Data_entry_get_ref_count( struct Data_entry *de )
{
        uint64_t ret;
        MALP_Spinlock_lock( &de->lock );
        {
                ret = de->ref_count;
        }
        MALP_Spinlock_unlock( &de->lock );

        return ret;
}

static inline void Data_entry_inc_ref_count( struct Data_entry *de, uint64_t val)
{
        MALP_Spinlock_lock( &de->lock );
        {
                de->ref_count+= val;
        }
        MALP_Spinlock_unlock( &de->lock );
}

static inline uint64_t Data_entry_dec_ref_count( struct Data_entry *de)
{
        uint64_t ret = 0;
        MALP_Spinlock_lock( &de->lock );
        {
                ret = --de->ref_count;
        }
        MALP_Spinlock_unlock( &de->lock );
        return ret;
}

static inline uint64_t Data_entry_get_key(struct Data_entry *de)
{
        return de->key;
}

static inline size_t Data_entry_get_payload_size( struct Data_entry *de )
{
        return de->size;
}

static inline void *Data_entry_get_payload( struct Data_entry *de )
{
        return (void *)de->payload;
}


#ifdef __cplusplus
  }
#endif

#endif