FreeCalypso > hg > themwi-system-sw
view sip-in/main.c @ 124:7e04d28fae8b
sip-in: default use-100rel to no
BulkVS servers act badly when we send a reliable 180 Ringing response
to an incoming call, even though they advertise 100rel support in
the Supported header in the INVITE packet, and we probably won't be
implementing 100rel for outbound because doing per-the-spec PRACK
as a UAC is just too burdensome. Therefore, we need to consider
100rel extension as not-really-supported in themwi-system-sw.
author | Mychaela Falconia <falcon@freecalypso.org> |
---|---|
date | Sat, 01 Oct 2022 15:54:50 -0800 |
parents | 6aa63cf4620a |
children |
line wrap: on
line source
/* * Main module for themwi-sip-in. */ #include <sys/types.h> #include <sys/time.h> #include <sys/errno.h> #include <stdio.h> #include <stdlib.h> #include <string.h> #include <strings.h> #include <signal.h> #include <syslog.h> #include <unistd.h> extern unsigned cfg_retrans_timeout; extern int gsm_socket, gsm_is_connected; extern int mgw_socket, mgw_is_connected; extern int sip_socket; static int max_fd; struct timeval cur_event_time; update_max_fd(newfd) { if (newfd > max_fd) max_fd = newfd; } main(argc, argv) char **argv; { fd_set fds; int rc, need_retrans, dead_sip_flag; struct timeval timeout; time_t dead_sip_time; openlog("themwi-sip-in", 0, LOG_LOCAL5); read_config_file(); if (read_number_db() < 0) { fprintf(stderr, "error reading number database\n"); exit(1); } if (open_sip_udp_socket() < 0) { fprintf(stderr, "error opening SIP UDP socket\n"); exit(1); } if (argv[1]) { rc = open_sip_log_file(argv[1]); if (rc < 0) exit(1); /* error msg already printed */ } signal(SIGPIPE, SIG_IGN); /* main select loop */ for (;;) { FD_ZERO(&fds); FD_SET(sip_socket, &fds); if (gsm_is_connected) FD_SET(gsm_socket, &fds); if (mgw_is_connected) FD_SET(mgw_socket, &fds); need_retrans = dead_sip_flag = 0; scan_call_list_for_timeouts(&need_retrans, &dead_sip_flag, &dead_sip_time); if (need_retrans) { timeout.tv_sec = cfg_retrans_timeout / 1000; timeout.tv_usec = (cfg_retrans_timeout % 1000) * 1000; rc = select(max_fd+1, &fds, 0, 0, &timeout); } else if (dead_sip_flag) { if (cur_event_time.tv_sec >= dead_sip_time) timeout.tv_sec = 0; else timeout.tv_sec = dead_sip_time - cur_event_time.tv_sec; timeout.tv_usec = 0; rc = select(max_fd+1, &fds, 0, 0, &timeout); } else rc = select(max_fd+1, &fds, 0, 0, 0); if (rc < 0) { if (errno == EINTR) continue; syslog(LOG_CRIT, "select: %m"); exit(1); } gettimeofday(&cur_event_time, 0); if (rc) { if (gsm_is_connected && FD_ISSET(gsm_socket, &fds)) gsm_socket_select(); if (mgw_is_connected && FD_ISSET(mgw_socket, &fds)) mgw_socket_select(); if (FD_ISSET(sip_socket, &fds)) sip_socket_select(); } else if (need_retrans) run_periodic_retrans(); clear_dead_sip_calls(); } }