{
struct ast_rtp *rtp = ice->user_data;
pj_status_t status = PJ_EINVALIDOP;
+ pj_ssize_t _size = (pj_ssize_t)size;
if (transport_id == TRANSPORT_SOCKET_RTP) {
/* Traffic is destined to go right out the RTP socket we already have */
- status = pj_sock_sendto(rtp->s, pkt, (pj_ssize_t*)&size, 0, dst_addr, dst_addr_len);
+ status = pj_sock_sendto(rtp->s, pkt, &_size, 0, dst_addr, dst_addr_len);
+ /* sendto on a connectionless socket should send all the data, or none at all */
+ ast_assert(_size == size || status != PJ_SUCCESS);
} else if (transport_id == TRANSPORT_SOCKET_RTCP) {
/* Traffic is destined to go right out the RTCP socket we already have */
if (rtp->rtcp) {
- status = pj_sock_sendto(rtp->rtcp->s, pkt, (pj_ssize_t*)&size, 0, dst_addr, dst_addr_len);
+ status = pj_sock_sendto(rtp->rtcp->s, pkt, &_size, 0, dst_addr, dst_addr_len);
+ /* sendto on a connectionless socket should send all the data, or none at all */
+ ast_assert(_size == size || status != PJ_SUCCESS);
} else {
status = PJ_SUCCESS;
}