diff options
Diffstat (limited to 'package/tapi_sip/src/sip_client.c')
| -rw-r--r-- | package/tapi_sip/src/sip_client.c | 800 |
1 files changed, 0 insertions, 800 deletions
diff --git a/package/tapi_sip/src/sip_client.c b/package/tapi_sip/src/sip_client.c deleted file mode 100644 index 0b1e2ddd8f..0000000000 --- a/package/tapi_sip/src/sip_client.c +++ /dev/null @@ -1,800 +0,0 @@ -#include "sip_client.h" - -#include <stdint.h> -#include <sys/socket.h> -#include <sys/types.h> -#include <netdb.h> -#include <netinet/in.h> -#include <arpa/inet.h> -#include <errno.h> -#include <sys/epoll.h> -#include <stdbool.h> -#include <unistd.h> -#include <fcntl.h> -#include <net/if.h> -#include <sys/ioctl.h> - -#include "stun.h" -#include "sip_agent.h" -#include "session.h" -#include "list.h" - -static inline struct sip_agent *agent_to_sip_agent(struct agent *agent) -{ - return container_of(agent, struct sip_agent, agent); -} - -static int iface_get_addr(const char *iface, struct sockaddr_storage *addr) -{ - int fd; - int ret; - struct ifreq ifr; - - fd = socket(AF_INET, SOCK_DGRAM, 0); - - ifr.ifr_addr.sa_family = AF_INET; - strncpy(ifr.ifr_name, iface, IFNAMSIZ-1); - ret = ioctl(fd, SIOCGIFADDR, &ifr); - if (ret < 0) - perror("Failed to get interface address"); - - close(fd); - - if (ret == 0) - memcpy(addr, &ifr.ifr_addr, sizeof(ifr.ifr_addr)); - - return ret; -} - -#if 0 -static bool sockaddr_is_local(struct sockaddr_storage *addr) -{ - unsigned long s_addr; - bool is_local = false; - - switch (addr->ss_family) { - case AF_INET: - s_addr = ((struct sockaddr_in *)addr)->sin_addr.s_addr; - if ((s_addr & 0xff000000) == 0x10000000) - is_local = true; - else if ((s_addr & 0xfff00000) == 0xac100000) - is_local = true; - else if ((s_addr & 0xffff0000) == 0xc0a80000) - is_local = true; - break; - default: - break; - } - - return is_local; -} -#endif - -static uint16_t sockaddr_get_port(struct sockaddr_storage *addr) -{ - uint16_t port; - - switch (addr->ss_family) { - case AF_INET: - port = ((struct sockaddr_in *)addr)->sin_port; - break; - case AF_INET6: - port = ((struct sockaddr_in6 *)addr)->sin6_port; - break; - default: - port = 0; - break; - } - - return port; -} - -static void sockaddr_set_port(struct sockaddr_storage *addr, uint16_t port) -{ - switch (addr->ss_family) { - case AF_INET: - ((struct sockaddr_in *)addr)->sin_port = port; - break; - case AF_INET6: - ((struct sockaddr_in6 *)addr)->sin6_port = port; - break; - default: - break; - } -} - -static void *sockaddr_get_addr(struct sockaddr_storage *addr) -{ - void *a; - switch (addr->ss_family) { - case AF_INET: - a = &((struct sockaddr_in *)addr)->sin_addr.s_addr; - break; - case AF_INET6: - a = ((struct sockaddr_in6 *)addr)->sin6_addr.s6_addr; - break; - default: - a = NULL; - break; - } - - return a; -} - -static int sockaddr_to_string(struct sockaddr_storage *addr, char *s, size_t n) -{ - return inet_ntop(addr->ss_family, sockaddr_get_addr(addr), s, n) == NULL ? -1 : 0; -} - -static pjsip_module mod_siprtp; -static struct sip_client *global_client; - -/* Creates a datagram socket and binds it to a port in the range of - * start_port-end_port */ -static int sip_client_create_socket(struct sip_client *client, - struct sockaddr_storage *sockaddr, uint16_t start_port, - uint16_t end_port) -{ - int sockfd; - int ret; - - sockfd = socket(AF_INET, SOCK_DGRAM, 0); - if (sockfd < 0) - return sockfd; - - memcpy(sockaddr, &client->local_addr, sizeof(client->local_addr)); - do { - sockaddr_set_port(sockaddr, start_port); - ret = bind(sockfd, (struct sockaddr *)sockaddr, sizeof(*sockaddr)); - ++start_port; - } while (ret == -1 && start_port < end_port); - - if (ret == -1) - return -1; - - return sockfd; -} - -static int sip_worker_thread(void *arg) -{ - struct sip_client *client = arg; - - while (1) { - pj_time_val timeout = {0, 10}; - pjsip_endpt_handle_events(client->sip_endpt, &timeout); - } - - return 0; -} - -static bool sip_agent_stream_recv_callback(int events, void *data) -{ - struct sip_agent *agent = data; - char buf[512]; - int len; - int ret; - - len = read(agent->stream->fd, buf, 512); - if (len < 0) - return true; - - ret = sendto(agent->rtp_sockfd, buf, len, 0, - (struct sockaddr *)&agent->remote_addr, sizeof(agent->remote_addr)); - - if (ret < 0) - printf("failed to send rtp data: %d\n", errno); - - return true; -} - - -static bool sip_agent_rtp_recv_callback(int events, void *data) -{ - struct sip_agent *agent = data; - char buf[512]; - int len; - - len = recvfrom(agent->rtp_sockfd, buf, 512, 0, NULL, NULL); - if (agent->stream) - write(agent->stream->fd, buf, len); - - return true; -} - -static pj_status_t sip_client_create_sdp(struct sip_client *client, pj_pool_t *pool, - struct sip_agent *agent, - pjmedia_sdp_session **p_sdp) -{ - pj_time_val tv; - pjmedia_sdp_session *sdp; - pjmedia_sdp_media *m; - pjmedia_sdp_attr *attr; - struct sockaddr_storage rtp_addr; - char addr[INET6_ADDRSTRLEN]; - - PJ_ASSERT_RETURN(pool && p_sdp, PJ_EINVAL); - - agent->rtp_sockfd = sip_client_create_socket(client, &rtp_addr, 4000, 5000); - if (client->stun) - stun_client_resolve(client->stun, agent->rtp_sockfd, - (struct sockaddr *)&rtp_addr); - - agent->rtp_recv_callback.callback = sip_agent_rtp_recv_callback; - agent->rtp_recv_callback.data = agent; - event_register(agent->rtp_sockfd, EPOLLIN, &agent->rtp_recv_callback); - - /* Create and initialize basic SDP session */ - sdp = pj_pool_zalloc (pool, sizeof(pjmedia_sdp_session)); - - pj_gettimeofday(&tv); - sdp->origin.user = pj_str("pjsip-siprtp"); - sdp->origin.version = sdp->origin.id = tv.sec + 2208988800UL; - sdp->origin.net_type = pj_str("IN"); - sdp->origin.addr_type = pj_str("IP4"); - sdp->origin.addr = *pj_gethostname(); - sdp->name = pj_str("pjsip"); - - /* Since we only support one media stream at present, put the - * SDP connection line in the session level. - */ - sdp->conn = pj_pool_zalloc(pool, sizeof(pjmedia_sdp_conn)); - sdp->conn->net_type = pj_str("IN"); - sdp->conn->addr_type = pj_str("IP4"); - sockaddr_to_string(&rtp_addr, addr, sizeof(addr)); - pj_strdup2_with_null(pool, &sdp->conn->addr, addr); - - /* SDP time and attributes. */ - sdp->time.start = sdp->time.stop = 0; - sdp->attr_count = 0; - - /* Create media stream 0: */ - - sdp->media_count = 1; - m = pj_pool_zalloc(pool, sizeof(pjmedia_sdp_media)); - sdp->media[0] = m; - - /* Standard media info: */ - m->desc.media = pj_str("audio"); - m->desc.port = sockaddr_get_port(&rtp_addr); - m->desc.port_count = 1; - m->desc.transport = pj_str("RTP/AVP"); - - /* Add format and rtpmap for each codec. */ - m->desc.fmt_count = 1; - m->attr_count = 0; - - { - pjmedia_sdp_rtpmap rtpmap; - char ptstr[10]; - - sprintf(ptstr, "%d", 0); - pj_strdup2_with_null(pool, &m->desc.fmt[0], ptstr); - rtpmap.pt = m->desc.fmt[0]; - rtpmap.clock_rate = 64000; - rtpmap.enc_name = pj_str("PCMU"); - rtpmap.param.slen = 0; - - } - - /* Add sendrecv attribute. */ - attr = pj_pool_zalloc(pool, sizeof(pjmedia_sdp_attr)); - attr->name = pj_str("sendrecv"); - m->attr[m->attr_count++] = attr; - - /* Done */ - *p_sdp = sdp; - - return PJ_SUCCESS; -} - -static int sip_agent_invite(struct agent *agent, struct session *session) -{ - struct sip_agent *sip_agent = agent_to_sip_agent(agent); - struct sip_client *client = sip_agent->client; - pjsip_dialog *dlg; - pjmedia_sdp_session *sdp; - pjsip_tx_data *tdata; - pj_status_t status; - pj_str_t dst_uri; - - sip_agent->session = session; - - dst_uri = pj_str((char *)sip_agent->identifier); - - /* Create UAC dialog */ - status = pjsip_dlg_create_uac(pjsip_ua_instance(), - &client->local_contact, /* local URI */ - &client->local_contact, /* local Contact */ - &dst_uri, /* remote URI */ - &dst_uri, /* remote target */ - &dlg); /* dialog */ - if (status != PJ_SUCCESS) { - fprintf(stderr, "Failed to create uac dialog\n"); - return -1; - } - - pjsip_auth_clt_set_credentials(&dlg->auth_sess, 1, &client->cred); - - /* Create SDP */ - sip_client_create_sdp(client, dlg->pool, sip_agent, &sdp); - - /* Create the INVITE session. */ - status = pjsip_inv_create_uac(dlg, sdp, 0, &sip_agent->inv); - if (status != PJ_SUCCESS) { - fprintf(stderr, "Failed to create invite session\n"); - pjsip_dlg_terminate(dlg); - return -1; - } - - - /* Attach call data to invite session */ - sip_agent->inv->mod_data[mod_siprtp.id] = sip_agent; - - /* Create initial INVITE request. - * This INVITE request will contain a perfectly good request and - * an SDP body as well. - */ - status = pjsip_inv_invite(sip_agent->inv, &tdata); - PJ_ASSERT_RETURN(status == PJ_SUCCESS, -1); /*TODO*/ - - /* Send initial INVITE request. - * From now on, the invite session's state will be reported to us - * via the invite session callbacks. - */ - status = pjsip_inv_send_msg(sip_agent->inv, tdata); - PJ_ASSERT_RETURN(status == PJ_SUCCESS, -1); /*TODO*/ - - return 0; -} - -static int sip_agent_hangup(struct agent *agent, struct session *session) -{ - struct sip_agent *sip_agent = agent_to_sip_agent(agent); - pjsip_tx_data *tdata; - pj_status_t status; - - printf("hangup %p\n", sip_agent->inv); - - status = pjsip_inv_end_session(sip_agent->inv, 603, NULL, &tdata); - if (status == PJ_SUCCESS && tdata != NULL) - pjsip_inv_send_msg(sip_agent->inv, tdata); - - if (sip_agent->rtp_sockfd) { - event_unregister(sip_agent->rtp_sockfd); - close(sip_agent->rtp_sockfd); - } - if (sip_agent->stream) { - event_unregister(sip_agent->stream->fd); - tapi_stream_free(sip_agent->stream); - } - - sip_agent->inv->mod_data[mod_siprtp.id] = NULL; - free(sip_agent); - - return 0; -} - -static int sip_agent_alloc_stream(struct sip_agent *agent) -{ - int flags; - - if (agent->stream) - printf("BUG!!!! %s:%s[%d]\n", __FILE__, __func__, __LINE__); - - agent->stream = tapi_stream_alloc(agent->client->tdev); - agent->stream_recv_callback.callback = sip_agent_stream_recv_callback; - agent->stream_recv_callback.data = agent; - - flags = fcntl(agent->stream->fd, F_GETFL, 0); - fcntl(agent->stream->fd, F_SETFL, flags | O_NONBLOCK); - - event_register(agent->stream->fd, EPOLLIN, &agent->stream_recv_callback); - - return 0; -} - -static void sip_agent_free_stream(struct sip_agent *agent) -{ - if (!agent->stream) - return; - - event_unregister(agent->stream->fd); - tapi_stream_free(agent->stream); - agent->stream = NULL; -} - -static int sip_agent_accept(struct agent *agent, struct session *session) -{ - struct sip_agent *sip_agent = agent_to_sip_agent(agent); - pj_status_t status; - pjsip_tx_data *tdata; - - /* Create 200 response .*/ - status = pjsip_inv_answer(sip_agent->inv, 200, - NULL, NULL, &tdata); - if (status != PJ_SUCCESS) { - status = pjsip_inv_answer(sip_agent->inv, - PJSIP_SC_NOT_ACCEPTABLE, - NULL, NULL, &tdata); - if (status == PJ_SUCCESS) - pjsip_inv_send_msg(sip_agent->inv, tdata); - else - pjsip_inv_terminate(sip_agent->inv, 500, PJ_FALSE); - return -1; - } - - /* Send the 200 response. */ - status = pjsip_inv_send_msg(sip_agent->inv, tdata); - PJ_ASSERT_ON_FAIL(status == PJ_SUCCESS, return -1); - - sip_agent_alloc_stream(sip_agent); - - return 0; -} - -static int sip_agent_get_endpoint(struct agent *agent, struct session *session) -{ - struct sip_agent *sip_agent = agent_to_sip_agent(agent); - return tapi_stream_get_endpoint(sip_agent->stream); -} - -static const struct agent_ops sip_agent_ops = { - .invite = sip_agent_invite, - .accept = sip_agent_accept, - .hangup = sip_agent_hangup, - .get_endpoint = sip_agent_get_endpoint, -}; - -struct sip_agent *sip_client_alloc_agent(struct sip_client *client, - const char *identifier) -{ - struct sip_agent *agent; - - agent = malloc(sizeof(*agent)); - memset(agent, 0, sizeof(*agent)); - - agent->agent.ops = &sip_agent_ops; - agent->identifier = identifier; - agent->client = client; - - return agent; -} - -/* - * Receive incoming call - */ -static void process_incoming_call(struct sip_client *client, pjsip_rx_data *rdata) -{ - unsigned options; - struct sip_agent *agent; - pjsip_tx_data *tdata; - pj_status_t status; - pjsip_dialog *dlg; - pjmedia_sdp_session *sdp; - - agent = sip_client_alloc_agent(client, "extern"); - - /* Verify that we can handle the request. */ - options = 0; - status = pjsip_inv_verify_request(rdata, &options, NULL, NULL, - client->sip_endpt, &tdata); - if (status != PJ_SUCCESS) { - /* - * No we can't handle the incoming INVITE request. - */ - if (tdata) { - pjsip_response_addr res_addr; - pjsip_get_response_addr(tdata->pool, rdata, &res_addr); - pjsip_endpt_send_response(client->sip_endpt, &res_addr, tdata, - NULL, NULL); - } else { - /* Respond with 500 (Internal Server Error) */ - pjsip_endpt_respond_stateless(client->sip_endpt, rdata, 500, NULL, - NULL, NULL); - } - - return; - } - - /* Create UAS dialog */ - status = pjsip_dlg_create_uas(pjsip_ua_instance(), rdata, - &client->local_contact, &dlg); - if (status != PJ_SUCCESS) { - const pj_str_t reason = pj_str("Unable to create dialog"); - pjsip_endpt_respond_stateless(client->sip_endpt, rdata, - 500, &reason, - NULL, NULL); - return; - } - - /* Create SDP */ - sip_client_create_sdp(client, dlg->pool, agent, &sdp); - - /* Create UAS invite session */ - status = pjsip_inv_create_uas(dlg, rdata, sdp, 0, &agent->inv); - if (status != PJ_SUCCESS) { - pjsip_dlg_create_response(dlg, rdata, 500, NULL, &tdata); - pjsip_dlg_send_response(dlg, pjsip_rdata_get_tsx(rdata), tdata); - return; - } - - /* Attach call data to invite session */ - agent->inv->mod_data[mod_siprtp.id] = agent; - - /* Create 180 response .*/ - status = pjsip_inv_initial_answer(agent->inv, rdata, 180, - NULL, NULL, &tdata); - if (status != PJ_SUCCESS) { - status = pjsip_inv_initial_answer(agent->inv, rdata, - PJSIP_SC_NOT_ACCEPTABLE, - NULL, NULL, &tdata); - if (status == PJ_SUCCESS) - pjsip_inv_send_msg(agent->inv, tdata); - else - pjsip_inv_terminate(agent->inv, 500, PJ_FALSE); - return; - } - - /* Send the 180 response. */ - status = pjsip_inv_send_msg(agent->inv, tdata); - PJ_ASSERT_ON_FAIL(status == PJ_SUCCESS, return); - - if (client->incoming_call_cb) - client->incoming_call_cb(client, agent); -} - -/* Callback to be called to handle incoming requests outside dialogs: */ -static pj_bool_t on_rx_request(pjsip_rx_data *rdata) -{ - struct sip_client *client = global_client; - - /* Ignore strandled ACKs (must not send respone */ - if (rdata->msg_info.msg->line.req.method.id == PJSIP_ACK_METHOD) - return PJ_FALSE; - - /* Respond (statelessly) any non-INVITE requests with 500 */ - if (rdata->msg_info.msg->line.req.method.id != PJSIP_INVITE_METHOD) { - pj_str_t reason = pj_str("Unsupported Operation"); - pjsip_endpt_respond_stateless(client->sip_endpt, rdata, - 500, &reason, - NULL, NULL); - return PJ_TRUE; - } - - /* Handle incoming INVITE */ - process_incoming_call(client, rdata); - - /* Done */ - return PJ_TRUE; -} - -static pjsip_module sip_client_mod = { - NULL, NULL, /* prev, next. */ - { "mod-tapisip", 13 }, /* Name. */ - -1, /* Id */ - PJSIP_MOD_PRIORITY_APPLICATION, /* Priority */ - NULL, /* load() */ - NULL, /* start() */ - NULL, /* stop() */ - NULL, /* unload() */ - &on_rx_request, /* on_rx_request() */ - NULL, /* on_rx_response() */ - NULL, /* on_tx_request. */ - NULL, /* on_tx_response() */ - NULL, /* on_tsx_state() */ -}; - -/* Callback to be called when dialog has forked: */ -static void call_on_forked(pjsip_inv_session *inv, pjsip_event *e) -{ - PJ_UNUSED_ARG(inv); - PJ_UNUSED_ARG(e); -} - -/* Callback to be called when invite session's state has changed: */ -static void call_on_state_changed(pjsip_inv_session *inv, pjsip_event *e) -{ - struct sip_agent *agent = inv->mod_data[mod_siprtp.id]; - - printf("state changed: %d\n", inv->state); - - if (!agent) - return; - - switch (inv->state) { - case PJSIP_INV_STATE_DISCONNECTED: - printf("Disconnected\n"); - if (agent->session) - session_hangup(agent->session, &agent->agent); - if (agent->rtp_sockfd) { - event_unregister(agent->rtp_sockfd); - close(agent->rtp_sockfd); - } - sip_agent_free_stream(agent); - free(agent); - inv->mod_data[mod_siprtp.id] = NULL; - break; - case PJSIP_INV_STATE_CONFIRMED: - printf("Connected: %p\n", agent->stream); - if (agent->stream) - break; - sip_agent_alloc_stream(agent); - session_accept(agent->session, &agent->agent); - break; - default: - break; - } -} - -static void call_on_media_update(pjsip_inv_session *inv, pj_status_t status) -{ - struct sip_agent *agent; - pj_pool_t *pool; - const pjmedia_sdp_session *local_sdp, *remote_sdp; - char local[100]; - char remote[100]; - int i; - - printf("media updte\n"); - - agent = inv->mod_data[mod_siprtp.id]; - pool = inv->dlg->pool; - - /* Do nothing if media negotiation has failed */ - if (status != PJ_SUCCESS) - return; - /* Capture stream definition from the SDP */ - pjmedia_sdp_neg_get_active_local(inv->neg, &local_sdp); - pjmedia_sdp_neg_get_active_remote(inv->neg, &remote_sdp); - - strlcpy(local, local_sdp->conn->addr.ptr, local_sdp->conn->addr.slen + 1); - printf("local media count: %d\n", local_sdp->media_count); - printf("local: %s %d\n", local, - ntohs(local_sdp->media[0]->desc.port)); - strlcpy(remote, remote_sdp->conn->addr.ptr, remote_sdp->conn->addr.slen + 1); - printf("remote media count: %d\n", remote_sdp->media_count); - printf("remote: %s %d\n", remote, - ntohs(remote_sdp->media[0]->desc.port)); - - agent->remote_addr.ss_family = AF_INET; - inet_pton(AF_INET, remote, - sockaddr_get_addr(&agent->remote_addr)); - sockaddr_set_port(&agent->remote_addr, remote_sdp->media[0]->desc.port); - - printf("attributes: %d\n", remote_sdp->attr_count); - for (i = 0; i < remote_sdp->attr_count; ++i) - printf("%s: %s\n", remote_sdp->attr[i]->name.ptr, - remote_sdp->attr[i]->value.ptr); - -} - -static int sip_client_init_sip_endpoint(struct sip_client *client) -{ - pj_status_t status; - pjsip_host_port addrname; - pjsip_inv_callback inv_cb; - pjsip_transport *tp; - char public_addr[INET6_ADDRSTRLEN]; - - global_client = client; - - pj_caching_pool_init(&client->cp, &pj_pool_factory_default_policy, 0); - client->pool = pj_pool_create(&client->cp.factory, "tapi sip", 1000, 1000, NULL); - - status = pjsip_endpt_create(&client->cp.factory, NULL, - &client->sip_endpt); - - client->sockfd = sip_client_create_socket(client, &client->public_addr, 5060, 5100); - if (client->stun) - stun_client_resolve(client->stun, client->sockfd, (struct sockaddr *)&client->public_addr); - - sockaddr_to_string(&client->public_addr, public_addr, sizeof(public_addr)); - - addrname.host = pj_str(public_addr); - addrname.port = sockaddr_get_port(&client->public_addr); - - pjsip_udp_transport_attach(client->sip_endpt, client->sockfd, &addrname, 1, &tp); - - status = pjsip_tsx_layer_init_module(client->sip_endpt); - PJ_ASSERT_RETURN(status == PJ_SUCCESS, status); - - status = pjsip_ua_init_module(client->sip_endpt, NULL); - PJ_ASSERT_RETURN(status == PJ_SUCCESS, status); - - status = pjsip_100rel_init_module(client->sip_endpt); - PJ_ASSERT_RETURN(status == PJ_SUCCESS, status); - - pj_bzero(&inv_cb, sizeof(inv_cb)); - inv_cb.on_state_changed = &call_on_state_changed; - inv_cb.on_new_session = &call_on_forked; - inv_cb.on_media_update = &call_on_media_update; - - status = pjsip_inv_usage_init(client->sip_endpt, &inv_cb); - PJ_ASSERT_RETURN(status == PJ_SUCCESS, 1); - - status = pjsip_endpt_register_module(client->sip_endpt, &sip_client_mod); - - pj_thread_create(client->pool, "sip client", &sip_worker_thread, client, - 0, 0, &client->sip_thread); - - return status; -} - -static void sip_client_register_callback(struct pjsip_regc_cbparam *param) -{ - if (param->status != PJ_SUCCESS || param->code / 100 != 2) - printf("Failed to register: %d %d", param->status, param->code); -} - -void sip_client_free(struct sip_client *client) -{ - pjsip_regc_destroy(client->regc); - pjsip_endpt_destroy(client->sip_endpt); -} - -void sip_client_register(struct sip_client *client) -{ - pjsip_tx_data *tdata; - - pjsip_regc_register(client->regc, true, &tdata); - pjsip_regc_send(client->regc, tdata); -} - -void sip_client_set_cred(struct sip_client *client) -{ - char local_contact[100]; - char server_uri[100]; - char s[INET6_ADDRSTRLEN]; - char contact_addr[INET6_ADDRSTRLEN + 10]; - pj_str_t pj_contact_addr; - - sockaddr_to_string(&client->public_addr, s, sizeof(s)); - - snprintf(contact_addr, sizeof(contact_addr), "sip:%s:%d", s, - sockaddr_get_port(&client->public_addr)); - pj_contact_addr = pj_str(contact_addr); - - client->cred.realm = pj_str((char *)client->config->host); - client->cred.scheme = pj_str("digest"); - client->cred.username = pj_str((char *)client->config->username); - client->cred.data_type = PJSIP_CRED_DATA_PLAIN_PASSWD; - client->cred.data = pj_str((char *)client->config->password); - - snprintf(local_contact, sizeof(local_contact), "sip:%s@%s", - client->config->username, client->config->host); - pj_strdup2_with_null(client->pool, &client->local_contact, local_contact); - - snprintf(server_uri, sizeof(server_uri), "sip:%s\n", client->config->host); - pj_strdup2_with_null(client->pool, &client->server_uri, server_uri); - - pjsip_regc_init(client->regc, &client->server_uri, &client->local_contact, - &client->local_contact, 1, &pj_contact_addr, 3600); - pjsip_regc_set_credentials(client->regc, 1, &client->cred); - - sip_client_register(client); -} - -void sip_client_init(struct sip_client *client, struct tapi_device *tdev, - const struct sip_client_config *config) -{ - global_client = client; - client->config = config; - - client->tdev = tdev; - - iface_get_addr(config->iface, &client->local_addr); - - if (config->stun_host && config->stun_port) - client->stun = stun_client_alloc(config->stun_host, config->stun_port); - else - client->stun = NULL; - - sip_client_init_sip_endpoint(client); - - pjsip_regc_create(client->sip_endpt, client, sip_client_register_callback, - &client->regc); - - sip_client_set_cred(client); -} - - |