mirror of
https://git.rwth-aachen.de/acs/public/villas/node/
synced 2025-03-09 00:00:00 +01:00
fixed some small bugs in async path and web socket
This commit is contained in:
parent
e7df392754
commit
fbabc57273
2 changed files with 5 additions and 3 deletions
|
@ -62,12 +62,14 @@ static void * path_run_async(void *arg)
|
|||
p->overrun += expir;
|
||||
warn("Overrun detected for path: overruns=%" PRIu64, expir);
|
||||
}
|
||||
|
||||
if (p->received == 0)
|
||||
continue;
|
||||
|
||||
if (path_run_hook(p, HOOK_ASYNC))
|
||||
continue;
|
||||
|
||||
if (p->received > 0)
|
||||
path_write(p);
|
||||
path_write(p);
|
||||
}
|
||||
|
||||
return NULL;
|
||||
|
|
|
@ -407,7 +407,7 @@ int websocket_write(struct node *n, struct msg *pool, int poolsize, int first, i
|
|||
|
||||
pthread_mutex_unlock(&w->write.mutex);
|
||||
|
||||
return 0;
|
||||
return 1;
|
||||
}
|
||||
|
||||
static struct node_type vt = {
|
||||
|
|
Loading…
Add table
Reference in a new issue