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

tweak
author ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
date Mon, 28 Feb 2022 22:11:26 +0900
parents a3cda2aa18aa
children
comparison
equal deleted inserted replaced
41:3959e0817369 42:01b88c0dd337
1 __code getDataLocalDGMQueue(struct LocalDGMQueue* cQueue, __code next(...), __code whenEOF(...), __code whenError(...)){ 1 __code getDataLocalDGMQueue(struct LocalDGMQueue* cQueue, __code next(...), __code whenEOF(...), __code whenError(...)){
2 int recv_size, send_size; 2 int recv_size, send_size;
3 char send_buf; 3 char send_buf;
4 4
5 union Data* recv_data; 5 union Data* recv_data;
6 recv_size = recv(cQueue->socket, recv_data, sizeof(union Data), 0); 6 recv_size = read(tQueue->socket, recv_data, sizeof(union Data));
7 if (recv_size == -1) { 7 if (recv_size == -1) {
8 printf("recv error\n"); 8 printf("recv error\n");
9 goto whenError(...); 9 goto whenError(...);
10 } 10 }
11 if (recv_size == 0) { 11 if (recv_size == 0) {