1 [sorry for the parts in french :]
8 sock specific tcp (buffsize) inutile
19 - gras_datadesc_import_nws
22 Verifier que les messages vont pas sur des sock raw
24 - Documentation (en particulier DD et Msg)
26 - gras_datadesc_cpy -> donne la taille prise pour donner un poids aux messages
28 - callback en reception ?? (remettre les pointeurs sur fonction etc)
31 gras_ddt_new_ignored : Pas portable (taille) => virer cat?
32 Necessaire aux pointeurs sur fonction? Renomer 'void'
39 - datadesc_set_cste: Donne la valeur par defaut en reception
40 plus de transfert, ce qui est utile pour les pointeurs sur fct
42 ============================================================================
44 * while (1) { fork; exec the child, wait in father }
47 - core ok (errors, logs ; dynars, dicts, hooks, pools; config, rrdb)
48 - virtualize (linux, solaris, SG) & conditions
49 - binary representation: any type, SNWF (Sender Native Wire Format)
50 - modules (logs, manage, token ring, bw)
51 - cleanups, documentation
54 Check in autoconf that no datatype is bigger than 64, or dynar_map will
58 Dynar of type, such as ref of type
59 Generate convertors in assembler ?
65 Message declarations in a tree manner
68 Better split casual errors from programing errors.
69 The first ones should be repported to the user, the second should kill
70 the program (or, yet better, only the msg handler)
71 Allows the use of an error handler depending on the current module (ie,
72 the same philosophy than log4c using GSL's error functions)
73 Rethink the error codes. Source of inspirations are:
74 - comerr (common error reporting from ext2)
78 Several appenders; fix the setting stuff to change the appender
79 Hijack message from a given category to another for a while (to mask
80 initializations, and more)
81 Allow each process in simulation to have its own setting
85 speed up the cursors, for example using the contexts when available
86 fix multi levels dicts
89 Error handling in cbps
90 Regression tests of cbps
93 * GRAS1 * Integrer grassouillet a gras; multiplexage XML; module de comm
96 [simuler le select sur les sockets avec des threads]
97 Le plan, c'est qu'a l'ouverture d'une socket server, on cree un thread
98 charge de faire du pool blocant dessus, et des que ce thread se debloque
99 car il commence a lire qqch, il passe la main a un thread de
100 communication charge de faire la lecture.
101 Quand la lecture est finie, le thread de comm passe la main aux threads
102 d'execution (un par couleur).
104 Voici comment faire le coeur du truc [dixit Olivier]:
105 Une liste est utilisee pour stocker ce que le thread de comm a le droit
106 de lire. Elle est protegee par mutex pour eviter les acces concurents.
107 c'est la "liste de lecture"
108 Une semaphore "de lecture" est utilisee pour permettre aux threads
109 servants des sockets de prevenir le thread de comm qu'ils ont qqch
111 Dans la liste de lecture, on place les messages en cours de creation, et
112 un ptit mutex pour que le thread de comm dise aux threads servants de
113 retourner ecouter la socket car il a fini
114 Chaque couleur a sa file de callback a appeller, proteger par semaphore
115 et un mutex comme pour la file de lecture
118 initialisation de toutes les semaphore a 0
119 comm: sem_P(semaphore lecture)
120 couleur: sem_P(semaphore de la couleur correspondante)
121 servant: read (1) sur la socket
125 1) le read debloque (c'est la version de gras, utilisee pour multiplexe
126 sur le XML, ou sur les differentes versions de gras/de pilote reseau)
127 2) Allocation du message vide pour contenir ce qui s'annonce
128 3) initialisation du mutex du message_instance a 0 (verrouille)
129 4) placement du message instance dans la file (prise de mutex,
130 placement, lachage de mutex)
132 6) mutex_lock sur le mutex_verrouille
134 7) quand on revient, on rebloque un read(1), et on recommence
137 1) on se reveille quand la semaphore se libere (etape 6 des servants)
138 2) prise d'une tache dans la file (protegee par semaphore)
139 3) lecture de l'instance de message
140 4) lache le mutex dans l'instance pour liberer le servant
141 5) pose le message pret dans la file de la couleur correpondant au
142 premier callback de la pile pour ces {messageID x version} et
143 augmente le semaphore correspondant.
144 6) se rebloque sur le semaphore de lecture et recommence
147 1) on se reveille quand quelqu'un a pose qqch dans sa file des messages
149 2) on le retire de la file
150 3) on acquiere le mutex d'execution de sa couleur (pour les callbacks
152 4) on execute le callback qu'il faut
153 5) on lache le mutex de sa couleur
154 Si le callback annonce avoir mange le message
155 a) on libere le message (le payload doit avoir ete libere par
157 b) on decremente le TTL du callback, et on le vire si c'etait pas un
158 callback infini et qu'il arrive en fin de vie
160 a) on place le message dans la liste des messages de la couleur du
161 suivant dans la pile des callback
162 6) On se rendort sur le semaphore de sa couleur et recommence
164 Emission d'un message:
165 A faire. Le thread de comm peut faire ceci, ou on peut faire un nouveau
166 thread de comm pour cela.
168 Fermeture d'une socket client:
169 Probleme: faut tuer le thread servant.
170 Solution pour l'instant: fermer la socket depuis ailleurs.
171 Solution si ca marche pas (ou pas partout): Les servants font des
172 selects sur un pool {leur socket x un pipe fait pour}
173 Quand qqch arrive sur le pipe, c'est le signal du suicide.
175 [Conversions inter-architectures]
176 Marquer les padding bytes explicitement aux structures (juste le sizeof
178 Marquer les offsetof des fields explicitement a l'ajout.
179 Prevoir tous les encoding pour les types elementaires
180 [taille, sexe, signess[non, a un, a deux]]
181 plus les flotants, justifiant un traitement a part
182 Tester avec autoconf les encodings sur l'archi courante
183 Trouver un moyen de convertir un encoding en un autre (si possible par
185 Generer ces convertors en assembleur a chaud, puisqu'on a rien de mieux a
186 foutre de notre temps
189 Tout comme c'est dit dans les articles
192 Gerer les typedefs (necessite de l'aide de grassouillet)
194 Faut des annotations pour dire si c'est :
196 - un tableau dont la longueur est ailleurs dans la struct
198 Ca peut se faire soit avec des commentaires, soit avec des macros se
199 reecrivant a rien dans la vraie vie, et parsee. Mais le risque est que
200 ces macros soient reecrites avant d'etre passee a mon bordel, selon les
202 Gerer les unions => specifier des annotations, mais j'y crois pas
205 Gerer les types struct, union et enum anonymes au milieu d'un autre bloc de
207 Verifier que "char"="signed char" sur toutes les archis
209 Renomer gs_parse_tok_num en gs_parse_token
212 Check struct { struct { int a } b; }
215 Gerer les typedefs pour aliaser un type sur un autre
216 Merger gs_type_union_append_field et gs_type_struc_append_field si possible.
218 gs_type_copy/gs_type_free
219 A quoi sert le champ name de gs_type_struct_append_field ?
220 Ca plante bizarement si on met une structure n'existant pas dans le
222 gs_type_dump, nardin, comment voir ce qui se passe sinon ??
225 Faire toutes les modifs aux Utils listees plus haut
226 Simplifier l'envoi de dynar et dico
227 Mettre les mutex et semaphores dans les dynar directement
228 Tenter (politiquement) le passage a GPL, pour voler du code.
234 GRAS double (ou encore "GRAS too" ou "too GRAS"):
235 - Priorite des messages
236 - Outils de visu pour ce qui se passe dans le simulo
237 - Outils de visu/deployement/management pour RL
240 - outils mathematiques pour dire des choses sur la validite du protocole