Mercurial > hg > Papers > 2022 > ikki-master

annotate Paper/src/LocalDGMQueue.cbc @ 42:01b88c0dd337

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
tweak
author ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
date Mon, 28 Feb 2022 22:11:26 +0900
parents a3cda2aa18aa
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
8
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
1 __code getDataLocalDGMQueue(struct LocalDGMQueue* cQueue, __code next(...), __code whenEOF(...), __code whenError(...)){
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
2 int recv_size, send_size;
9
cc4cb64f9af9 add impl
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents: 8
diff changeset
3 char send_buf;
8
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
4
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
5 union Data* recv_data;
42
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents: 11
diff changeset
6 recv_size = read(tQueue->socket, recv_data, sizeof(union Data));
8
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
7 if (recv_size == -1) {
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
8 printf("recv error\n");
11
a3cda2aa18aa add par goto??
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents: 9
diff changeset
9 goto whenError(...);
8
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
10 }
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
11 if (recv_size == 0) {
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
12 printf("connection ended\n");
11
a3cda2aa18aa add par goto??
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents: 9
diff changeset
13 goto whenError(...);
8
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
14 }
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
15
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
16
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
17 FileString* fileString = NEW(FileString);
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
18 fileString = recv_data;
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
19 if (fileString->EoF) == 1) {
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
20 send_buf = 0;
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
21 send_size = send(cQueue->socket, &send_buf, 1, 0);
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
22 if (send_size == -1) {
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
23 printf("send error\n");
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
24 }
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
25 close(cQueue->buffer);
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
26 goto whenEOF(...);
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
27 } else {
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
28 send_buf = 1;
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
29 send_size = send(cQueue->socket, &send_buf, 1, 0);
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
30 if (send_size == -1) {
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
31 printf("send error\n");
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
32 goto whenError(...);
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
33 }
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
34 }
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
35
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
36 Gearef(context, cQueue)->data = recv_data;
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
37 goto putLocalDGMQueue(recv_data, next);
25cf5b9b74a2 add GearsDGM
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff changeset
38 }