Mirrors/VILLASnode
1
0
Fork 0
mirror of https://git.rwth-aachen.de/acs/public/villas/node/ synced 2025-03-09 00:00:00 +01:00
Code Issues Releases Wiki Activity

add polling loop inside shmem_read

Browse source
This commit is contained in:
Georg Reinke 2017-07-28 12:15:56 +02:00
parent cc02829def
commit 37fc5df254
1 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
lib/nodes/shmem.c
View file

@ -110,14 +110,15 @@ int shmem_read(struct node *n, struct sample *smps[], unsigned cnt)
int recv;
struct sample *shared_smps[cnt];
recv = shmem_int_read(&shm->intf, shared_smps, cnt);
if (recv < 0)
do {
recv = shmem_int_read(&shm->intf, shared_smps, cnt);
} while (recv == 0);
if (recv < 0) {
/* This can only really mean that the other process has exited, so close
* the interface to make sure the shared memory object is unlinked */
shmem_int_close(&shm->intf);
if (recv <= 0)
return recv;
}
sample_copy_many(smps, shared_smps, recv);
sample_put_many(shared_smps, recv);