sources/parallel/parallel_channels.c

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.
*/

/*
** INCLUDES
*/

#include "hlx/core.h"
#include "helixis_internal.h"

#if defined(HLX_BUILD_WITH_PARALLEL_THREADING)

#ifdef __cplusplus
extern "C"      {
#endif

/*
** EXTERNALS
*/

extern hlx_api gl_api;

/*
** GLOBALS
*/

static _hlx_channel_manager gl_channel_manager;

/*
** FUNCTIONS
*/

static _hlx_channel*                    _hlx_get_channel_by_hash(unsigned long id)
{
        _hlx_channel*           chan;
        struct slist_element*   it;

        it = 0;
        while (slist_get_head_and_then_next(gl_channel_manager.channels, &it))
                if (slist_get_user_data_from_element(it, (void **)&chan) && chan->hash_code == id)
                        return (chan);
        return (0);
}

HLX_CHAN_WRITE_GENERATOR(short, short, s)
HLX_CHAN_READ_GENERATOR(short, short, s)

HLX_CHAN_WRITE_GENERATOR(int, int, i)
HLX_CHAN_READ_GENERATOR(int, int, i)

HLX_CHAN_WRITE_GENERATOR(char, char, c)
HLX_CHAN_READ_GENERATOR(char, char, c)

HLX_CHAN_WRITE_GENERATOR(float, float, f)
HLX_CHAN_READ_GENERATOR(float, float, f)

HLX_CHAN_WRITE_GENERATOR(ptr, void *, p)
HLX_CHAN_READ_GENERATOR(ptr, void *, p)

hlx_channel_errors              hlx_chan_create(unsigned long id)
{
        _hlx_channel            *chan;

        chan = _hlx_get_channel_by_hash(id);
        if (chan != 0)
                return (CHAN_ERROR_ALREADY_EXISTS);
        if ((chan = gl_api.malloc_entry(sizeof(_hlx_channel))) == 0)
                return (CHAN_ERROR_MEMORY_EXHAUSTED);
        chan->hash_code = id;
        chan->status = HLX_CHAN_AVAILABLE;
        if (slist_new(&gl_channel_manager.channels, 0, 0) == 0 || slist_new_head(gl_channel_manager.channels, chan) == 0)
        {
                gl_api.free_entry(chan);
                return (EV_ERROR_MEMORY_EXHAUSTED);
        }
        return (CHAN_ERROR_SUCCESS);
}

void    _init_channel_manager(void)
{
        slist_new(&gl_channel_manager.channels, 0, 0);
}

void    _destroy_channel_manager(void)
{
        struct slist_element*   it;
        _hlx_channel*   chan;

        it = 0;
        while (slist_get_head_and_then_next(gl_channel_manager.channels, &it))
        {
                slist_get_user_data_from_element(it, (void **)&chan);
                gl_api.free_entry(chan);
        }
        slist_delete(gl_channel_manager.channels);
}

#endif /* !HLX_BUILD_WITH_PARALLEL_THREADING */

#ifdef __cplusplus
}
#endif

/*
** END OF FILE
*/