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

shm node: fixed bug introduced by previous refactoring

Browse source
This commit is contained in:
Steffen Vogel 2017-04-15 22:26:56 +02:00
parent db3d1477d1
commit 374f5bb557
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
lib/nodes/shmem.c
View file

@ -142,20 +142,20 @@ int shmem_read(struct node *n, struct sample *smps[], unsigned cnt)
{
struct shmem *shm = n->_vd;
int ret;
int ret, recv;
ret = shm->polling ? queue_pull_many(&shm->shared->in.q, (void**) smps, cnt)
recv = shm->polling ? queue_pull_many(&shm->shared->in.q, (void**) smps, cnt)
: queue_signalled_pull_many(&shm->shared->in.qs, (void**) smps, cnt);
if (ret <= 0)
return ret;
if (recv <= 0)
return recv;
/* Check if remote process is still running */
ret = atomic_load_explicit(&shm->shared->ext_stopped, memory_order_relaxed);
if (ret)
return -1;
return ret;
return ret;
return recv;
}
int shmem_write(struct node *n, struct sample *smps[], unsigned cnt)