sources/internal_includes/native/native_channels.h

Go to the documentation of this file.

/*
** Copyright 2009-2011, helixis.org
** All rights reserved.
**
** Redistribution and use in source and binary forms, with or without modification, are permitted provided
** that the following conditions are met:
**
** Redistributions of source code must retain the above copyright notice, this list of conditions and the
** following disclaimer.
**
** Redistributions in binary form must reproduce the above copyright notice, this list of conditions and
** the following disclaimer in the documentation and/or other materials provided with the distribution.
**
** Neither the name of the helixis.org nor the names of its contributors may be used to endorse or promote
** products derived from this software without specific prior written permission.
**
** THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED
** WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A
** PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR
** ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED
** TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
** HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
** NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
** POSSIBILITY OF SUCH DAMAGE.
*/

#ifndef __HLX_NATIVE_CHANNELS_H__
# define __HLX_NATIVE_CHANNELS_H__

#if !defined(HLX_BUILD_WITH_PARALLEL_THREADING)

#ifdef __cplusplus
extern "C"      {
#endif

/*
** MACROS
*/

# define HLX_CHAN_AVAILABLE             (0)
# define HLX_CHAN_FILLED                (3)

# define HLX_CHAN_WRITE_GENERATOR(name, type, union_var)        \
int             __hlx_chan_write_##name(unsigned long id, type value)   \
{       \
        hlx_list_node           *node;  \
        _hlx_channel            *chan;  \
        \
        if ((node = _hlx_get_channel_by_hash(id)) == 0) \
           return (0);  \
    chan = (_hlx_channel *)node->data;  \
        if (chan->status != HLX_CHAN_AVAILABLE) \
           return (0);  \
        chan->data.union_var = value;   \
    chan->status = HLX_CHAN_FILLED;     \
        return (1);     \
}

# define HLX_CHAN_READ_GENERATOR(name, type, union_var) \
int             __hlx_chan_read_##name(unsigned long id, type* value)   \
{       \
        hlx_list_node           *node;  \
        _hlx_channel            *chan;  \
        \
        if ((node = _hlx_get_channel_by_hash(id)) == 0) \
           return (0);  \
    chan = (_hlx_channel *)node->data;  \
    if (chan->status != HLX_CHAN_FILLED)        \
       return (0);      \
    *value = chan->data.union_var;      \
    chan->status = HLX_CHAN_AVAILABLE;  \
    return (1); \
}

/*
** TYPES
*/

typedef union
{
        char    c;
        short   s;
        int             i;
        float   f;
        void*   p;
}       _hlx_channel_data;

typedef struct
{
        _hlx_channel_data       data;
        unsigned char           status;
        unsigned long           hash_code;
}                                               _hlx_channel;

typedef struct
{
        hlx_list                        channels;
}                                               _hlx_channel_manager;

/*
** FUNCTIONS
*/

void    _init_channel_manager(void);
void    _destroy_channel_manager(void);

#ifdef __cplusplus
}
#endif

#endif /* HLX_BUILD_WITH_KERNEL_THREAD */

#endif /* !__HLX_NATIVE_CHANNELS_H__ */

/*
** END OF FILE
*/