From 3d6561097f66b1d3b4be0eedc3b93024cd404488 Mon Sep 17 00:00:00 2001 From: Steffen Vogel Date: Mon, 16 Oct 2017 23:08:46 +0200 Subject: [PATCH] cleanups --- lib/nodes/loopback.c | 5 ++--- lib/shmem.c | 4 ++-- 2 files changed, 4 insertions(+), 5 deletions(-) diff --git a/lib/nodes/loopback.c b/lib/nodes/loopback.c index 3b4badaf0..9ca95094e 100644 --- a/lib/nodes/loopback.c +++ b/lib/nodes/loopback.c @@ -1,6 +1,5 @@ /** Node-type for loopback connections. * - * @file * @author Steffen Vogel * @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); } diff --git a/lib/shmem.c b/lib/shmem.c index c9ab74640..d0dffe4ad 100644 --- a/lib/shmem.c +++ b/lib/shmem.c @@ -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);