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

cleanups

Browse source
This commit is contained in:
Steffen Vogel 2017-10-16 23:08:46 +02:00
parent af39651d09
commit 3d6561097f
2 changed files with 4 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
lib/nodes/loopback.c
View file

@ -1,6 +1,5 @@
/** Node-type for loopback connections.
*
* @file
* @author Steffen Vogel <stvogel@eonerc.rwth-aachen.de>
* @copyright 2017, Institute for Automation of Complex Power Systems, EONERC
* @license GNU General Public License (version 3)
@ -109,12 +108,12 @@ char * loopback_print(struct node *n)
strcatf(&buf, "queuelen=%d", l->queuelen);
return buf;
};
}
int loopback_fd(struct node *n)
{
struct loopback *l = n->_vd;
return queue_signalled_fd(&l->queue);
}

4
lib/shmem.c
View file

@ -93,7 +93,7 @@ int shmem_int_open(const char *wname, const char* rname, struct shmem_int *shm,
memset(shared, 0, sizeof(struct shmem_shared));
shared->polling = conf->polling;
int flags = QUEUE_SIGNALLED_PROCESS_SHARED;
if (conf->polling)
flags |= QUEUE_SIGNALLED_POLLING;
@ -156,7 +156,7 @@ int shmem_int_open(const char *wname, const char* rname, struct shmem_int *shm,
int shmem_int_close(struct shmem_int *shm)
{
atomic_store(&shm->closed, 1);
queue_signalled_close(&shm->write.shared->queue);
shm_unlink(shm->write.name);