summaryrefslogtreecommitdiff
path: root/tinyrtc.c
diff options
context:
space:
mode:
Diffstat (limited to 'tinyrtc.c')
-rw-r--r--tinyrtc.c308
1 files changed, 155 insertions, 153 deletions
diff --git a/tinyrtc.c b/tinyrtc.c
index 2b74890..54bb9b9 100644
--- a/tinyrtc.c
+++ b/tinyrtc.c
@@ -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 : */
generated by cgit v1.2.3 (git 2.25.1) at 2024-11-01 10:30:07 +0000