X-Git-Url: http://git.eversberg.eu/gitweb.cgi?p=lcr.git;a=blobdiff_plain;f=gsm_ms.cpp;h=b966ad82654aaf8958b21169934dda49749ef4a1;hp=551fcad6b47a3f90542c21a9661b863ee1ae2351;hb=41a0668da1dbd5644a50036eaa26c8ba85201ffd;hpb=6e1e99808e5b1c16b00904d31f95d0b74487023e diff --git a/gsm_ms.cpp b/gsm_ms.cpp index 551fcad..b966ad8 100644 --- a/gsm_ms.cpp +++ b/gsm_ms.cpp @@ -10,53 +10,37 @@ \*****************************************************************************/ #include "main.h" +#include "mncc.h" -#ifndef _GNU_SOURCE -#define _GNU_SOURCE -#endif -extern "C" { -#include - -#include -#include - -#include -#include -#include -#include -} - -const char *openbsc_copyright = ""; -short vty_port = 4247; -struct llist_head ms_list; -struct log_target *stderr_target; -void *l23_ctx = NULL; -int (*l23_app_work) (struct osmocom_ms *ms) = NULL; -int (*l23_app_exit) (struct osmocom_ms *ms) = NULL; +struct lcr_gsm *gsm_ms_first = NULL; static int dtmf_timeout(struct lcr_timer *timer, void *instance, int index); +#define DTMF_ST_IDLE 0 /* no DTMF active */ +#define DTMF_ST_START 1 /* DTMF started, waiting for resp. */ +#define DTMF_ST_MARK 2 /* wait tone duration */ +#define DTMF_ST_STOP 3 /* DTMF stopped, waiting for resp. */ +#define DTMF_ST_SPACE 4 /* wait space between tones */ + /* * constructor */ Pgsm_ms::Pgsm_ms(int type, struct mISDNport *mISDNport, char *portname, struct port_settings *settings, int channel, int exclusive, int mode) : Pgsm(type, mISDNport, portname, settings, channel, exclusive, mode) { - struct osmocom_ms *ms = NULL; + struct lcr_gsm *gsm_ms = gsm_ms_first; char *ms_name = mISDNport->ifport->gsm_ms_name; - p_m_g_instance = NULL; + p_m_g_lcr_gsm = NULL; - llist_for_each_entry(ms, &ms_list, entity) { - if (!strcmp(ms->name, ms_name)) { - p_m_g_instance = ms; + while (gsm_ms) { + if (gsm_ms->type == LCR_GSM_TYPE_MS && !strcmp(gsm_ms->name, ms_name)) { + p_m_g_lcr_gsm = gsm_ms; break; } + gsm_ms = gsm_ms->gsm_ms_next; } - if (!p_m_g_instance) - FATAL("MS name %s does not exists. Please fix!"); - p_m_g_dtmf_state = DTMF_ST_IDLE; p_m_g_dtmf_index = 0; p_m_g_dtmf[0] = '\0'; @@ -105,7 +89,7 @@ void Pgsm_ms::setup_ind(unsigned int msg_type, unsigned int callref, struct gsm_ add_trace("cause", "value", "%d", mncc->cause.value); add_trace("reason", NULL, "callref already in use"); end_trace(); - send_and_free_mncc(p_m_g_instance, mncc->msg_type, mncc); + send_and_free_mncc(p_m_g_lcr_gsm, mncc->msg_type, mncc); new_state(PORT_STATE_RELEASE); trigger_work(&p_m_g_delete); return; @@ -126,7 +110,7 @@ void Pgsm_ms::setup_ind(unsigned int msg_type, unsigned int callref, struct gsm_ add_trace("cause", "value", "%d", mncc->cause.value); add_trace("reason", NULL, "port is blocked"); end_trace(); - send_and_free_mncc(p_m_g_instance, mncc->msg_type, mncc); + send_and_free_mncc(p_m_g_lcr_gsm, mncc->msg_type, mncc); new_state(PORT_STATE_RELEASE); trigger_work(&p_m_g_delete); return; @@ -318,7 +302,7 @@ void Pgsm_ms::setup_ind(unsigned int msg_type, unsigned int callref, struct gsm_ add_trace("cause", "value", "%d", mncc->cause.value); add_trace("reason", NULL, "no channel"); end_trace(); - send_and_free_mncc(p_m_g_instance, mncc->msg_type, mncc); + send_and_free_mncc(p_m_g_lcr_gsm, mncc->msg_type, mncc); new_state(PORT_STATE_RELEASE); trigger_work(&p_m_g_delete); return; @@ -340,9 +324,10 @@ void Pgsm_ms::setup_ind(unsigned int msg_type, unsigned int callref, struct gsm_ gsm_trace_header(p_m_mISDNport, this, MNCC_LCHAN_MODIFY, DIRECTION_OUT); mode = create_mncc(MNCC_LCHAN_MODIFY, p_m_g_callref); mode->lchan_mode = 0x01; /* GSM V1 */ + mode->lchan_type = 0x02; add_trace("mode", NULL, "0x%02x", mode->lchan_mode); end_trace(); - send_and_free_mncc(p_m_g_instance, mode->msg_type, mode); + send_and_free_mncc(p_m_g_lcr_gsm, mode->msg_type, mode); /* send call proceeding */ gsm_trace_header(p_m_mISDNport, this, MNCC_CALL_CONF_REQ, DIRECTION_OUT); @@ -352,7 +337,7 @@ void Pgsm_ms::setup_ind(unsigned int msg_type, unsigned int callref, struct gsm_ proceeding->fields |= MNCC_F_CCCAP; proceeding->cccap.dtmf = 1; end_trace(); - send_and_free_mncc(p_m_g_instance, proceeding->msg_type, proceeding); + send_and_free_mncc(p_m_g_lcr_gsm, proceeding->msg_type, proceeding); new_state(PORT_STATE_IN_PROCEEDING); @@ -360,7 +345,7 @@ void Pgsm_ms::setup_ind(unsigned int msg_type, unsigned int callref, struct gsm_ gsm_trace_header(p_m_mISDNport, this, MNCC_FRAME_RECV, DIRECTION_OUT); end_trace(); frame = create_mncc(MNCC_FRAME_RECV, p_m_g_callref); - send_and_free_mncc(p_m_g_instance, frame->msg_type, frame); + send_and_free_mncc(p_m_g_lcr_gsm, frame->msg_type, frame); p_m_g_tch_connected = 1; } @@ -381,7 +366,7 @@ void Pgsm_ms::setup_ind(unsigned int msg_type, unsigned int callref, struct gsm_ /* * MS sends message to port */ -static int message_ms(struct osmocom_ms *ms, int msg_type, void *arg) +int message_ms(struct lcr_gsm *gsm_ms, int msg_type, void *arg) { struct gsm_mncc *mncc = (struct gsm_mncc *)arg; unsigned int callref = mncc->callref; @@ -391,7 +376,7 @@ static int message_ms(struct osmocom_ms *ms, int msg_type, void *arg) struct mISDNport *mISDNport; /* Special messages */ - if (msg_type) { + switch (msg_type) { } /* find callref */ @@ -419,7 +404,7 @@ static int message_ms(struct osmocom_ms *ms, int msg_type, void *arg) /* find gsm ms port */ mISDNport = mISDNport_first; while(mISDNport) { - if (mISDNport->gsm_ms && !strcmp(mISDNport->ifport->gsm_ms_name, ms->name)) + if (mISDNport->gsm_ms && !strcmp(mISDNport->ifport->gsm_ms_name, gsm_ms->name)) break; mISDNport = mISDNport->next; } @@ -436,7 +421,7 @@ static int message_ms(struct osmocom_ms *ms, int msg_type, void *arg) add_trace("cause", "location", "%d", rej->cause.location); add_trace("cause", "value", "%d", rej->cause.value); end_trace(); - send_and_free_mncc(ms, rej->msg_type, rej); + send_and_free_mncc(gsm_ms, rej->msg_type, rej); return 0; } /* creating port object, transparent until setup with hdlc */ @@ -508,6 +493,20 @@ void Pgsm_ms::message_setup(unsigned int epoint_id, int message_id, union parame memcpy(&p_capainfo, ¶m->setup.capainfo, sizeof(p_capainfo)); memcpy(&p_redirinfo, ¶m->setup.redirinfo, sizeof(p_redirinfo)); + /* no instance */ + if (!p_m_g_lcr_gsm || p_m_g_lcr_gsm->mncc_lfd.fd < 0) { + gsm_trace_header(p_m_mISDNport, this, MNCC_SETUP_REQ, DIRECTION_OUT); + add_trace("failure", NULL, "MS %s instance is unavailable", p_m_mISDNport->ifport->gsm_ms_name); + end_trace(); + message = message_create(p_serial, epoint_id, PORT_TO_EPOINT, MESSAGE_RELEASE); + message->param.disconnectinfo.cause = 41; + message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL; + message_put(message); + new_state(PORT_STATE_RELEASE); + trigger_work(&p_m_g_delete); + return; + } + /* no number */ if (!p_dialinginfo.id[0]) { gsm_trace_header(p_m_mISDNport, this, MNCC_SETUP_REQ, DIRECTION_OUT); @@ -632,7 +631,7 @@ void Pgsm_ms::message_setup(unsigned int epoint_id, int message_id, union parame } end_trace(); - send_and_free_mncc(p_m_g_instance, mncc->msg_type, mncc); + send_and_free_mncc(p_m_g_lcr_gsm, mncc->msg_type, mncc); new_state(PORT_STATE_OUT_SETUP); @@ -662,7 +661,7 @@ void Pgsm_ms::dtmf_statemachine(struct gsm_mncc *mncc) PDEBUG(DEBUG_GSM, "start DTMF (keypad %c)\n", dtmf->keypad); end_trace(); - send_and_free_mncc(p_m_g_instance, dtmf->msg_type, dtmf); + send_and_free_mncc(p_m_g_lcr_gsm, dtmf->msg_type, dtmf); return; case DTMF_ST_START: if (mncc->msg_type != MNCC_START_DTMF_RSP) { @@ -678,7 +677,7 @@ void Pgsm_ms::dtmf_statemachine(struct gsm_mncc *mncc) dtmf = create_mncc(MNCC_STOP_DTMF_REQ, p_m_g_callref); p_m_g_dtmf_state = DTMF_ST_STOP; end_trace(); - send_and_free_mncc(p_m_g_instance, dtmf->msg_type, dtmf); + send_and_free_mncc(p_m_g_lcr_gsm, dtmf->msg_type, dtmf); return; case DTMF_ST_STOP: schedule_timer(&p_m_g_dtmf_timer, 0, 120 * 1000); @@ -782,101 +781,108 @@ int Pgsm_ms::message_epoint(unsigned int epoint_id, int message_id, union parame int gsm_ms_exit(int rc) { + /* destroy all instances */ + while (gsm_ms_first) + gsm_ms_delete(gsm_ms_first->name); - return(rc); + return rc; } int gsm_ms_init(void) { - INIT_LLIST_HEAD(&ms_list); - log_init(&log_info); - stderr_target = log_target_create_stderr(); - log_add_target(stderr_target); - log_set_all_filter(stderr_target, 1); - - l23_ctx = talloc_named_const(NULL, 1, "layer2 context"); - return 0; } /* add a new GSM mobile instance */ -int gsm_ms_new(const char *name, const char *socket_path) +int gsm_ms_new(const char *name) { - struct osmocom_ms *ms = NULL; - int rc; + struct lcr_gsm *gsm_ms = gsm_ms_first, **gsm_ms_p = &gsm_ms_first; - PDEBUG(DEBUG_GSM, "GSM: creating new instance '%s' on '%s'\n", name, socket_path); - - ms = talloc_zero(l23_ctx, struct osmocom_ms); - if (!ms) { - FATAL("Failed to allocate MS\n"); + while (gsm_ms) { + gsm_ms_p = &gsm_ms->gsm_ms_next; + gsm_ms = gsm_ms->gsm_ms_next; } - /* must add here, because other init processes may search in the list */ - llist_add_tail(&ms->entity, &ms_list); + PDEBUG(DEBUG_GSM, "GSM: interface for MS '%s' is created\n", name); - SPRINT(ms->name, name); + /* create gsm instance */ + gsm_ms = (struct lcr_gsm *)MALLOC(sizeof(struct lcr_gsm)); - rc = layer2_open(ms, socket_path); - if (rc < 0) { - FATAL("Failed during layer2_open()\n"); - } + gsm_ms->type = LCR_GSM_TYPE_MS; + SCPY(gsm_ms->name, name); + gsm_ms->sun.sun_family = AF_UNIX; + SPRINT(gsm_ms->sun.sun_path, "/tmp/ms_mncc_%s", name); - lapdm_init(&ms->l2_entity.lapdm_dcch, ms); - lapdm_init(&ms->l2_entity.lapdm_acch, ms); + memset(&gsm_ms->socket_retry, 0, sizeof(gsm_ms->socket_retry)); + add_timer(&gsm_ms->socket_retry, mncc_socket_retry_cb, gsm_ms, 0); - rc = l23_app_init(ms); - if (rc < 0) { - FATAL("Failed to init layer23\n"); - } - ms->mncc_entity.mncc_recv = message_ms; + /* do the initial connect */ + mncc_socket_retry_cb(&gsm_ms->socket_retry, gsm_ms, 0); + + *gsm_ms_p = gsm_ms; return 0; } int gsm_ms_delete(const char *name) { - struct osmocom_ms *ms = NULL; - int found = 0; + struct lcr_gsm *gsm_ms = gsm_ms_first, **gsm_ms_p = &gsm_ms_first; +// class Port *port; +// class Pgsm_ms *pgsm_ms = NULL; - PDEBUG(DEBUG_GSM, "GSM: destroying instance '%s'\n", name); + PDEBUG(DEBUG_GSM, "GSM: interface for MS '%s' is deleted\n", name); - llist_for_each_entry(ms, &ms_list, entity) { - if (!strcmp(ms->name, name)) { - found = 1; + while (gsm_ms) { + if (gsm_ms->type == LCR_GSM_TYPE_MS && !strcmp(gsm_ms->name, name)) break; - } + gsm_ms_p = &gsm_ms->gsm_ms_next; + gsm_ms = gsm_ms->gsm_ms_next; } - if (!found) { - FATAL("Failed delete layer23, instance '%s' not found\n", name); + if (!gsm_ms) + return 0; + +/* not needed, because: + * - shutdown of interface will destry port instances locally + * - closing of socket will make remote socket destroy calls locally + */ +#if 0 + port = port_first; + while(port) { + if ((port->p_type & PORT_CLASS_GSM_MASK) == PORT_CLASS_GSM_MS) { + pgsm_ms = (class Pgsm_ms *)port; + if (pgsm_ms->p_m_g_lcr_gsm == gsm_ms && pgsm_ms->p_m_g_callref) { + struct gsm_mncc *rej; + + rej = create_mncc(MNCC_REL_REQ, pgsm_ms->p_m_g_callref); + rej->fields |= MNCC_F_CAUSE; + rej->cause.coding = 3; + rej->cause.location = 1; + rej->cause.value = 27; + gsm_trace_header(NULL, NULL, MNCC_REJ_REQ, DIRECTION_OUT); + add_trace("cause", "coding", "%d", rej->cause.coding); + add_trace("cause", "location", "%d", rej->cause.location); + add_trace("cause", "value", "%d", rej->cause.value); + end_trace(); + send_and_free_mncc(gsm_ms, rej->msg_type, rej); + pgsm_ms->new_state(PORT_STATE_RELEASE); + trigger_work(&pgsm_ms->p_m_g_delete); + } + } } +#endif - l23_app_exit(ms); - lapdm_exit(&ms->l2_entity.lapdm_dcch); - lapdm_exit(&ms->l2_entity.lapdm_acch); + if (gsm_ms->mncc_lfd.fd > -1) { + close(gsm_ms->mncc_lfd.fd); + unregister_fd(&gsm_ms->mncc_lfd); + } + del_timer(&gsm_ms->socket_retry); - llist_del(&ms->entity); + /* remove instance from list */ + *gsm_ms_p = gsm_ms->gsm_ms_next; + FREE(gsm_ms, sizeof(struct lcr_gsm)); return 0; } -/* - * handles bsc select function within LCR's main loop - */ -int handle_gsm_ms(void) -{ - struct osmocom_ms *ms = NULL; - int work = 0; - - llist_for_each_entry(ms, &ms_list, entity) { - if (l23_app_work(ms)) - work = 1; -// debug_reset_context(); - if (bsc_select_main(1)) /* polling */ - work = 1; - } - - return work; -}