Function mod_init

modules/rtp.io/rtp_io.c:140–196

}

static int mod_init(void)
{
    int nsocks;
    const char * const argv_stat[] = {
        "-d", "err",
        "-n", "tcp:127.0.0.1:9642",
        "--dso", "catch_dtmf",
        "--dso", "dtls_gw",
        "--dso", "ice_lite",
    };

    unsigned int extra = 0;
    nsocks = count_child_processes() - count_module_procs(0) - timer_count_processes(&extra);
    nsocks -= extra;

    if (nsocks <= 1)
        goto e0;

    LM_DBG("initializing %s(%d)\n", exports.name, nsocks);

    if (rio_socks_init(nsocks) != 0)
        goto e0;
    if (init_rtpp_host() != 0)
        goto e1;

    for (int i = 0; i < howmany(argv_stat, *argv_stat); i++) {
        ENV_ADD(argv_stat[i], e1);
    }

    struct rtpp_n_sock *n_sock = &rpi_descp->n_sock;
    int *fdp = n_sock->_fds;
    if (socketpair(AF_UNIX, SOCK_STREAM, 0, fdp) < 0)
        goto e1;
    snprintf(n_sock->_name, sizeof(n_sock->_name), "fd:%d", n_sock->fds.rtpp);
    n_sock->name.s = n_sock->_name;
    n_sock->name.len = strlen(n_sock->_name);
    ENV_ADD("-n", e2);
    ENV_ADD("%s", e2, n_sock->name.s);
    for (int i = 0; i < nsocks; i++) {
        int *fdp = &rpi_descp->socks->holder[i * 2];
        if (socketpair(AF_UNIX, SOCK_STREAM, 0, fdp) < 0)
            goto e2;
        ENV_ADD("-s", e2);
        ENV_ADD("fd:%d", e2, fdp[0]);
    }

    rpi_descp->socks->n = nsocks;

    return 0;
e2:
    close(n_sock->_fds[0]);
    close(n_sock->_fds[1]);
e1:
    free(rpi_descp->socks);
e0:
    return -1;
}