Squashed 'third_party/rawrtc/rawrtc/' content from commit aa3ae4b24
Change-Id: I38a655a4259b62f591334e90a1315bd4e7e4d8ec
git-subtree-dir: third_party/rawrtc/rawrtc
git-subtree-split: aa3ae4b247275cc6e69c30613b3a4ba7fdc82d1b
diff --git a/tools/ice-transport-loopback.c b/tools/ice-transport-loopback.c
new file mode 100644
index 0000000..008c9a0
--- /dev/null
+++ b/tools/ice-transport-loopback.c
@@ -0,0 +1,152 @@
+#include "helper/handler.h"
+#include "helper/utils.h"
+#include <rawrtc.h>
+#include <rawrtcc.h>
+#include <rawrtcdc.h>
+#include <re.h>
+#include <stdlib.h> // exit
+#include <unistd.h> // STDIN_FILENO
+
+#define DEBUG_MODULE "ice-transport-loopback-app"
+#define DEBUG_LEVEL 7
+#include <re_dbg.h>
+
+// Note: Shadows struct client
+struct ice_transport_client {
+ char* name;
+ char** ice_candidate_types;
+ size_t n_ice_candidate_types;
+ struct rawrtc_ice_gather_options* gather_options;
+ struct rawrtc_ice_parameters* ice_parameters;
+ enum rawrtc_ice_role role;
+ struct rawrtc_ice_gatherer* gatherer;
+ struct rawrtc_ice_transport* ice_transport;
+ struct ice_transport_client* other_client;
+};
+
+static void ice_gatherer_local_candidate_handler(
+ struct rawrtc_ice_candidate* const candidate,
+ char const* const url, // read-only
+ void* const arg) {
+ struct ice_transport_client* const client = arg;
+
+ // Print local candidate
+ default_ice_gatherer_local_candidate_handler(candidate, url, arg);
+
+ // Add to other client as remote candidate (if type enabled)
+ add_to_other_if_ice_candidate_type_enabled(arg, candidate, client->other_client->ice_transport);
+}
+
+static void client_init(struct ice_transport_client* const local) {
+ // Create ICE gatherer
+ EOE(rawrtc_ice_gatherer_create(
+ &local->gatherer, local->gather_options, default_ice_gatherer_state_change_handler,
+ default_ice_gatherer_error_handler, ice_gatherer_local_candidate_handler, local));
+
+ // Create ICE transport
+ EOE(rawrtc_ice_transport_create(
+ &local->ice_transport, local->gatherer, default_ice_transport_state_change_handler,
+ default_ice_transport_candidate_pair_change_handler, local));
+}
+
+static void client_start(
+ struct ice_transport_client* const local, struct ice_transport_client* const remote) {
+ // Get & set ICE parameters
+ EOE(rawrtc_ice_gatherer_get_local_parameters(&local->ice_parameters, remote->gatherer));
+
+ // Start gathering
+ EOE(rawrtc_ice_gatherer_gather(local->gatherer, NULL));
+
+ // Start ICE transport
+ EOE(rawrtc_ice_transport_start(
+ local->ice_transport, local->gatherer, local->ice_parameters, local->role));
+}
+
+static void client_stop(struct ice_transport_client* const client) {
+ // Stop transport & close gatherer
+ EOE(rawrtc_ice_transport_stop(client->ice_transport));
+ EOE(rawrtc_ice_gatherer_close(client->gatherer));
+
+ // Un-reference & close
+ client->ice_parameters = mem_deref(client->ice_parameters);
+ client->ice_transport = mem_deref(client->ice_transport);
+ client->gatherer = mem_deref(client->gatherer);
+}
+
+int main(int argc, char* argv[argc + 1]) {
+ char** ice_candidate_types = NULL;
+ size_t n_ice_candidate_types = 0;
+ struct rawrtc_ice_gather_options* gather_options;
+ char* const turn_zwuenf_org_urls[] = {"stun:turn.zwuenf.org"};
+ struct ice_transport_client a = {0};
+ struct ice_transport_client b = {0};
+ (void) a.ice_candidate_types;
+ (void) a.n_ice_candidate_types;
+ (void) b.ice_candidate_types;
+ (void) b.n_ice_candidate_types;
+
+ // Debug
+ dbg_init(DBG_DEBUG, DBG_ALL);
+ DEBUG_PRINTF("Init\n");
+
+ // Initialise
+ EOE(rawrtc_init(true));
+
+ // Get enabled ICE candidate types to be added (optional)
+ if (argc > 1) {
+ ice_candidate_types = &argv[1];
+ n_ice_candidate_types = (size_t) argc - 1;
+ }
+
+ // Create ICE gather options
+ EOE(rawrtc_ice_gather_options_create(&gather_options, RAWRTC_ICE_GATHER_POLICY_ALL));
+
+ // Add ICE servers to ICE gather options
+ EOE(rawrtc_ice_gather_options_add_server(
+ gather_options, turn_zwuenf_org_urls, ARRAY_SIZE(turn_zwuenf_org_urls), NULL, NULL,
+ RAWRTC_ICE_CREDENTIAL_TYPE_NONE));
+
+ // Setup client A
+ a.name = "A";
+ a.ice_candidate_types = ice_candidate_types;
+ a.n_ice_candidate_types = n_ice_candidate_types;
+ a.gather_options = gather_options;
+ a.role = RAWRTC_ICE_ROLE_CONTROLLING;
+ a.other_client = &b;
+
+ // Setup client B
+ b.name = "B";
+ b.ice_candidate_types = ice_candidate_types;
+ b.n_ice_candidate_types = n_ice_candidate_types;
+ b.gather_options = gather_options;
+ b.role = RAWRTC_ICE_ROLE_CONTROLLED;
+ b.other_client = &a;
+
+ // Initialise clients
+ client_init(&a);
+ client_init(&b);
+
+ // Start clients
+ client_start(&a, &b);
+ client_start(&b, &a);
+
+ // Listen on stdin
+ EOR(fd_listen(STDIN_FILENO, FD_READ, stop_on_return_handler, NULL));
+
+ // Start main loop
+ EOR(re_main(default_signal_handler));
+
+ // Stop clients
+ client_stop(&a);
+ client_stop(&b);
+
+ // Stop listening on STDIN
+ fd_close(STDIN_FILENO);
+
+ // Free
+ mem_deref(gather_options);
+
+ // Bye
+ before_exit();
+ return 0;
+}