diff options
author | Chris Hiszpanski <chris.hiszpanski@verkada.com> | 2022-05-22 01:41:02 -0700 |
---|---|---|
committer | Chris Hiszpanski <chris.hiszpanski@verkada.com> | 2022-05-22 01:41:12 -0700 |
commit | 1c21817646f1f3c8fc99f1fd6ad04324641da383 (patch) | |
tree | 1787d65e49422e00db5d7a48dab2627267b1c20f /tinyrtc.c | |
parent | 8a4e7fabafd8d42b0b2cbdbd766bea49a62bfae1 (diff) |
expand tabs and add vim modeline
Diffstat (limited to 'tinyrtc.c')
-rw-r--r-- | tinyrtc.c | 308 |
1 files changed, 155 insertions, 153 deletions
@@ -26,11 +26,11 @@ * OF SUCH DAMAGE. */ -#include <ifaddrs.h> // freeifaddrs, getifaddrs +#include <ifaddrs.h> // freeifaddrs, getifaddrs #include <stdbool.h> -#include <stdio.h> // snprintf -#include <string.h> // memset -#include <unistd.h> // close +#include <stdio.h> // snprintf +#include <string.h> // memset +#include <unistd.h> // close #include <arpa/inet.h> #include <net/if.h> @@ -43,26 +43,26 @@ /// OPAQUE TYPE DEFINITIONS //////////////////////////////////////////////// struct trtc_peerconn_t { - bool active; + bool active; - char offer[TRTC_MAX_SDP_SIZE]; - char answer[TRTC_MAX_SDP_SIZE]; + char offer[TRTC_MAX_SDP_SIZE]; + char answer[TRTC_MAX_SDP_SIZE]; - /* local description */ - const char* ldesc; + /* local description */ + const char* ldesc; - /* remote description */ - const char* rdesc; + /* remote description */ + const char* rdesc; - char l_ice_pwd[TRTC_MAX_ICE_PWD_SIZE]; - char l_ice_ufrag[TRTC_MAX_ICE_UFRAG_SIZE]; + 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; + /* onIceCandidate callback */ + trtc_on_ice_candidate_t* on_ice_candidate; + void* on_ice_candidate_arg; - /* tcp host candidate socket */ - int host_tcp_fd; + /* tcp host candidate socket */ + int host_tcp_fd; }; @@ -74,7 +74,7 @@ static struct trtc_peerconn_t peer_connection_pool[TRTC_MAX_PEER_CONNECTIONS]; /// RTC PEER CONNECTION API //////////////////////////////////////////////// void trtc_init() { - memset(peer_connection_pool, 0, sizeof(peer_connection_pool)); + memset(peer_connection_pool, 0, sizeof(peer_connection_pool)); } /** @@ -83,72 +83,72 @@ void trtc_init() { * \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; + 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; } /** @@ -162,100 +162,102 @@ static int get_host_candidates(struct trtc_peerconn_t* pc) { * \return NULL. */ static void* peer_connection_thread(void *arg) { - return NULL; + return NULL; } struct trtc_peerconn_t* trtc_peer_connection(struct trtc_config_t cfg) { - struct trtc_peerconn_t* pc = NULL; + 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)); - pc = &peer_connection_pool[i]; - break; - } - } + 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)); + pc = &peer_connection_pool[i]; + break; + } + } - return pc; + return pc; } void trtc_peer_connection_destroy(struct trtc_peerconn_t* pc) { - if (!pc) return; + if (!pc) return; - close(pc->host_tcp_fd); + close(pc->host_tcp_fd); - // XXX mark as available + // XXX mark as available } int trtc_set_on_ice_candidate( - struct trtc_peerconn_t* pc, - trtc_on_ice_candidate_t* cb, - void* arg + struct trtc_peerconn_t* pc, + trtc_on_ice_candidate_t* cb, + void* arg ) { - if (!pc || !cb) return -1; + if (!pc || !cb) return -1; - pc->on_ice_candidate = cb; - pc->on_ice_candidate_arg = arg; + pc->on_ice_candidate = cb; + pc->on_ice_candidate_arg = arg; - return 0; + return 0; } int trtc_add_ice_candidate(struct trtc_peerconn_t *pc, const struct trtc_ice_candidate_t c) { - return -1; + return -1; }; const char * trtc_create_answer(struct trtc_peerconn_t *pc) { - unsigned char fp[32]; - - snprintf(pc->l_ice_ufrag, TRTC_MAX_ICE_UFRAG_SIZE, "xxxx"); // XXX - snprintf(pc->l_ice_pwd, TRTC_MAX_ICE_PWD_SIZE, "xxxxxxxxxxxxxxxxxxxxxx"); // XXX - - snprintf(pc->answer, TRTC_MAX_SDP_SIZE, - "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" - "m=video 9 UDP/TLS/RTP/SAVPF 98\\r\\n" // XXX - "c=IN IP4 0.0.0.0\\r\\n" - "a=rtcp:9 IN IP4 0.0.0.0\\r\\n" - "a=ice-ufrag:%s\\r\\n" - "a=ice-pwd:%s\\r\\n" - "a=ice-options:trickle\\r\\n" - "a=fingerprint:sha-256 " - "%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:" - "%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:" - "%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:" - "%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:%02hhX\\r\\n" - "a=setup:passive\\r\\n" - "a=mid:0\\r\\n" - "a=sendonly\\r\\n" - "a=rtcp-mux\\r\\n" - "a=rtcp-rsize\\r\\n" - "a=rtpmap:98 H264/90000\\r\\n" - "a=rtcp-fb:98 nack\\r\\n" - "a=rtcp-fb:98 nack pli\\r\\n" - "a=fmtp:98 level-asymmetry-allowed=1;packetization-mode=1;profile-level-id=42e01f\\r\\n", - pc->l_ice_ufrag, - pc->l_ice_pwd, - fp[ 0], fp[ 1], fp[ 2], fp[ 3], fp[ 4], fp[ 5], fp[ 6], fp[ 7], - fp[ 8], fp[ 9], fp[10], fp[11], fp[12], fp[13], fp[14], fp[15], - fp[16], fp[17], fp[18], fp[19], fp[20], fp[21], fp[22], fp[23], - fp[24], fp[25], fp[26], fp[27], fp[28], fp[29], fp[30], fp[31] - ); - - return pc->answer; + unsigned char fp[32]; + + snprintf(pc->l_ice_ufrag, TRTC_MAX_ICE_UFRAG_SIZE, "xxxx"); // XXX + snprintf(pc->l_ice_pwd, TRTC_MAX_ICE_PWD_SIZE, "xxxxxxxxxxxxxxxxxxxxxx"); // XXX + + snprintf(pc->answer, TRTC_MAX_SDP_SIZE, + "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" + "m=video 9 UDP/TLS/RTP/SAVPF 98\\r\\n" // XXX + "c=IN IP4 0.0.0.0\\r\\n" + "a=rtcp:9 IN IP4 0.0.0.0\\r\\n" + "a=ice-ufrag:%s\\r\\n" + "a=ice-pwd:%s\\r\\n" + "a=ice-options:trickle\\r\\n" + "a=fingerprint:sha-256 " + "%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:" + "%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:" + "%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:" + "%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:%02hhX:%02hhX\\r\\n" + "a=setup:passive\\r\\n" + "a=mid:0\\r\\n" + "a=sendonly\\r\\n" + "a=rtcp-mux\\r\\n" + "a=rtcp-rsize\\r\\n" + "a=rtpmap:98 H264/90000\\r\\n" + "a=rtcp-fb:98 nack\\r\\n" + "a=rtcp-fb:98 nack pli\\r\\n" + "a=fmtp:98 level-asymmetry-allowed=1;packetization-mode=1;profile-level-id=42e01f\\r\\n", + pc->l_ice_ufrag, + pc->l_ice_pwd, + fp[ 0], fp[ 1], fp[ 2], fp[ 3], fp[ 4], fp[ 5], fp[ 6], fp[ 7], + fp[ 8], fp[ 9], fp[10], fp[11], fp[12], fp[13], fp[14], fp[15], + fp[16], fp[17], fp[18], fp[19], fp[20], fp[21], fp[22], fp[23], + fp[24], fp[25], fp[26], fp[27], fp[28], fp[29], fp[30], fp[31] + ); + + return pc->answer; }; int trtc_set_local_description(struct trtc_peerconn_t *pc, const char *sdp) { - pc->ldesc = sdp; - get_host_candidates(pc); - return -1; + 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; + pc->rdesc = sdp; + return -1; }; + +/* vim: set et ts=4 sw=4 : */ |