Mercurial > hg > Members > kono > Cerium
annotate Renderer/Test/dynamic_create.cc @ 576:cc989924f469
minor fix
| author | Shinji KONO <kono@ie.u-ryukyu.ac.jp> |
|---|---|
| date | Fri, 23 Oct 2009 17:02:47 +0900 |
| parents | 0f13810d4492 |
| children | e3f3cfa8794f |
| rev | line source |
|---|---|
| 566 | 1 #include <stdlib.h> |
| 2 #include <stdio.h> | |
| 3 #include <string.h> | |
| 4 #include <fcntl.h> | |
| 5 #include <sys/types.h> | |
| 6 #include <sys/mman.h> | |
| 7 #include <sys/stat.h> | |
| 8 #include <unistd.h> | |
| 9 #include <arpa/inet.h> | |
| 10 #include "SceneGraphRoot.h" | |
| 11 #include "lindaapi.h" | |
| 12 #include "dynamic_create.h" | |
| 13 | |
| 14 #define PORT 10000 | |
| 15 | |
| 16 #define SERIAL_REGIST_TUPLE_NO 1 | |
| 17 | |
| 18 /* | |
| 19 typedef struct { | |
| 20 caddr_t file_mmap; | |
| 21 off_t size; | |
| 22 } st_mmap_t; | |
| 23 */ | |
| 24 | |
| 25 typedef struct client_ { | |
| 26 int id; | |
| 27 SceneGraphPtr sgp; | |
| 28 struct client_ *next; | |
| 29 } client_t; | |
| 30 | |
| 31 typedef struct { | |
| 32 int tid; | |
| 33 int sid; | |
| 34 int read_id; | |
| 35 SceneGraphPtr node; | |
| 36 TaskManager *manager; | |
| 37 client_t *clist; | |
| 38 } callback_arg; | |
| 39 | |
| 40 | |
| 41 void | |
| 42 client_list_init(TaskManager* manager, client_t *clist) | |
| 43 { | |
| 44 clist->id = -1; | |
| 45 clist->next = clist; | |
| 46 } | |
| 47 | |
| 48 void | |
| 49 client_list_update(TaskManager *manager, client_t *clist, int id, SceneGraphPtr sgp) | |
| 50 { | |
| 51 //client_t *c; | |
| 52 // for (c = clist->next; c != clist; c = c->next) { | |
| 53 // if (c->id == id) { | |
| 54 // c->sgp = sgp; | |
| 55 // return; | |
| 56 // } | |
| 57 // } | |
| 58 | |
| 59 // c->next = (client_t *)manager->allocate(sizeof(client_t)); | |
| 60 // c->next->id = id; | |
| 61 // c->next->sgp = sgp; | |
| 62 // c->next->next = clist; | |
| 63 } | |
| 64 | |
| 65 void | |
| 66 client_list_delete(TaskManager *manager, client_t *clist, int id) | |
| 67 { | |
| 68 client_t *c, *prev; | |
| 69 for (c = clist->next, prev = clist; c->next != clist; c = c->next) { | |
| 70 if (c->id == id) { | |
| 71 prev->next = c->next; | |
| 72 return; | |
| 73 } | |
| 74 prev = clist; | |
| 75 } | |
| 76 if (c->id == id) { | |
| 77 prev->next = c->next; | |
| 78 return; | |
| 79 } | |
| 80 } | |
| 81 | |
| 82 | |
| 83 static void | |
| 84 earth_collision(SceneGraphPtr node, int screen_w, int screen_h, | |
| 85 SceneGraphPtr tree) | |
| 86 { | |
| 87 } | |
| 88 | |
| 89 static void | |
| 90 moon_collision(SceneGraphPtr node, int screen_w, int screen_h, | |
| 91 SceneGraphPtr tree) | |
| 92 { | |
| 93 } | |
| 94 | |
| 95 static void | |
| 96 moon_move(SceneGraphPtr node, int screen_w, int screen_h) | |
| 97 { | |
| 98 //node->angle[0] += 3.0f; | |
| 99 node->xyz[1] += 1.0f; | |
| 100 } | |
| 101 | |
| 102 | |
| 103 static void | |
| 104 earth_move(SceneGraphPtr node, int screen_w, int screen_h) | |
| 105 { | |
|
575
0f13810d4492
Linda API worked. (slightly unreliable)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
574
diff
changeset
|
106 // psx_sync_n(); in viewer::MainLoop |
| 566 | 107 } |
| 108 | |
| 109 SceneGraphPtr | |
| 110 create_sg(TaskManager *manager, SceneGraphPtr node, unsigned char *data, int len, int serial_id) | |
| 111 { | |
| 112 SceneGraphPtr object; | |
| 113 | |
| 114 sgroot->createFromXMLmemory(sgroot->tmanager, (char *)data, len); | |
| 115 object = sgroot->createSceneGraph(sgroot->getLast()); | |
| 116 object->id = serial_id; | |
| 117 object->set_move_collision(moon_move, moon_collision); | |
| 118 node->addChild(object); | |
| 119 | |
| 120 return object; | |
| 121 } | |
| 122 | |
| 574 | 123 // void |
| 124 // del_callback(unsigned char *data, void *arg) | |
| 125 // { | |
| 126 // free(data); | |
| 127 // } | |
| 566 | 128 |
| 574 | 129 // void |
| 130 // psx_del(int t, int id) | |
| 131 // { | |
| 132 // psx_callback_in(t, id, del_callback, NULL); | |
| 133 // } | |
| 566 | 134 |
| 135 static void | |
| 136 callback_get_xml(unsigned char *xml_tuple, void *arg) { | |
| 137 int xml_len = psx_get_datalength(xml_tuple); | |
| 138 callback_arg *carg = (callback_arg *)arg; | |
| 139 unsigned char *xml_data = xml_tuple+LINDA_HEADER_SIZE; | |
| 140 SceneGraphPtr sgp; | |
| 141 // ここで create | |
| 574 | 142 fwrite(xml_data, 1, 10, stdout); |
| 566 | 143 sgp = create_sg(carg->manager, carg->node, xml_data, xml_len, carg->sid); |
| 144 client_list_update(carg->manager, carg->clist, carg->sid, sgp); | |
| 145 free(arg); | |
| 146 free(xml_tuple); | |
| 147 } | |
| 148 | |
| 149 static void | |
| 150 callbacker(unsigned char *tuple, void *arg) { | |
| 151 int serial_id, xml_id; | |
| 152 | |
| 153 unsigned char *data; | |
| 154 callback_arg *carg = (callback_arg *)arg; | |
| 155 | |
| 156 // 最初の4byteデータは使わない | |
| 157 data = tuple+LINDA_HEADER_SIZE; | |
| 158 // clientのSerialIDを取得 | |
| 159 serial_id = ntohl(*(int *)data); | |
| 574 | 160 |
| 161 printf("serial id = %d\n", serial_id); | |
| 566 | 162 // タプルを解放 |
| 574 | 163 //psx_del(carg->tid, SERIAL_REGIST_TUPLE_NO); |
| 566 | 164 |
| 165 // xml fileを取得する もうすでにxml fileが送信済みである事を期待 | |
| 166 // つまり、送信者がserial_idを送る前にxml fileを送信していなくてはならない | |
| 167 xml_id = serial_id * 10; | |
| 168 callback_arg *copy_arg = (callback_arg *)carg->manager->allocate(sizeof(callback_arg)); | |
| 169 *copy_arg = *carg; | |
| 170 copy_arg->sid = serial_id; | |
| 171 psx_callback_in(carg->tid, xml_id, callback_get_xml, (void *)copy_arg); | |
| 172 | |
| 173 /* dataは'\0'で終わっている事を期待 (writerで保証する) */ | |
| 174 //printf("get data[%d]: `%s'\n", len, data); | |
| 175 free(tuple); | |
| 176 | |
| 574 | 177 psx_callback_in(carg->tid, carg->read_id, callbacker, arg); |
| 566 | 178 } |
| 179 | |
| 180 void | |
| 181 linda_init(TaskManager *manager, client_t *clist, SceneGraphPtr node) | |
| 182 { | |
| 183 init_linda(); | |
| 184 callback_arg *carg = (callback_arg *)manager->allocate(sizeof(callback_arg)); | |
| 185 | |
| 186 carg->tid = open_linda_java("localhost", PORT); | |
| 187 carg->read_id = SERIAL_REGIST_TUPLE_NO; | |
| 188 carg->node = node; | |
| 189 carg->manager = manager; | |
| 190 carg->clist = clist; | |
| 574 | 191 psx_callback_in(carg->tid, carg->read_id, callbacker, carg); |
| 566 | 192 } |
| 193 | |
| 194 MainLoopPtr | |
| 195 dynamic_create::init(Viewer *sgroot, int screen_w, int screen_h) | |
| 196 { | |
| 197 //SceneGraphPtr earth; | |
| 198 client_t *clist; | |
| 199 clist = (client_t *)sgroot->manager->allocate(sizeof(client_t)); | |
| 200 | |
| 201 client_list_init(sgroot->manager, clist); | |
| 202 | |
| 203 SceneGraphPtr parent; | |
| 204 parent = sgroot->createSceneGraph(); | |
| 205 parent->set_move_collision(earth_move, earth_collision); | |
| 206 parent->xyz[0] += 300; | |
| 207 | |
| 208 linda_init(sgroot->manager, clist, parent); | |
| 209 | |
| 210 // SceneGraphRoot に、使用する SceneGraph を設定する | |
| 211 // このとき、ユーザーが記述した SceneGraph の root を渡す。 | |
| 212 sgroot->setSceneData(parent); | |
| 213 return sgroot; | |
| 214 } | |
| 215 | |
| 216 extern Application * | |
| 217 application() { | |
| 218 return new dynamic_create(); | |
| 219 } | |
| 220 | |
| 221 const char *usr_help_str = "Usage: ./test_nogl [OPTION]\n"; | |
| 222 | |
| 223 extern int init(TaskManager *manager, int argc, char *argv[]); | |
| 224 extern void task_initialize(); | |
| 225 static void TMend(TaskManager *manager); | |
| 226 | |
| 227 int | |
| 228 TMmain(TaskManager *manager, int argc, char *argv[]) | |
| 229 { | |
| 230 task_initialize(); | |
| 231 manager->set_TMend(TMend); | |
| 232 return init(manager, argc, argv); | |
| 233 | |
| 234 } | |
| 235 | |
| 236 void | |
| 237 TMend(TaskManager *manager) | |
| 238 { | |
| 239 printf("test_nogl end\n"); | |
| 240 } | |
| 241 | |
| 242 /* end */ | |
| 243 |