summaryrefslogtreecommitdiffstats
path: root/src/lib/eiotas_spin.c
blob: 195b772893ebe630c6d8517c386dd1435fa343ff (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
/* EIOTAS
 * Copyright (C) 2012 Jérémy Zurcher
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 *
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library;
 * if not, see <http://www.gnu.org/licenses/>.
 */

#include "eiotas_spin.h"
#include "eiotas_iota.h"
#include "eiotas_particle.h"
#include "eiotas_private.h"

EAPI Eiotas_Spin* eiotas_spin_add(const char* name, unsigned int step)
{
    BUILD_INSTANCE(Eiotas_Spin,spin);

    INIT_IOTA(&spin->room.iota,name,NULL,EIOTAS_TYPE_SPIN);

    spin->room.links = NULL;    /* not used */
    spin->room.children = eina_hash_stringshared_new((Eina_Free_Cb)&eiotas_iota_free);
    spin->free_particles = eina_array_new(step);
    spin->sys_fifo = NULL;
    spin->app_fifo = NULL;

    return spin;
}

EAPI void eiotas_spin_free(Eiotas_Spin *spin)
{
    unsigned int        i;
    Eiotas_Particle     *particle;
    Eina_Array_Iterator iterator;
    Eina_Inlist         *list;

    DBG("Spin free 0x%X",PRINTPTR(spin));

    eiotas_iota_desinit(&spin->room.iota);
    eina_hash_free(spin->room.children);
    EINA_ARRAY_ITER_NEXT(spin->free_particles, i, particle, iterator) eiotas_particle_free(particle);
    eina_array_free(spin->free_particles);
    EINA_INLIST_FOREACH_SAFE(spin->sys_fifo, list,particle) eiotas_particle_free(particle);
    EINA_INLIST_FOREACH_SAFE(spin->app_fifo, list,particle) eiotas_particle_free(particle);

    free(spin);
}

EAPI Eiotas_Particle* eiotas_spin_require_particle(Eiotas_Spin *spin)
{
    Eiotas_Particle *particle;
    if(eina_array_count(spin->free_particles)>0) {
        particle = eina_array_pop(spin->free_particles);
    } else {
        particle = (Eiotas_Particle*)eiotas_particle_alloc();
    }
    return particle;
}

EAPI void eiotas_spin_release_particle(Eiotas_Spin *spin, Eiotas_Particle *particle)
{
    // TODO particle->reset();
    eina_array_push(spin->free_particles,particle);
}

EAPI void eiotas_spin_send_particle(Eiotas_Spin *spin, Eiotas_Particle *particle, Eina_Bool system)
{
    if(system) {
        spin->sys_fifo = eina_inlist_append(spin->sys_fifo,EINA_INLIST_GET(particle));
    } else {
        spin->app_fifo = eina_inlist_append(spin->app_fifo,EINA_INLIST_GET(particle));
    }
}