mirror of
https://git.rwth-aachen.de/acs/public/villas/node/
synced 2025-03-09 00:00:00 +01:00
add free and mem_deref to prevent memory leaks
This commit is contained in:
parent
22b42a8d88
commit
7e38cb9eb0
1 changed files with 5 additions and 2 deletions
|
@ -127,8 +127,9 @@ static void rtp_handler(const struct sa *src, const struct rtp_header *hdr, stru
|
|||
if (queue_push(&r->recv_queue, (void *) mbuf_alloc_ref(mb)) != 1)
|
||||
warn("Failed to push to queue");
|
||||
|
||||
/* header not yet used */
|
||||
(void)hdr;
|
||||
/* source, header not yet used */
|
||||
(void) src;
|
||||
(void) hdr;
|
||||
}
|
||||
|
||||
int rtp_start(struct node *n)
|
||||
|
@ -236,6 +237,7 @@ int rtp_read(struct node *n, struct sample *smps[], unsigned cnt, unsigned *rele
|
|||
if (ret < 0)
|
||||
warn("Received invalid packet from node %s: reason=%d", node_name(n), ret);
|
||||
|
||||
free(buf);
|
||||
return ret;
|
||||
}
|
||||
|
||||
|
@ -297,6 +299,7 @@ retry: cnt = io_sprint(&r->io, buf, buflen, &wbytes, smps, cnt);
|
|||
}
|
||||
|
||||
out: free(buf);
|
||||
mem_deref(mb);
|
||||
|
||||
return cnt;
|
||||
}
|
||||
|
|
Loading…
Add table
Reference in a new issue