Mercurial > hg > Members > kono > Cerium
annotate Renderer/Engine/lindaapi.cc @ 606:32a7260fad2f
32bit/64bit ABI (64 bit is not tested yet).
64bit ABI requires 64bit SDL library etc.
| author | Shinji KONO <kono@ie.u-ryukyu.ac.jp> |
|---|---|
| date | Sat, 07 Nov 2009 18:05:52 +0900 |
| parents | 90c61fe2b109 |
| children | 0decff4e867b |
| rev | line source |
|---|---|
| 572 | 1 // $Id$ |
| 507 | 2 // |
| 3 | |
| 4 /*---------------------------------------------------------------------- | |
| 572 | 5 インクルードファイル読み込み |
| 507 | 6 ----------------------------------------------------------------------*/ |
| 7 #include <stdio.h> | |
| 8 #include <string.h> | |
| 572 | 9 #include <stdlib.h> |
| 10 #include <sys/time.h> | |
| 507 | 11 #include <unistd.h> |
| 572 | 12 #include <netinet/in.h> |
| 507 | 13 #include <sys/select.h> |
| 14 #include <sys/types.h> | |
| 15 #include <sys/socket.h> | |
| 572 | 16 #include <netdb.h> |
| 507 | 17 #include <netinet/tcp.h> |
| 572 | 18 #include <sys/un.h> |
| 507 | 19 #include <errno.h> |
| 572 | 20 #include <arpa/inet.h> |
| 507 | 21 |
| 22 #include "lindaapi.h" | |
|
606
32a7260fad2f
32bit/64bit ABI (64 bit is not tested yet).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
605
diff
changeset
|
23 |
| 572 | 24 |
| 507 | 25 #if 0 |
| 26 #define PSX_Debug(deb) (putchar(PS_DEB)),\ | |
| 27 (printf deb ),\ | |
| 28 (putchar(PS_DEB)) | |
| 572 | 29 #define DEB(a) |
| 507 | 30 #else |
| 572 | 31 #define PSX_Debug(deb) |
| 507 | 32 #define DEB(a) /* a */ |
| 33 #endif | |
| 34 | |
| 572 | 35 /* Global Variables */ |
| 36 static COMMAND *q_top, *q_end; /* コマンドキュー */ | |
| 37 static REPLY *reply, *r_end; /* 受け取り用キュー */ | |
| 38 static int qsize; /* コマンドキューのサイズ */ | |
| 39 static fd_set g_fds; /* 接続しているタプルスペース群のFD(FileDiscripter)を保持 */ | |
|
575
0f13810d4492
Linda API worked. (slightly unreliable)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
572
diff
changeset
|
40 static int g_max_fds = 0; /* 監視するFDの最大値 */ |
| 507 | 41 |
| 572 | 42 /* Static Functions */ |
| 43 static void unix_chkserv(int ps); | |
| 44 void psx_free(void *); | |
|
606
32a7260fad2f
32bit/64bit ABI (64 bit is not tested yet).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
605
diff
changeset
|
45 static long psx_queue(unsigned int tspace_id, unsigned int id, |
| 572 | 46 unsigned int size, unsigned char *data, char mode, |
| 47 void(*callback)(unsigned char *,void *),void * obj); | |
| 507 | 48 |
| 49 #ifdef COUNT_PACKET | |
| 50 // print packet count message per PRINT_INTERVAL sec | |
| 51 #define PRINT_INTERVAL 4 | |
| 572 | 52 static void count_packet(char type); |
| 507 | 53 |
| 54 /*-------------------------------------------------------------------/ | |
| 572 | 55 static void |
| 507 | 56 count_packet (char type): |
| 572 | 57 パケットの送受信カウントする |
| 58 | |
| 59 引き数: | |
| 60 type - 送信、受信 (char型: s,r) | |
| 507 | 61 /-------------------------------------------------------------------*/ |
| 572 | 62 static void |
| 63 count_packet(char type) | |
| 507 | 64 { |
| 65 static int send_packet=-1,receive_packet=0; | |
| 66 static struct timeval start,now,previous; | |
| 572 | 67 |
| 507 | 68 if (out_packet == -1) { |
| 69 gettimeofday(&start,NULL); | |
| 70 gettimeofday(&previous,NULL); | |
| 71 send_packet = 0; | |
| 72 printf("packet\tout\tread\t\ttime\n"); | |
| 73 } | |
| 572 | 74 |
| 507 | 75 if (type == 's') { |
| 76 send_packet++; | |
| 77 } else if (type == 'r') { | |
| 78 receive_packet++; | |
| 79 } else { | |
| 80 fprintf(stderr,"No type in count_packet function\n"); | |
| 81 return; | |
| 82 } | |
| 572 | 83 |
| 507 | 84 gettimeofday(&now,NULL); |
| 85 if ((now.tv_sec-previous.tv_sec) > PRINT_INTERVAL) { | |
| 86 printf("log\t%d\t%d\t%ld\n", | |
| 87 send_packet,receive_packet,now.tv_sec-start.tv_sec); | |
| 88 fflush(stdout); | |
| 572 | 89 |
| 507 | 90 previous.tv_sec = now.tv_sec; |
| 91 send_packet = receive_packet = 0; | |
| 92 } | |
| 93 } | |
| 94 #endif | |
| 95 | |
| 96 | |
| 97 #define unix_read_w read | |
| 572 | 98 |
| 99 | |
| 100 static int | |
| 101 unix_write(int fd,unsigned char *buf,unsigned int size) { | |
| 102 unsigned int count=0; | |
| 103 uint32_t nsize; | |
| 507 | 104 |
| 572 | 105 /* これから送信するデータのサイズをまず送信 */ |
| 106 nsize = htonl(size); | |
| 107 write(fd, &nsize, INT_SIZE); | |
| 108 | |
| 109 /* 目的のデータを送信 */ | |
| 110 while (count < size) { | |
| 111 count += write(fd, buf+count, size-count); | |
| 507 | 112 } |
| 113 #ifdef COUNT_PACKET | |
| 114 count_packet('s'); | |
| 115 #endif | |
| 572 | 116 return count+INT_SIZE; |
| 507 | 117 } |
| 118 | |
| 119 #define unix_write_w unix_write | |
| 120 | |
| 121 #define SERV_NAME unix_port | |
| 122 #define PROTO_NAME "tcp" | |
| 123 #define SERVER_NAME hostname | |
| 124 #define MAX_REQ 16 | |
| 125 | |
| 572 | 126 |
| 127 | |
| 128 /*-------------------------------------------------------------------/ | |
| 129 void | |
| 130 init_linda(): | |
| 131 大域変数の初期化等を行なう | |
| 132 /-------------------------------------------------------------------*/ | |
| 133 void | |
| 134 init_linda() { | |
| 135 FD_ZERO(&g_fds); | |
| 136 /* 大域変数はゼロクリアされる | |
| 137 g_max_fds = 0; | |
| 138 q_end = q_top = NULL; | |
| 139 r_end = reply = NULL; | |
| 140 qsize = 0; | |
| 141 */ | |
| 142 } | |
| 507 | 143 |
| 144 | |
| 145 /*-------------------------------------------------------------------/ | |
| 146 int | |
| 572 | 147 open_linda (char * hostname, int port): |
| 148 Lindaサーバとのコネクションを確立し、タプルスペースのIDを返す。 | |
| 149 現在はファイルディスクリプタを返している。 | |
| 507 | 150 |
| 572 | 151 引き数: |
| 152 hostname - サーバのホスト名 | |
| 153 port - サーバのポート番号 | |
| 154 返り値: | |
| 155 コネクション確立が成功するとそのファイルディスクリプタを返す。 | |
| 156 失敗すると -1 を返す。 | |
| 507 | 157 /-------------------------------------------------------------------*/ |
| 158 int | |
| 572 | 159 open_linda(char * hostname, int port){ |
| 160 int fd; | |
| 161 struct hostent *hoste; | |
| 162 struct sockaddr_in serv_addr; | |
| 163 struct sockaddr_un serv_addr_un; | |
| 164 | |
| 507 | 165 if (hostname[0]=='/') { |
| 166 /* Unix domain */ | |
| 167 if ((fd = socket(AF_UNIX, SOCK_STREAM, 0)) == FAIL){ | |
| 572 | 168 perror("socket"); |
| 507 | 169 return(-1); |
| 170 } | |
| 171 serv_addr_un.sun_family = AF_UNIX; | |
| 172 strcpy(serv_addr_un.sun_path, hostname); | |
| 572 | 173 fprintf(stdout,"connecting ... %d\n", serv_addr.sin_port); |
| 507 | 174 if (connect(fd, (struct sockaddr *)&serv_addr_un,sizeof(serv_addr_un)) == FAIL){ |
| 572 | 175 perror("connect"); |
| 507 | 176 close(fd); |
| 177 return(-1); | |
| 178 } | |
| 572 | 179 |
| 507 | 180 } else { |
| 181 /* INET domain */ | |
| 182 if ((fd = socket(AF_INET, SOCK_STREAM, 0)) == FAIL){ | |
| 572 | 183 perror("socket"); |
| 507 | 184 return(-1); |
| 185 } | |
| 572 | 186 if ((hoste = gethostbyname(SERVER_NAME)) == NULL){ |
| 507 | 187 fprintf(stderr,"hostname error\n"); |
| 188 close(fd); | |
| 189 return(-1); | |
| 190 } | |
| 191 serv_addr.sin_family = AF_INET; | |
| 572 | 192 serv_addr.sin_port = port; |
| 507 | 193 serv_addr.sin_addr.s_addr = ((struct in_addr *)(hoste->h_addr))->s_addr; |
| 194 if (serv_addr.sin_family == AF_INET) { | |
| 195 int tmp = 1; | |
| 196 setsockopt (fd, IPPROTO_TCP, TCP_NODELAY, | |
| 197 (char *) &tmp, sizeof (int)); | |
| 198 } | |
| 572 | 199 fprintf(stdout,"connecting ... %d\n", serv_addr.sin_port); |
| 507 | 200 if (connect(fd, (struct sockaddr *)&serv_addr,sizeof(serv_addr)) == FAIL){ |
| 201 fprintf(stderr,"connection error! errno :%d %s\n", errno, | |
| 202 strerror(errno)); | |
| 203 close(fd); | |
| 204 return(-1); | |
| 205 } | |
| 206 } | |
| 207 | |
| 572 | 208 FD_SET(fd, &g_fds); |
| 209 if (g_max_fds < fd) g_max_fds = fd; | |
| 210 | |
| 507 | 211 fprintf(stdout," connect middle server %d\n", fd); |
| 572 | 212 return fd; |
| 213 } | |
| 214 | |
| 215 int | |
| 216 open_linda_java(char * hostname, int port){ | |
| 217 int fd; | |
| 218 struct hostent *hoste; | |
| 219 struct sockaddr_in serv_addr; | |
| 220 struct sockaddr_un serv_addr_un; | |
| 221 | |
| 222 if (hostname[0]=='/') { | |
| 223 /* Unix domain */ | |
| 224 if ((fd = socket(AF_UNIX, SOCK_STREAM, 0)) == FAIL){ | |
| 225 perror("socket"); | |
| 226 return(-1); | |
| 227 } | |
| 228 serv_addr_un.sun_family = AF_UNIX; | |
| 229 strcpy(serv_addr_un.sun_path, hostname); | |
| 230 DEB(fprintf(stdout,"connecting ... %d\n", serv_addr.sin_port)); | |
| 231 if (connect(fd, (struct sockaddr *)&serv_addr_un,sizeof(serv_addr_un)) == FAIL){ | |
| 232 perror("connect"); | |
| 233 close(fd); | |
| 234 return(-1); | |
| 235 } | |
| 236 | |
| 237 } else { | |
| 238 /* INET domain */ | |
| 239 if ((fd = socket(AF_INET, SOCK_STREAM, 0)) == FAIL){ | |
| 240 perror("socket"); | |
| 241 return(-2); | |
| 242 } | |
| 243 serv_addr.sin_family = AF_INET; | |
| 244 serv_addr.sin_port = htons(port); | |
| 245 | |
| 246 serv_addr.sin_addr.s_addr = inet_addr(hostname); | |
| 247 if (serv_addr.sin_addr.s_addr == 0xffffffff) { | |
| 248 if ((hoste = gethostbyname(hostname)) == NULL){ | |
| 249 fprintf(stdout, "hostname error\n"); | |
| 250 close(fd); | |
| 251 return(-1); | |
| 252 } | |
| 253 serv_addr.sin_addr.s_addr = *(unsigned int *)hoste->h_addr_list[0]; | |
| 254 } | |
| 255 | |
| 256 if (serv_addr.sin_family == AF_INET) { | |
| 257 int tmp = 1; | |
| 258 setsockopt (fd, IPPROTO_TCP, TCP_NODELAY, | |
| 259 (char *) &tmp, sizeof (int)); | |
| 260 } | |
| 261 DEB(fprintf(stdout,"connecting ... %d \n", ntohs(serv_addr.sin_port))); | |
| 262 DEB(fprintf(stdout," serv_addr.sin_port ... %d \n", ntohs(serv_addr.sin_port))); | |
| 263 //fprintf(stdout," serv_addr.sin_addr.s_addr... %s\n", serv_addr.sin_addr.s_addr); | |
| 264 if (connect(fd, (struct sockaddr *)&serv_addr,sizeof(serv_addr)) == FAIL){ | |
| 265 perror("connect"); | |
| 266 close(fd); | |
| 267 return(-4); | |
| 268 } | |
| 269 } | |
| 270 | |
| 271 FD_SET(fd, &g_fds); | |
| 272 if (g_max_fds < fd) g_max_fds = fd; | |
| 273 | |
| 274 DEB(fprintf(stdout," connect middle server %d\n", fd)); | |
| 275 return fd; | |
| 276 } | |
| 277 | |
| 278 | |
| 279 /*-------------------------------------------------------------------/ | |
| 280 int | |
| 281 close_linda(int tspace_id): | |
| 282 接続しているタプルスペースへの接続を切る。 | |
| 283 ソケットを閉じ、g_fds から外す。 | |
| 284 引数: | |
| 285 tspace_id - 閉じるタプルスペースのID | |
| 286 返り値: | |
| 287 close の値 | |
| 288 /-------------------------------------------------------------------*/ | |
| 289 int | |
| 290 close_linda(int tspace_id){ | |
| 291 int retval; | |
| 292 int i; | |
| 293 if ((retval = close(tspace_id)) == 0) { | |
| 294 FD_CLR(tspace_id, &g_fds); | |
| 295 if (g_max_fds == tspace_id) { | |
| 296 for (i = g_max_fds-1; FD_ISSET(i, &g_fds) && i; i--); | |
| 297 g_max_fds = i; | |
| 298 } | |
| 299 } | |
| 300 return retval; | |
| 507 | 301 } |
| 302 | |
| 303 /*-------------------------------------------------------------------/ | |
| 304 int | |
| 572 | 305 psx_out (unsigned int tspace_id, unsigned int id, |
| 306 unsigned char *data, unsigned int size): | |
| 307 outコマンドをCOMMANDキューへ溜める。 | |
| 507 | 308 |
| 572 | 309 引き数: |
| 310 tspace_id - タプルスペースのID | |
| 311 id - タプルのID | |
| 312 data - 送信するデータ | |
| 313 size - dataのサイズ | |
| 314 返り値: | |
| 315 シーケンス番号 | |
| 507 | 316 /-------------------------------------------------------------------*/ |
|
606
32a7260fad2f
32bit/64bit ABI (64 bit is not tested yet).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
605
diff
changeset
|
317 long |
| 572 | 318 psx_out(unsigned int tspace_id, unsigned int id, |
| 319 unsigned char *data, unsigned int size){ | |
|
606
32a7260fad2f
32bit/64bit ABI (64 bit is not tested yet).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
605
diff
changeset
|
320 long r; |
| 572 | 321 if ((r = psx_queue(tspace_id, id, size, data, 'o', NULL, NULL)) == FAIL) { |
| 507 | 322 return(FAIL); |
| 323 } | |
| 324 DEB( fprintf(stdout, "psx_out: size = %d, command = %s\n", | |
| 325 q_end->size, q_end->command+LINDA_HEADER_SIZE)); | |
| 572 | 326 return(r); |
| 507 | 327 } |
| 328 | |
| 329 /*-------------------------------------------------------------------/ | |
| 330 int | |
| 572 | 331 psx_ld (unsigned tspace_id, unsigned int id, |
| 332 char mode, void(*callback)(char*,void*), void * obj): | |
| 333 in,read,waitなどの受信コマンドをCOMMANDキューへ溜める。 | |
| 334 psx_in,psx_rd,psx_wait_rdなどに置き換えられている。 | |
| 335 | |
| 336 引き数: | |
| 337 tspace_id- タプルスペースのID | |
| 338 id - タプルのID | |
| 339 mode - i,r,w の文字を取り、各々in,read,waitを表している。 | |
| 340 callback - コールバックを使用する場合の関数へのポインタ。 | |
| 341 使用しない場合はNULLをいれる。 | |
| 342 obj - コールバックで用いる関数の引き数。 | |
| 343 返り値: | |
| 344 psx_queue内でmallocされたREPLY構造体へのポインタ | |
| 507 | 345 /-------------------------------------------------------------------*/ |
|
606
32a7260fad2f
32bit/64bit ABI (64 bit is not tested yet).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
605
diff
changeset
|
346 long |
| 572 | 347 psx_ld(unsigned int tspace_id, unsigned int id, |
| 348 char mode, void(*callback)(unsigned char *,void *), void * obj){ | |
|
606
32a7260fad2f
32bit/64bit ABI (64 bit is not tested yet).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
605
diff
changeset
|
349 long r; |
| 572 | 350 if ((r = psx_queue(tspace_id, id, 0, NULL, mode, callback, obj)) == FAIL) { |
| 507 | 351 return(FAIL); |
| 352 } | |
| 353 return(r); | |
| 354 } | |
| 355 | |
| 356 /*-------------------------------------------------------------------/ | |
| 357 unsigned char * | |
| 358 psx_reply (int seq): | |
| 572 | 359 サーバから答えが来たデータを返す。 |
| 507 | 360 |
| 572 | 361 引き数: |
| 362 seq - psx_ld()が返した値。 | |
| 363 返り値: | |
| 364 seqに対応したデータを返す。データをまだ受信していない場合は | |
| 365 NULLを返す。 | |
| 507 | 366 /-------------------------------------------------------------------*/ |
| 367 unsigned char * | |
| 572 | 368 psx_reply(unsigned int seq){ |
| 507 | 369 REPLY *p, *q; |
| 572 | 370 unsigned char *ans; |
| 371 | |
| 507 | 372 DEB(fprintf(stdout, "psx_reply: search of seq = %d\n", seq)); |
| 572 | 373 PSX_Debug(("psx_reply: seq %d", seq)); |
| 374 for(q = NULL,p = reply; p; q = p,p = p->next){ | |
| 375 if (p->seq == seq){ | |
| 507 | 376 DEB(fprintf(stdout, "psx_reply: match of seq = %d\n", seq)); |
| 377 if (p->mode == '!'){ | |
| 572 | 378 ans = p->answer; |
| 507 | 379 if (q == NULL){ |
| 380 reply = p->next; | |
| 381 if(p==r_end) { | |
| 382 r_end = p->next; | |
| 383 } | |
| 384 } else { | |
| 385 q->next = p->next; | |
| 386 if(p==r_end) { | |
| 387 r_end = q; | |
| 388 } | |
| 389 } | |
| 572 | 390 PSX_Debug(("psx_reply: reply %x r_end %x p %x q %x",reply,r_end,p,q)); |
| 391 psx_free(p); | |
| 507 | 392 DEB( for(p=reply;p;p=p->next) { PSX_Debug(("psx_queue dump: seq %d mode %c %x %x",p->seq,p->mode,p,p->next))}); |
| 393 DEB( fprintf(stdout, "psx_reply: returned answer = %s\n", ans)); | |
| 394 PSX_Debug(("psx_reply: answer %s",ans)); | |
| 572 | 395 return(ans); |
| 507 | 396 } else { |
| 397 if (p->mode == '?'){ | |
| 398 DEB(fprintf(stdout, "psx_reply: don't accept anser\n")); | |
| 399 return(NULL); | |
| 400 } | |
| 401 } | |
| 402 } | |
| 403 | |
| 404 } | |
| 405 PSX_Debug(("psx_reply: no match seq %d",seq)); | |
| 406 DEB(fprintf(stdout, "psx_reply: no match of seq\n")); | |
| 407 return(NULL); | |
| 408 } | |
| 409 | |
| 410 /*-------------------------------------------------------------------/ | |
| 411 void | |
| 412 psx_sync_n (): | |
| 572 | 413 サーバとデータの送受信をする。COMMANDキューに溜まったデータを |
| 414 送信し、サーバから送られて来たデータを対応するREPLYへいれる。 | |
| 507 | 415 /-------------------------------------------------------------------*/ |
| 572 | 416 #define TIMEDELTA 10 |
| 507 | 417 void |
| 418 psx_sync_n(){ | |
| 419 int acount; | |
| 572 | 420 int i; |
| 507 | 421 COMMAND *c, *t; |
| 422 | |
|
575
0f13810d4492
Linda API worked. (slightly unreliable)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
572
diff
changeset
|
423 if (g_max_fds==0) return; |
|
0f13810d4492
Linda API worked. (slightly unreliable)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
572
diff
changeset
|
424 |
| 572 | 425 fd_set tmp; |
| 507 | 426 struct timeval timeout; |
| 427 timeout.tv_sec=0; | |
| 428 timeout.tv_usec=TIMEDELTA * 1000; | |
| 429 | |
| 430 acount = 0; | |
| 431 while (q_top != NULL){ | |
| 432 c = q_top; | |
| 572 | 433 unix_write_w(c->tspace_id, c->command, c->size); |
| 434 psx_free(c->command); | |
| 507 | 435 t = c->next; |
| 572 | 436 psx_free(c); |
| 437 q_top = c = t; | |
| 438 qsize--; | |
| 507 | 439 } |
| 572 | 440 |
| 441 tmp = g_fds; | |
| 442 while(select(g_max_fds+1, &tmp, NULL, NULL, &timeout) > 0) { | |
| 443 for (i = 0; i < g_max_fds+1; i++) { | |
| 444 if (FD_ISSET(i, &tmp)) { | |
| 445 unix_chkserv(i); | |
| 446 } | |
| 507 | 447 } |
| 572 | 448 } |
| 507 | 449 } |
| 450 | |
| 451 /*-------------------------------------------------------------------/ | |
|
606
32a7260fad2f
32bit/64bit ABI (64 bit is not tested yet).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
605
diff
changeset
|
452 static int |
| 572 | 453 psx_queue (unsigned int tspace_id, unsigned int id, |
| 454 unsigned int size, unsigned char *data, char mode, | |
| 455 void(*callback)(char*,void*), void * obj): | |
| 456 out,in,read,waitなどのコマンドをCOMMANDキューに溜める。データを | |
| 457 受信するコマンド(in,read,wait)のときは受け取ったときにデータを | |
| 458 格納するREPLY構造体を作る。 | |
| 507 | 459 |
| 572 | 460 引き数: |
| 461 tspace_id- 送信先タプルスペースのID | |
| 462 id - アクセスするTUPLE SpaceのID | |
| 463 size - dataのサイズ | |
| 464 data - 送信するデータ。受信時はNULL。 | |
| 465 mode - コマンドのモード(out,in,read,wait は各々char型: o,i,r,w) | |
| 466 callback - コールバックを使用する場合の関数へのポインタ。 | |
| 467 使用しない場合はNULL。 | |
| 468 obj - コールバックで用いる関数に引き渡すデータ。 | |
| 469 返り値: | |
| 470 成功した場合 - mallocしたREPLY構造体へのポインタ。outの場合は | |
| 471 0が返る。 | |
| 472 失敗した場合 - FAIL(-1)が返る。 | |
| 507 | 473 /-------------------------------------------------------------------*/ |
|
606
32a7260fad2f
32bit/64bit ABI (64 bit is not tested yet).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
605
diff
changeset
|
474 static long |
| 572 | 475 psx_queue(unsigned int tspace_id, unsigned int id, |
| 476 unsigned int size, unsigned char *data, char mode, | |
| 477 void(*callback)(unsigned char *,void *), void * obj){ | |
| 507 | 478 REPLY *p; |
| 479 COMMAND *c; | |
| 572 | 480 |
| 481 if (qsize >= MAX_QUEUE) { | |
| 507 | 482 // PSX_Debug(("max queue: qsize=%d",qsize)); |
| 483 psx_sync_n(); | |
| 484 } | |
| 572 | 485 |
| 486 if (q_top == NULL) { | |
| 507 | 487 if ((q_top = (COMMAND *) malloc (sizeof(COMMAND))) == NULL){ |
| 488 return(FAIL); | |
| 489 } | |
| 490 c = q_end = q_top; | |
| 491 } else { | |
| 492 if ((q_end->next = (COMMAND *) malloc (sizeof(COMMAND))) == NULL){ | |
| 493 return(FAIL); | |
| 494 } | |
| 495 c = q_end; | |
| 496 q_end = q_end->next; | |
| 497 } | |
| 572 | 498 |
| 499 /* size は DATASIZE */ | |
| 500 if ((q_end->command = (unsigned char *) malloc(size+LINDA_HEADER_SIZE)) == NULL) { | |
| 501 psx_free(q_end); | |
| 507 | 502 c->next = NULL; |
| 503 return(FAIL); | |
| 504 } | |
| 505 | |
| 572 | 506 /* データ受け取り要求(in,rd,wait)なら受け取り用の箱を用意 */ |
| 507 if (mode != 'o') { | |
| 507 | 508 if (reply == NULL){ |
|
606
32a7260fad2f
32bit/64bit ABI (64 bit is not tested yet).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
605
diff
changeset
|
509 if ((reply = (REPLY *) malloc (sizeof(REPLY))) == NULL){ |
|
32a7260fad2f
32bit/64bit ABI (64 bit is not tested yet).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
605
diff
changeset
|
510 return(FAIL); |
|
32a7260fad2f
32bit/64bit ABI (64 bit is not tested yet).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
605
diff
changeset
|
511 } |
| 507 | 512 p = r_end = reply; p->next = NULL; |
| 513 } else { | |
|
606
32a7260fad2f
32bit/64bit ABI (64 bit is not tested yet).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
605
diff
changeset
|
514 if ((r_end->next = (REPLY *) malloc (sizeof(REPLY))) == NULL){ |
|
32a7260fad2f
32bit/64bit ABI (64 bit is not tested yet).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
605
diff
changeset
|
515 return(FAIL); |
|
32a7260fad2f
32bit/64bit ABI (64 bit is not tested yet).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
605
diff
changeset
|
516 } |
| 507 | 517 p = r_end->next; r_end = p; p->next = NULL; |
| 518 } | |
| 519 p->mode = '?'; | |
|
606
32a7260fad2f
32bit/64bit ABI (64 bit is not tested yet).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
605
diff
changeset
|
520 p->seq = (long)p; // 構造体のアドレスで識別 |
| 507 | 521 p->callback = callback; |
| 522 p->obj = obj; | |
| 523 PSX_Debug(("psx_queue: seq %d reply %x p %x r_end %x",seq,reply,p,r_end)); | |
| 572 | 524 } else { |
| 525 p = 0; | |
| 507 | 526 } |
| 527 q_end->command[LINDA_MODE_OFFSET] = mode; | |
| 528 | |
| 529 q_end->command[LINDA_ID_OFFSET] = id >> 8; | |
| 530 q_end->command[LINDA_ID_OFFSET+1] = id & 0xff; | |
| 531 | |
|
602
1733f3cbfa28
64bit mode try... not worked.
e075740@nw0740.st.ie.u-ryukyu.ac.jp
parents:
575
diff
changeset
|
532 q_end->command[LINDA_SEQ_OFFSET] = ((long)p>>24) & 0xff; |
|
1733f3cbfa28
64bit mode try... not worked.
e075740@nw0740.st.ie.u-ryukyu.ac.jp
parents:
575
diff
changeset
|
533 q_end->command[LINDA_SEQ_OFFSET+1] = ((long)p>>16) & 0xff; |
|
1733f3cbfa28
64bit mode try... not worked.
e075740@nw0740.st.ie.u-ryukyu.ac.jp
parents:
575
diff
changeset
|
534 q_end->command[LINDA_SEQ_OFFSET+2] = ((long)p>>8) & 0xff; |
|
1733f3cbfa28
64bit mode try... not worked.
e075740@nw0740.st.ie.u-ryukyu.ac.jp
parents:
575
diff
changeset
|
535 q_end->command[LINDA_SEQ_OFFSET+3] = ((long)p) & 0xff; |
|
606
32a7260fad2f
32bit/64bit ABI (64 bit is not tested yet).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
605
diff
changeset
|
536 |
|
32a7260fad2f
32bit/64bit ABI (64 bit is not tested yet).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
605
diff
changeset
|
537 q_end->command[LINDA_DATA_LENGTH_OFFSET] = (size>>24) & 0xff; |
|
32a7260fad2f
32bit/64bit ABI (64 bit is not tested yet).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
605
diff
changeset
|
538 q_end->command[LINDA_DATA_LENGTH_OFFSET+1] = (size>>16) & 0xff; |
|
32a7260fad2f
32bit/64bit ABI (64 bit is not tested yet).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
605
diff
changeset
|
539 q_end->command[LINDA_DATA_LENGTH_OFFSET+2] = (size>>8) & 0xff; |
|
32a7260fad2f
32bit/64bit ABI (64 bit is not tested yet).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
605
diff
changeset
|
540 q_end->command[LINDA_DATA_LENGTH_OFFSET+3] = (size) & 0xff; |
| 572 | 541 |
| 507 | 542 q_end->size = size+LINDA_HEADER_SIZE; /* command size */ |
| 572 | 543 q_end->tspace_id = tspace_id; /* destination id */ |
| 544 q_end->next = NULL; | |
| 545 qsize++; | |
| 546 if (data && size>0) | |
| 547 memcpy(q_end->command+LINDA_HEADER_SIZE, data, size); | |
|
602
1733f3cbfa28
64bit mode try... not worked.
e075740@nw0740.st.ie.u-ryukyu.ac.jp
parents:
575
diff
changeset
|
548 return((long)p); |
| 507 | 549 } |
| 550 | |
| 551 /*-------------------------------------------------------------------/ | |
| 572 | 552 static void |
| 553 unix_chkserv (int ps): | |
| 554 サーバからデータ(TUPLE)を受け取る。REPLY構造体にコールバック関数 | |
| 555 が指定されていればその関数を実行し、REPLY構造体をキューから取り | |
| 556 除く。コールバック関数が指定されていなければREPLY構造体にデータ | |
| 557 を引き渡す。 | |
| 558 引数: | |
| 559 ps - 接続しているタプルスペースのソケット | |
| 507 | 560 /-------------------------------------------------------------------*/ |
| 572 | 561 static void |
| 562 unix_chkserv(int ps){ | |
| 563 int i,pkt,npkt,mode; | |
| 564 unsigned int k; | |
| 507 | 565 REPLY *r,*prev; |
| 566 int a; | |
| 567 unsigned char * tuple = 0; | |
| 568 | |
| 569 if((i=read(ps,&npkt,INT_SIZE))<0) { | |
| 572 | 570 perror("read"); |
| 507 | 571 exit(1); |
| 572 } | |
| 573 pkt = ntohl(npkt); | |
| 574 DEB(printf("pkt: %d\n",pkt)); | |
| 575 DEB(fprintf(stdout, "psx_chkserv: queue number: %d , size = %d\n", i, pkt)); | |
| 576 if((tuple = (unsigned char *)malloc(pkt))==NULL){ | |
| 572 | 577 perror("malloc"); |
| 507 | 578 exit(1); |
| 579 } | |
| 580 for(a=0;a<pkt;a+=i) { | |
| 581 if((i=unix_read_w(ps,tuple+a,pkt-a))<0) { | |
| 582 fprintf(stderr, "psx_chkserv: read error! on i=%d pkt=%d %s\n", | |
| 583 i, pkt, strerror(errno)); | |
| 584 exit(1);//close(ps); | |
| 585 } | |
| 586 } | |
| 587 | |
| 588 #ifdef COUNT_PACKET | |
| 589 count_packet('r'); | |
| 590 #endif | |
| 572 | 591 mode = psx_get_mode(tuple); |
| 592 i = psx_get_id(tuple); | |
| 593 k = psx_get_seq(tuple); | |
| 594 PSX_Debug(("psx_chkserv: anser packet size = %d id %d seq %d", pkt,i,k)); | |
| 507 | 595 DEB(fprintf(stdout, "psx_chkserv: data from server: %s id=%d seq = %d\n", tuple, i, k)); |
| 596 DEB ( | |
| 597 for(p=reply;p;p=p->next) { | |
| 598 PSX_Debug(printf("psx_queue dump: seq %d mode %c %x %x",p->seq,p->mode,p,p->next)); | |
| 599 }) | |
| 572 | 600 |
| 507 | 601 for(prev = NULL,r = reply; r; prev = r,r = r->next){ |
| 602 DEB(fprintf(stdout,"seq: %d\n",r->seq);) | |
| 572 | 603 if (r->seq == k){ |
| 507 | 604 if(r->callback){ // call callback function |
| 572 | 605 (*r->callback)(tuple,r->obj); |
| 507 | 606 if (prev == NULL){ |
| 607 reply = r->next; | |
| 608 if(r == r_end) { | |
| 609 r_end = r->next; | |
| 610 } | |
| 611 } else { | |
| 612 prev->next = r->next; | |
| 613 if(r == r_end) { | |
| 614 r_end = prev; | |
| 615 } | |
| 616 } | |
| 572 | 617 psx_free(r); |
| 507 | 618 }else{ // normal reply |
| 619 PSX_Debug(("psx_chkserv: copy answer r %x seq %d",r,k)); | |
| 572 | 620 if(mode == 'a'){ |
| 621 r->answer = tuple; | |
| 622 }else{ | |
| 623 r->answer = NULL; | |
| 624 } | |
| 625 r->mode = '!'; | |
| 507 | 626 } |
| 627 break; | |
| 628 } | |
| 629 } | |
| 630 tuple = 0; | |
| 631 if (!r){ | |
| 632 DEB(fprintf(stdout, "unix_chkserv: accepted seq %d does not match. \n",k)); | |
| 633 } | |
| 634 } | |
| 635 | |
| 572 | 636 void psx_free(void *tuple) |
| 507 | 637 { |
| 638 free(tuple); | |
| 639 } | |
| 640 | |
| 641 /*-------------------------------------------------------------------/ | |
| 572 | 642 static unsigned int |
| 507 | 643 get_int(unsigned char * tuple, int offset): |
| 572 | 644 TUPLEのヘッダに格納された int型 のデータを得るための関数 |
| 645 psx_get_datalength() と psx_get_seq() から呼ばれる。 | |
| 507 | 646 |
| 572 | 647 引き数: |
| 648 tuple - ヘッダ情報も含んだTUPLE。psx_reply()で得たものでもいい。 | |
| 649 offset - 取りだすデータのオフセット。LINDA_DATA_LENGTH_OFFSET | |
| 650 か LINDA_SEQ_OFFSET。 | |
| 507 | 651 |
| 572 | 652 返り値: |
| 653 指定したオフセットに格納されていた数値(int型) | |
| 507 | 654 /-------------------------------------------------------------------*/ |
| 572 | 655 static unsigned int |
| 656 get_int(unsigned char * tuple, int offset){ | |
| 657 unsigned int i; | |
| 507 | 658 i = (tuple[offset] <<24) + |
| 659 (tuple[offset+1]<<16) + | |
| 660 (tuple[offset+2]<<8) + | |
| 661 (tuple[offset+3]); | |
| 662 return i; | |
| 663 } | |
| 664 | |
| 572 | 665 unsigned int |
| 666 psx_get_datalength(unsigned char * tuple){ | |
| 507 | 667 return get_int(tuple,LINDA_DATA_LENGTH_OFFSET); |
| 668 } | |
| 669 | |
| 572 | 670 unsigned char * |
| 671 psx_get_data(unsigned char * tuple) { | |
| 672 return tuple + LINDA_HEADER_SIZE; | |
| 507 | 673 } |
| 674 | |
| 572 | 675 unsigned int |
| 676 psx_get_seq(unsigned char * tuple){ | |
| 507 | 677 return get_int(tuple,LINDA_SEQ_OFFSET); |
| 678 } | |
| 679 | |
| 572 | 680 unsigned short |
| 681 psx_get_id(unsigned char * tuple){ | |
| 682 return (tuple[LINDA_ID_OFFSET] * 256 + tuple[LINDA_ID_OFFSET+1]); | |
| 507 | 683 } |
| 684 | |
| 572 | 685 unsigned char |
| 686 psx_get_mode(unsigned char * tuple){ | |
| 507 | 687 return tuple[LINDA_MODE_OFFSET]; |
| 688 } | |
| 689 | |
| 572 | 690 static |
| 691 void | |
| 692 set_int_to_char(unsigned char * tuple, int i, int offset){ | |
| 693 tuple[offset] = (i>>24) & 0xff; | |
| 694 tuple[offset+1] = (i>>16) & 0xff; | |
| 695 tuple[offset+2] = (i>>8) & 0xff; | |
| 696 tuple[offset+3] = (i) & 0xff; | |
| 697 } | |
| 698 | |
| 699 void | |
| 700 psx_set_datalength(unsigned char * tuple, int length){ | |
| 701 set_int_to_char(tuple,length,LINDA_DATA_LENGTH_OFFSET); | |
| 702 } | |
| 703 | |
| 704 | |
| 705 void | |
| 706 psx_set_seq(unsigned char * tuple, int seq){ | |
| 707 set_int_to_char(tuple,seq,LINDA_SEQ_OFFSET); | |
| 708 } | |
| 709 | |
| 710 void | |
| 711 psx_set_id(unsigned char * tuple, short id){ | |
| 712 tuple[LINDA_ID_OFFSET] = id >> 8; | |
| 713 tuple[LINDA_ID_OFFSET+1] = id & 0xff; | |
| 714 } | |
| 715 | |
| 716 void | |
| 717 psx_set_mode(unsigned char * tuple, char mode){ | |
| 718 tuple[LINDA_MODE_OFFSET] = mode; | |
| 719 } | |
| 720 | |
| 721 | |
| 507 | 722 |
| 723 /* end */ |