diff options
Diffstat (limited to 'tinyrtc.c')
| -rw-r--r-- | tinyrtc.c | 143 |
1 files changed, 139 insertions, 4 deletions
@@ -26,9 +26,16 @@ * OF SUCH DAMAGE. */ +#include <ifaddrs.h> // freeifaddrs, getifaddrs #include <stdbool.h> #include <stdio.h> // snprintf #include <string.h> // memset +#include <unistd.h> // close + +#include <arpa/inet.h> +#include <net/if.h> +#include <netinet/in.h> +#include <sys/socket.h> #include "tinyrtc.h" @@ -41,8 +48,21 @@ struct trtc_peerconn_t { char offer[TRTC_MAX_SDP_SIZE]; char answer[TRTC_MAX_SDP_SIZE]; + /* local description */ + const char* ldesc; + + /* remote description */ + const char* rdesc; + char l_ice_pwd[TRTC_MAX_ICE_PWD_SIZE]; char l_ice_ufrag[TRTC_MAX_ICE_UFRAG_SIZE]; + + /* onIceCandidate callback */ + trtc_on_ice_candidate_t* on_ice_candidate; + void* on_ice_candidate_arg; + + /* tcp host candidate socket */ + int host_tcp_fd; }; @@ -53,20 +73,131 @@ static struct trtc_peerconn_t peer_connection_pool[TRTC_MAX_PEER_CONNECTIONS]; /// RTC PEER CONNECTION API //////////////////////////////////////////////// -void rtc_init() { +void trtc_init() { memset(peer_connection_pool, 0, sizeof(peer_connection_pool)); } +/** + * Get host candidates + * + * \return 0 on success, -1 on error. + */ +static int get_host_candidates(struct trtc_peerconn_t* pc) { + struct ifaddrs *ifaddr, *ifa; + socklen_t laddrlen; + + /* sanity check */ + if (!pc) return -1; + + /* create tcp socket */ + pc->host_tcp_fd = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP); + if (-1 == pc->host_tcp_fd) { + return -1; + } + + /* bind to arbitrary port */ + struct sockaddr_in laddr = { + .sin_family = AF_INET, + .sin_addr.s_addr = INADDR_ANY, + .sin_port = 0, + }; + if (-1 == bind(pc->host_tcp_fd, (struct sockaddr*)&laddr, sizeof(laddr))) { + return -1; + } + laddrlen = sizeof(struct sockaddr_in); + if (-1 == getsockname(pc->host_tcp_fd, (struct sockaddr *)&laddr, &laddrlen)) { + return -1; + } + + /* listen on socket */ + if (-1 == listen(pc->host_tcp_fd, 0)) { + return -1; + } + + /* get network interface addresses */ + if (-1 == getifaddrs(&ifaddr)) { + return -1; + } + + /* iterate over addresses */ + for (ifa = ifaddr; ifa; ifa = ifa->ifa_next) { + if (!ifa->ifa_addr) continue; + + /* skip loopback interface addresses */ + if (IFF_LOOPBACK & ifa->ifa_flags) continue; + + if (AF_INET == ifa->ifa_addr->sa_family) { + struct sockaddr_in *sa = (struct sockaddr_in*)ifa->ifa_addr; + + /* host tcp candidate */ + struct trtc_ice_candidate_t c = { + .sdp_mid = "0", + .sdp_mline_index = 0 + }; + snprintf(c.candidate, TRTC_MAX_ICE_CANDIDATE_SIZE, + "candidate:2894319779 1 tcp 212260223 %s %d typ host tcptype passive", + inet_ntoa(sa->sin_addr), + laddr.sin_port); // XXXX + + /* callback */ + if (pc->on_ice_candidate) { + pc->on_ice_candidate(c, pc->on_ice_candidate_arg); + } + } + } + + freeifaddrs(ifaddr); + + return 0; +} + +/** + * Peer connection thread + * + * Each peer connection uses one background thread for stepping the ICE agent, + * handling timeouts, and sending/receiving packets. + * + * \param arg[in] User-specified argument. + * + * \return NULL. + */ +static void* peer_connection_thread(void *arg) { + return NULL; +} + struct trtc_peerconn_t* trtc_peer_connection(struct trtc_config_t cfg) { + struct trtc_peerconn_t* pc = NULL; + for (int i = 0; i < TRTC_MAX_PEER_CONNECTIONS; i++) { if (!peer_connection_pool[i].active) { memset(&peer_connection_pool[i], 0, sizeof(struct trtc_peerconn_t)); - peer_connection_pool[i].active = true; - return &peer_connection_pool[i]; + pc = &peer_connection_pool[i]; + break; } } - return NULL; + return pc; +} + +void trtc_peer_connection_destroy(struct trtc_peerconn_t* pc) { + if (!pc) return; + + close(pc->host_tcp_fd); + + // XXX mark as available +} + +int trtc_set_on_ice_candidate( + struct trtc_peerconn_t* pc, + trtc_on_ice_candidate_t* cb, + void* arg +) { + if (!pc || !cb) return -1; + + pc->on_ice_candidate = cb; + pc->on_ice_candidate_arg = arg; + + return 0; } int trtc_add_ice_candidate(struct trtc_peerconn_t *pc, const struct trtc_ice_candidate_t c) { @@ -83,6 +214,7 @@ const char * trtc_create_answer(struct trtc_peerconn_t *pc) { "v=0\\r\\n" "o=- 2210401696197537454 2 IN IP4 127.0.0.1\\r\\n" // XXX "s=-\\r\\n" + "u=https://tinyrtc.org/\\r\\n" "t=0 0\\r\\n" "a=group:BUNDLE 0\\r\\n" "a=msid-semantic: WMS\\r\\n" @@ -118,9 +250,12 @@ const char * trtc_create_answer(struct trtc_peerconn_t *pc) { }; int trtc_set_local_description(struct trtc_peerconn_t *pc, const char *sdp) { + pc->ldesc = sdp; + get_host_candidates(pc); return -1; }; int trtc_set_remote_description(struct trtc_peerconn_t *pc, const char *sdp) { + pc->rdesc = sdp; return -1; }; |