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

start API in villas-pipe

Browse source
This commit is contained in:
Steffen Vogel 2017-04-07 17:35:55 +02:00
parent 053b43fb9f
commit 51e0930d39
1 changed files with 9 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
src/pipe.c
View file

@ -44,6 +44,8 @@ pthread_t ptid; /**< Parent thread id */
static void quit(int signal, siginfo_t *sinfo, void *ctx)
{
int ret;
if (recvv.started) {
pthread_cancel(recvv.thread);
pthread_join(recvv.thread, NULL);
@ -55,13 +57,11 @@ static void quit(int signal, siginfo_t *sinfo, void *ctx)
pthread_join(sendd.thread, NULL);
pool_destroy(&sendd.pool);
}
if (node->_vt->start == websocket_start)
web_stop(&sn.web);
node_stop(node);
node_type_stop(node->_vt);
ret = super_node_stop(&sn);
if (ret)
error("Failed to stop super-node");
super_node_destroy(&sn);
info(GRN("Goodbye!"));
@ -207,7 +207,7 @@ int main(int argc, char *argv[])
usage();
exit(EXIT_FAILURE);
}
log_init(&sn.log, level, LOG_ALL);
log_start(&sn.log);
@ -224,8 +224,8 @@ int main(int argc, char *argv[])
error("Node '%s' does not exist!", argv[optind+1]);
if (node->_vt->start == websocket_start) {
web_init(&sn.web, NULL); /* API is disabled in villas-pipe */
web_start(&sn.web);
api_start(&sn.api);
}
if (reverse)