kenmirrors/asterisk
1
0
Fork 0
mirror of https://github.com/asterisk/asterisk.git synced 2025-10-12 15:45:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use non-blocking socket() and pipe() wrappers

Browse Source 
Change-Id: I050ceffe5a133d5add2dab46687209813d58f597
This commit is contained in:
Sean Bright
2018-12-11 09:54:43 -05:00
parent cd8101dbd1
commit 9febdba05b
5 changed files with 12 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
res/res_rtp_asterisk.c
View File

@@ -3112,22 +3112,19 @@ static double stddev_compute(double stddev, double sample, double normdev, doubl
static int create_new_socket(const char *type, int af)
{
int sock = socket(af, SOCK_DGRAM, 0);
int sock = ast_socket_nonblock(af, SOCK_DGRAM, 0);
if (sock < 0) {
if (!type) {
type = "RTP/RTCP";
}
ast_log(LOG_WARNING, "Unable to allocate %s socket: %s\n", type, strerror(errno));
} else {
ast_fd_set_flags(sock, O_NONBLOCK);
#ifdef SO_NO_CHECK
if (nochecksums) {
setsockopt(sock, SOL_SOCKET, SO_NO_CHECK, &nochecksums, sizeof(nochecksums));
}
#endif
return sock;
}
#ifdef SO_NO_CHECK
if (nochecksums) {
setsockopt(sock, SOL_SOCKET, SO_NO_CHECK, &nochecksums, sizeof(nochecksums));
}
#endif
return sock;
}