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
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
|
/*
(c) Copyright 2001-2009 The world wide DirectFB Open Source Community (directfb.org)
(c) Copyright 2000-2004 Convergence (integrated media) GmbH
All rights reserved.
Written by Denis Oliver Kropp <dok@directfb.org>,
Andreas Hundt <andi@fischlustig.de>,
Sven Neumann <neo@directfb.org>,
Ville Syrjälä <syrjala@sci.fi> and
Claudio Ciccani <klan@users.sf.net>.
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 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, write to the
Free Software Foundation, Inc., 59 Temple Place - Suite 330,
Boston, MA 02111-1307, USA.
*/
#ifndef __FUSION__FUSION_INTERNAL_H__
#define __FUSION__FUSION_INTERNAL_H__
#include <sys/types.h>
#include <sys/param.h>
#include <string.h>
#include <direct/list.h>
#include <fusion/build.h>
#include <fusion/fusion.h>
#include <fusion/lock.h>
#include <fusion/ref.h>
#include <fusion/shm/shm_internal.h>
#if FUSION_BUILD_MULTI
# if FUSION_BUILD_KERNEL
# include <sys/ioctl.h>
# include <linux/fusion.h>
# else
# include <fusion/protocol.h>
# endif
#endif
#define FUSION_MAX_WORLDS 8
/***************************************
* Fusion internal type declarations *
***************************************/
struct __Fusion_FusionWorldShared {
int magic;
int refs; /* Increased by the master on fork(). */
int world_index;
int world_abi;
struct timeval start_time;
DirectLink *arenas;
FusionSkirmish arenas_lock;
FusionSkirmish reactor_globals;
FusionSHMShared shm;
FusionSHMPoolShared *main_pool;
DirectLink *fusionees; /* Connected fusionees. */
FusionSkirmish fusionees_lock;
unsigned int call_ids; /* Generates call ids. */
unsigned int lock_ids; /* Generates locks ids. */
unsigned int ref_ids; /* Generates refs ids. */
unsigned int reactor_ids; /* Generates reactors ids. */
unsigned int pool_ids; /* Generates pools ids. */
void *pool_base; /* SHM pool allocation base. */
void *pool_max; /* SHM pool max address. */
};
struct __Fusion_FusionWorld {
int magic;
int refs;
FusionWorldShared *shared;
int fusion_fd;
FusionID fusion_id;
DirectThread *dispatch_loop;
bool dispatch_stop;
/*
* List of reactors with at least one local reaction attached.
*/
DirectLink *reactor_nodes;
pthread_mutex_t reactor_nodes_lock;
FusionSHM shm;
FusionForkAction fork_action;
FusionForkCallback fork_callback;
void *fusionee;
};
/*******************************************
* Fusion internal function declarations *
*******************************************/
int _fusion_fd( const FusionWorldShared *shared );
FusionID _fusion_id( const FusionWorldShared *shared );
FusionWorld *_fusion_world( const FusionWorldShared *shared );
/*
* from reactor.c
*/
void _fusion_reactor_free_all ( FusionWorld *world );
void _fusion_reactor_process_message( FusionWorld *world,
int reactor_id,
int channel,
const void *msg_data );
#if FUSION_BUILD_MULTI
/*
* from call.c
*/
void _fusion_call_process( FusionWorld *world,
int call_id,
FusionCallMessage *call );
#if FUSION_BUILD_KERNEL
/*
* from shm.c
*/
void _fusion_shmpool_process( FusionWorld *world,
int pool_id,
FusionSHMPoolMessage *msg );
#else
/*
* form fusion.c
*/
void _fusion_add_local( FusionWorld *world,
FusionRef *ref,
int add );
void _fusion_check_locals( FusionWorld *world,
FusionRef *ref );
void _fusion_remove_all_locals( FusionWorld *world,
const FusionRef *ref );
DirectResult _fusion_send_message( int fd,
const void *msg,
size_t msg_size,
struct sockaddr_un *addr );
DirectResult _fusion_recv_message( int fd,
void *msg,
size_t msg_size,
struct sockaddr_un *addr );
/*
* from ref.c
*/
DirectResult _fusion_ref_change( FusionRef *ref, int add, bool global );
#endif /* FUSION_BUILD_KERNEL */
#endif /* FUSION_BUILD_MULTI */
#endif
|
