Revision 7e26a8a0
| net_helper-ml.c | ||
|---|---|---|
| 440 | 440 |
{
|
| 441 | 441 |
int size; |
| 442 | 442 |
if (receivedBuffer[rIdx].id==NULL) { //block till first message arrives
|
| 443 |
wait4data(local, NULL); |
|
| 443 |
wait4data(local, NULL, NULL);
|
|
| 444 | 444 |
} |
| 445 | 445 |
|
| 446 | 446 |
(*remote) = receivedBuffer[rIdx].id; |
| ... | ... | |
| 461 | 461 |
} |
| 462 | 462 |
|
| 463 | 463 |
|
| 464 |
int wait4data(const struct nodeID *n, struct timeval *tout) {
|
|
| 464 |
int wait4data(const struct nodeID *n, struct timeval *tout, fd_set *dummy) {
|
|
| 465 | 465 |
|
| 466 | 466 |
// fprintf(stderr,"Net-helper : Waiting for data to come...\n"); |
| 467 | 467 |
if (tout) { //if tout==NULL, loop wait infinitely
|
Also available in: Unified diff