From ed5cacb240b846c106f0fc6a3ab8e8721f4c70a5 Mon Sep 17 00:00:00 2001 From: Pablo Neira Ayuso Date: Wed, 17 Aug 2011 22:44:07 +0200 Subject: src: port openBSC over libosmo-abis This is a big patch that ports openBSC over libosmo-abis. Sorry, the changes that are included here are all dependent of libosmo-abis, splitting them into smaller pieces would leave the repository in some intermediate state, which is not desired. The main changes are: - The directory libabis/ has been removed as it now lives in libosmo-abis. - new configuration file format for nanoBTS and HSL femto, we need to define the virtual e1_line and attach it to the OML link. - all the existing BTS drivers (nanoBTS, hsl femto, Nokia site, BS11 and rbs2000) now use the new libosmo-abis framework. - use r232 input driver available in libosmo-abis for bs11_config. - use ipa_msg_recv instead of old ipaccess_read_msg function. - delete definition of gsm_e1_subslot and input_signal_data. These structures now lives in libosmo-abis. Most of this patch are deletions of libabis/ which has been moved to libosmo-abis. This patch also modifies openBSC to use all the new definitions available in libosmocore and libosmo-abis. In order to do that, we have replaced the following: - DINP, DMI, DMIB and DMUX by their respective DL* correspondences. - SS_GLOBAL by SS_L_GLOBAL - SS_INPUT by SS_L_INPUT - S_GLOBAL_SHUTDOWN by S_L_GLOBAL_SHUTDOWN - SS_INPUT by SS_L_INPUT - S_INP_* by S_L_INP_* sub-signals - E1INP_NODE by L_E1INP_NODE vty node This patch has been tested with: - one nanoBTS - the HSL femto with the examples available under libosmo-abis - BS11 with both dahdi and misdn drivers. --- openbsc/src/libabis/input/ipaccess.c | 842 ----------------------------------- 1 file changed, 842 deletions(-) delete mode 100644 openbsc/src/libabis/input/ipaccess.c (limited to 'openbsc/src/libabis/input/ipaccess.c') diff --git a/openbsc/src/libabis/input/ipaccess.c b/openbsc/src/libabis/input/ipaccess.c deleted file mode 100644 index 2d6764e25..000000000 --- a/openbsc/src/libabis/input/ipaccess.c +++ /dev/null @@ -1,842 +0,0 @@ -/* OpenBSC Abis input driver for ip.access */ - -/* (C) 2009 by Harald Welte - * (C) 2010 by Holger Hans Peter Freyther - * (C) 2010 by On-Waves - * - * All Rights Reserved - * - * This program is free software; you can redistribute it and/or modify - * it under the terms of the GNU Affero General Public License as published by - * the Free Software Foundation; either version 3 of the License, or - * (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU Affero General Public License for more details. - * - * You should have received a copy of the GNU Affero General Public License - * along with this program. If not, see . - * - */ - -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include - -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include - -#define PRIV_OML 1 -#define PRIV_RSL 2 - -/* data structure for one E1 interface with A-bis */ -struct ia_e1_handle { - struct osmo_fd listen_fd; - struct osmo_fd rsl_listen_fd; - struct gsm_network *gsmnet; -}; - -static struct ia_e1_handle *e1h; - - -#define TS1_ALLOC_SIZE 900 - -/* - * Common propietary IPA messages: - * - PONG: in reply to PING. - * - ID_REQUEST: first messages once OML has been established. - * - ID_ACK: in reply to ID_ACK. - */ -const uint8_t ipa_pong_msg[] = { - 0, 1, IPAC_PROTO_IPACCESS, IPAC_MSGT_PONG -}; - -const uint8_t ipa_id_ack_msg[] = { - 0, 1, IPAC_PROTO_IPACCESS, IPAC_MSGT_ID_ACK -}; - -const uint8_t ipa_id_req_msg[] = { - 0, 17, IPAC_PROTO_IPACCESS, IPAC_MSGT_ID_GET, - 0x01, IPAC_IDTAG_UNIT, - 0x01, IPAC_IDTAG_MACADDR, - 0x01, IPAC_IDTAG_LOCATION1, - 0x01, IPAC_IDTAG_LOCATION2, - 0x01, IPAC_IDTAG_EQUIPVERS, - 0x01, IPAC_IDTAG_SWVERSION, - 0x01, IPAC_IDTAG_UNITNAME, - 0x01, IPAC_IDTAG_SERNR, -}; - -static const char *idtag_names[] = { - [IPAC_IDTAG_SERNR] = "Serial_Number", - [IPAC_IDTAG_UNITNAME] = "Unit_Name", - [IPAC_IDTAG_LOCATION1] = "Location_1", - [IPAC_IDTAG_LOCATION2] = "Location_2", - [IPAC_IDTAG_EQUIPVERS] = "Equipment_Version", - [IPAC_IDTAG_SWVERSION] = "Software_Version", - [IPAC_IDTAG_IPADDR] = "IP_Address", - [IPAC_IDTAG_MACADDR] = "MAC_Address", - [IPAC_IDTAG_UNIT] = "Unit_ID", -}; - -const char *ipaccess_idtag_name(uint8_t tag) -{ - if (tag >= ARRAY_SIZE(idtag_names)) - return "unknown"; - - return idtag_names[tag]; -} - -int ipaccess_idtag_parse(struct tlv_parsed *dec, unsigned char *buf, int len) -{ - uint8_t t_len; - uint8_t t_tag; - uint8_t *cur = buf; - - memset(dec, 0, sizeof(*dec)); - - while (len >= 2) { - len -= 2; - t_len = *cur++; - t_tag = *cur++; - - if (t_len > len + 1) { - LOGP(DMI, LOGL_ERROR, "The tag does not fit: %d\n", t_len); - return -EINVAL; - } - - DEBUGPC(DMI, "%s='%s' ", ipaccess_idtag_name(t_tag), cur); - - dec->lv[t_tag].len = t_len; - dec->lv[t_tag].val = cur; - - cur += t_len; - len -= t_len; - } - return 0; -} - -struct gsm_bts *find_bts_by_unitid(struct gsm_network *net, - uint16_t site_id, uint16_t bts_id) -{ - struct gsm_bts *bts; - - llist_for_each_entry(bts, &net->bts_list, list) { - - if (!is_ipaccess_bts(bts)) - continue; - - if (bts->ip_access.site_id == site_id && - bts->ip_access.bts_id == bts_id) - return bts; - } - - return NULL; -} - -int ipaccess_parse_unitid(const char *str, uint16_t *site_id, - uint16_t *bts_id, uint16_t *trx_id) -{ - unsigned long ul; - char *endptr; - const char *nptr; - - nptr = str; - ul = strtoul(nptr, &endptr, 10); - if (endptr <= nptr) - return -EINVAL; - if (site_id) - *site_id = ul & 0xffff; - - if (*endptr++ != '/') - return -EINVAL; - - nptr = endptr; - ul = strtoul(nptr, &endptr, 10); - if (endptr <= nptr) - return -EINVAL; - if (bts_id) - *bts_id = ul & 0xffff; - - if (*endptr++ != '/') - return -EINVAL; - - nptr = endptr; - ul = strtoul(nptr, &endptr, 10); - if (endptr <= nptr) - return -EINVAL; - if (trx_id) - *trx_id = ul & 0xffff; - - return 0; -} - -static int ipaccess_send(int fd, const void *msg, size_t msglen) -{ - int ret; - - ret = write(fd, msg, msglen); - if (ret < 0) - return ret; - if (ret < msglen) { - LOGP(DINP, LOGL_ERROR, "ipaccess_send: short write\n"); - return -EIO; - } - return ret; -} - -int ipaccess_send_pong(int fd) -{ - return ipaccess_send(fd, ipa_pong_msg, sizeof(ipa_pong_msg)); -} - -int ipaccess_send_id_ack(int fd) -{ - return ipaccess_send(fd, ipa_id_ack_msg, sizeof(ipa_id_ack_msg)); -} - -int ipaccess_send_id_req(int fd) -{ - return ipaccess_send(fd, ipa_id_req_msg, sizeof(ipa_id_req_msg)); -} - -/* base handling of the ip.access protocol */ -int ipaccess_rcvmsg_base(struct msgb *msg, - struct osmo_fd *bfd) -{ - uint8_t msg_type = *(msg->l2h); - int ret = 0; - - switch (msg_type) { - case IPAC_MSGT_PING: - ret = ipaccess_send_pong(bfd->fd); - break; - case IPAC_MSGT_PONG: - DEBUGP(DMI, "PONG!\n"); - break; - case IPAC_MSGT_ID_ACK: - DEBUGP(DMI, "ID_ACK? -> ACK!\n"); - ret = ipaccess_send_id_ack(bfd->fd); - break; - } - return 0; -} - -static int ipaccess_rcvmsg(struct e1inp_line *line, struct msgb *msg, - struct osmo_fd *bfd) -{ - struct tlv_parsed tlvp; - uint8_t msg_type = *(msg->l2h); - uint16_t site_id = 0, bts_id = 0, trx_id = 0; - struct gsm_bts *bts; - char *unitid; - int len, ret; - - /* handle base messages */ - ipaccess_rcvmsg_base(msg, bfd); - - switch (msg_type) { - case IPAC_MSGT_ID_RESP: - DEBUGP(DMI, "ID_RESP "); - /* parse tags, search for Unit ID */ - ret = ipaccess_idtag_parse(&tlvp, (uint8_t *)msg->l2h + 2, - msgb_l2len(msg)-2); - DEBUGP(DMI, "\n"); - if (ret < 0) { - LOGP(DINP, LOGL_ERROR, "ignoring IPA response message " - "with malformed TLVs\n"); - return ret; - } - if (!TLVP_PRESENT(&tlvp, IPAC_IDTAG_UNIT)) - break; - - len = TLVP_LEN(&tlvp, IPAC_IDTAG_UNIT); - if (len < 1) - break; - - /* lookup BTS, create sign_link, ... */ - unitid = (char *) TLVP_VAL(&tlvp, IPAC_IDTAG_UNIT); - unitid[len - 1] = '\0'; - ipaccess_parse_unitid(unitid, &site_id, &bts_id, &trx_id); - bts = find_bts_by_unitid(e1h->gsmnet, site_id, bts_id); - if (!bts) { - LOGP(DINP, LOGL_ERROR, "Unable to find BTS configuration for " - " %u/%u/%u, disconnecting\n", site_id, bts_id, - trx_id); - return -EIO; - } - DEBUGP(DINP, "Identified BTS %u/%u/%u\n", site_id, bts_id, trx_id); - if (bfd->priv_nr == PRIV_OML) { - /* drop any old oml connection */ - ipaccess_drop_oml(bts); - bts->oml_link = e1inp_sign_link_create(&line->ts[PRIV_OML - 1], - E1INP_SIGN_OML, bts->c0, - bts->oml_tei, 0); - } else if (bfd->priv_nr == PRIV_RSL) { - struct e1inp_ts *e1i_ts; - struct osmo_fd *newbfd; - struct gsm_bts_trx *trx = gsm_bts_trx_num(bts, trx_id); - - /* drop any old rsl connection */ - ipaccess_drop_rsl(trx); - - if (!bts->oml_link) { - osmo_fd_unregister(bfd); - close(bfd->fd); - bfd->fd = -1; - talloc_free(bfd); - return 0; - } - - bfd->data = line = bts->oml_link->ts->line; - e1i_ts = &line->ts[PRIV_RSL + trx_id - 1]; - newbfd = &e1i_ts->driver.ipaccess.fd; - e1inp_ts_config(e1i_ts, line, E1INP_TS_TYPE_SIGN); - - trx->rsl_link = e1inp_sign_link_create(e1i_ts, - E1INP_SIGN_RSL, trx, - trx->rsl_tei, 0); - trx->rsl_link->ts->sign.delay = 0; - - /* get rid of our old temporary bfd */ - memcpy(newbfd, bfd, sizeof(*newbfd)); - newbfd->priv_nr = PRIV_RSL + trx_id; - osmo_fd_unregister(bfd); - bfd->fd = -1; - talloc_free(bfd); - osmo_fd_register(newbfd); - } - break; - } - return 0; -} - -#define OML_UP 0x0001 -#define RSL_UP 0x0002 - -/* - * read one ipa message from the socket - * return NULL in case of error - */ -struct msgb *ipaccess_read_msg(struct osmo_fd *bfd, int *error) -{ - struct msgb *msg = msgb_alloc(TS1_ALLOC_SIZE, "Abis/IP"); - struct ipaccess_head *hh; - int len, ret = 0; - - if (!msg) { - *error = -ENOMEM; - return NULL; - } - - /* first read our 3-byte header */ - hh = (struct ipaccess_head *) msg->data; - ret = recv(bfd->fd, msg->data, sizeof(*hh), 0); - if (ret == 0) { - msgb_free(msg); - *error = ret; - return NULL; - } else if (ret != sizeof(*hh)) { - if (errno != EAGAIN) - LOGP(DINP, LOGL_ERROR, "recv error %d %s\n", ret, strerror(errno)); - msgb_free(msg); - *error = ret; - return NULL; - } - - msgb_put(msg, ret); - - /* then read te length as specified in header */ - msg->l2h = msg->data + sizeof(*hh); - len = ntohs(hh->len); - - if (len < 0 || TS1_ALLOC_SIZE < len + sizeof(*hh)) { - LOGP(DINP, LOGL_ERROR, "Can not read this packet. %d avail\n", len); - msgb_free(msg); - *error = -EIO; - return NULL; - } - - ret = recv(bfd->fd, msg->l2h, len, 0); - if (ret < len) { - LOGP(DINP, LOGL_ERROR, "short read! Got %d from %d\n", ret, len); - msgb_free(msg); - *error = -EIO; - return NULL; - } - msgb_put(msg, ret); - - return msg; -} - -int ipaccess_drop_oml(struct gsm_bts *bts) -{ - struct gsm_bts_trx *trx; - struct e1inp_ts *ts; - struct e1inp_line *line; - struct osmo_fd *bfd; - - if (!bts || !bts->oml_link) - return -1; - - /* send OML down */ - ts = bts->oml_link->ts; - line = ts->line; - e1inp_event(ts, S_INP_TEI_DN, bts->oml_link->tei, bts->oml_link->sapi); - - bfd = &ts->driver.ipaccess.fd; - osmo_fd_unregister(bfd); - close(bfd->fd); - bfd->fd = -1; - - /* clean up OML and RSL */ - e1inp_sign_link_destroy(bts->oml_link); - bts->oml_link = NULL; - bts->ip_access.flags = 0; - - /* drop all RSL connections too */ - llist_for_each_entry(trx, &bts->trx_list, list) - ipaccess_drop_rsl(trx); - - /* kill the E1 line now... as we have no one left to use it */ - talloc_free(line); - - return -1; -} - -static int ipaccess_drop(struct e1inp_ts *ts, struct osmo_fd *bfd) -{ - struct e1inp_sign_link *link; - int bts_nr; - - if (!ts || !bfd->data) { - /* - * If we don't have a TS this means that this is a RSL - * connection but we are not past the authentication - * handling yet. So we can safely delete this bfd and - * wait for a reconnect. - * If we don't have bfd->data this means that a RSL - * connection was accept()ed, but nothing was recv()ed - * and the connection gets close()ed. - */ - osmo_fd_unregister(bfd); - close(bfd->fd); - bfd->fd = -1; - talloc_free(bfd); - return -1; - } - - /* attempt to find a signalling link */ - if (ts->type == E1INP_TS_TYPE_SIGN) { - llist_for_each_entry(link, &ts->sign.sign_links, list) { - bts_nr = link->trx->bts->bts_nr; - /* we have issues just reconnecting RLS so we drop OML */ - ipaccess_drop_oml(link->trx->bts); - return bts_nr; - } - } - - /* error case */ - LOGP(DINP, LOGL_ERROR, "Failed to find a signalling link for ts: %p\n", ts); - osmo_fd_unregister(bfd); - close(bfd->fd); - bfd->fd = -1; - return -1; -} - -int ipaccess_drop_rsl(struct gsm_bts_trx *trx) -{ - struct osmo_fd *bfd; - struct e1inp_ts *ts; - - if (!trx || !trx->rsl_link) - return -1; - - /* send RSL down */ - ts = trx->rsl_link->ts; - e1inp_event(ts, S_INP_TEI_DN, trx->rsl_link->tei, trx->rsl_link->sapi); - - /* close the socket */ - bfd = &ts->driver.ipaccess.fd; - osmo_fd_unregister(bfd); - close(bfd->fd); - bfd->fd = -1; - - /* destroy */ - e1inp_sign_link_destroy(trx->rsl_link); - trx->rsl_link = NULL; - - return -1; -} - -static int handle_ts1_read(struct osmo_fd *bfd) -{ - struct e1inp_line *line = bfd->data; - unsigned int ts_nr = bfd->priv_nr; - struct e1inp_ts *e1i_ts = &line->ts[ts_nr-1]; - struct e1inp_sign_link *link; - struct msgb *msg; - struct ipaccess_head *hh; - int ret = 0, error; - - msg = ipaccess_read_msg(bfd, &error); - if (!msg) { - if (error == 0) { - int ret = ipaccess_drop(e1i_ts, bfd); - if (ret >= 0) - LOGP(DINP, LOGL_NOTICE, "BTS %u disappeared, dead socket\n", - ret); - else - LOGP(DINP, LOGL_NOTICE, "unknown BTS disappeared, dead socket\n"); - } - return error; - } - - DEBUGP(DMI, "RX %u: %s\n", ts_nr, osmo_hexdump(msgb_l2(msg), msgb_l2len(msg))); - - hh = (struct ipaccess_head *) msg->data; - if (hh->proto == IPAC_PROTO_IPACCESS) { - ret = ipaccess_rcvmsg(line, msg, bfd); - if (ret < 0) - ipaccess_drop(e1i_ts, bfd); - msgb_free(msg); - return ret; - } - /* BIG FAT WARNING: bfd might no longer exist here, since ipaccess_rcvmsg() - * might have free'd it !!! */ - - link = e1inp_lookup_sign_link(e1i_ts, hh->proto, 0); - if (!link) { - LOGP(DINP, LOGL_ERROR, "no matching signalling link for " - "hh->proto=0x%02x\n", hh->proto); - msgb_free(msg); - return -EIO; - } - msg->dst = link; - - switch (link->type) { - case E1INP_SIGN_RSL: - if (!(link->trx->bts->ip_access.flags & (RSL_UP << link->trx->nr))) { - e1inp_event(e1i_ts, S_INP_TEI_UP, link->tei, link->sapi); - link->trx->bts->ip_access.flags |= (RSL_UP << link->trx->nr); - } - ret = abis_rsl_rcvmsg(msg); - break; - case E1INP_SIGN_OML: - if (!(link->trx->bts->ip_access.flags & OML_UP)) { - e1inp_event(e1i_ts, S_INP_TEI_UP, link->tei, link->sapi); - link->trx->bts->ip_access.flags |= OML_UP; - } - ret = abis_nm_rcvmsg(msg); - break; - default: - LOGP(DINP, LOGL_NOTICE, "Unknown IP.access protocol proto=0x%02x\n", hh->proto); - msgb_free(msg); - break; - } - return ret; -} - -void ipaccess_prepend_header_ext(struct msgb *msg, int proto) -{ - struct ipaccess_head_ext *hh_ext; - - /* prepend the osmo ip.access header extension */ - hh_ext = (struct ipaccess_head_ext *) msgb_push(msg, sizeof(*hh_ext)); - hh_ext->proto = proto; -} - -void ipaccess_prepend_header(struct msgb *msg, int proto) -{ - struct ipaccess_head *hh; - - /* prepend the ip.access header */ - hh = (struct ipaccess_head *) msgb_push(msg, sizeof(*hh)); - hh->len = htons(msg->len - sizeof(*hh)); - hh->proto = proto; -} - -static int ts_want_write(struct e1inp_ts *e1i_ts) -{ - e1i_ts->driver.ipaccess.fd.when |= BSC_FD_WRITE; - - return 0; -} - -static void timeout_ts1_write(void *data) -{ - struct e1inp_ts *e1i_ts = (struct e1inp_ts *)data; - - /* trigger write of ts1, due to tx delay timer */ - ts_want_write(e1i_ts); -} - -static int handle_ts1_write(struct osmo_fd *bfd) -{ - struct e1inp_line *line = bfd->data; - unsigned int ts_nr = bfd->priv_nr; - struct e1inp_ts *e1i_ts = &line->ts[ts_nr-1]; - struct e1inp_sign_link *sign_link; - struct msgb *msg; - uint8_t proto; - int ret; - - bfd->when &= ~BSC_FD_WRITE; - - /* get the next msg for this timeslot */ - msg = e1inp_tx_ts(e1i_ts, &sign_link); - if (!msg) { - /* no message after tx delay timer */ - return 0; - } - - switch (sign_link->type) { - case E1INP_SIGN_OML: - proto = IPAC_PROTO_OML; - break; - case E1INP_SIGN_RSL: - proto = IPAC_PROTO_RSL; - break; - default: - msgb_free(msg); - bfd->when |= BSC_FD_WRITE; /* come back for more msg */ - return -EINVAL; - } - - msg->l2h = msg->data; - ipaccess_prepend_header(msg, sign_link->tei); - - DEBUGP(DMI, "TX %u: %s\n", ts_nr, osmo_hexdump(msg->l2h, msgb_l2len(msg))); - - ret = send(bfd->fd, msg->data, msg->len, 0); - msgb_free(msg); - - /* set tx delay timer for next event */ - e1i_ts->sign.tx_timer.cb = timeout_ts1_write; - e1i_ts->sign.tx_timer.data = e1i_ts; - - /* Reducing this might break the nanoBTS 900 init. */ - osmo_timer_schedule(&e1i_ts->sign.tx_timer, 0, e1i_ts->sign.delay); - - return ret; -} - -/* callback from select.c in case one of the fd's can be read/written */ -static int ipaccess_fd_cb(struct osmo_fd *bfd, unsigned int what) -{ - struct e1inp_line *line = bfd->data; - unsigned int ts_nr = bfd->priv_nr; - unsigned int idx = ts_nr-1; - struct e1inp_ts *e1i_ts; - int rc = 0; - - /* In case of early RSL we might not yet have a line */ - - if (line) - e1i_ts = &line->ts[idx]; - - if (!line || e1i_ts->type == E1INP_TS_TYPE_SIGN) { - if (what & BSC_FD_READ) - rc = handle_ts1_read(bfd); - if (what & BSC_FD_WRITE) - rc = handle_ts1_write(bfd); - } else - LOGP(DINP, LOGL_ERROR, "unknown E1 TS type %u\n", e1i_ts->type); - - return rc; -} - -struct e1inp_driver ipaccess_driver = { - .name = "ip.access", - .want_write = ts_want_write, - .default_delay = 0, -}; - -/* callback of the OML listening filedescriptor */ -static int listen_fd_cb(struct osmo_fd *listen_bfd, unsigned int what) -{ - int ret; - int idx = 0; - int i; - struct e1inp_line *line; - struct e1inp_ts *e1i_ts; - struct osmo_fd *bfd; - struct sockaddr_in sa; - socklen_t sa_len = sizeof(sa); - - if (!(what & BSC_FD_READ)) - return 0; - - ret = accept(listen_bfd->fd, (struct sockaddr *) &sa, &sa_len); - if (ret < 0) { - perror("accept"); - return ret; - } - LOGP(DINP, LOGL_NOTICE, "accept()ed new OML link from %s\n", - inet_ntoa(sa.sin_addr)); - - line = talloc_zero(tall_bsc_ctx, struct e1inp_line); - if (!line) { - close(ret); - return -ENOMEM; - } - line->driver = &ipaccess_driver; - //line->driver_data = e1h; - /* create virrtual E1 timeslots for signalling */ - e1inp_ts_config(&line->ts[1-1], line, E1INP_TS_TYPE_SIGN); - - /* initialize the fds */ - for (i = 0; i < ARRAY_SIZE(line->ts); ++i) - line->ts[i].driver.ipaccess.fd.fd = -1; - - e1i_ts = &line->ts[idx]; - - bfd = &e1i_ts->driver.ipaccess.fd; - bfd->fd = ret; - bfd->data = line; - bfd->priv_nr = PRIV_OML; - bfd->cb = ipaccess_fd_cb; - bfd->when = BSC_FD_READ; - ret = osmo_fd_register(bfd); - if (ret < 0) { - LOGP(DINP, LOGL_ERROR, "could not register FD\n"); - close(bfd->fd); - talloc_free(line); - return ret; - } - - /* Request ID. FIXME: request LOCATION, HW/SW VErsion, Unit Name, Serno */ - ret = ipaccess_send_id_req(bfd->fd); - - return ret; - //return e1inp_line_register(line); -} - -static int rsl_listen_fd_cb(struct osmo_fd *listen_bfd, unsigned int what) -{ - struct sockaddr_in sa; - socklen_t sa_len = sizeof(sa); - struct osmo_fd *bfd; - int ret; - - if (!(what & BSC_FD_READ)) - return 0; - - bfd = talloc_zero(tall_bsc_ctx, struct osmo_fd); - if (!bfd) - return -ENOMEM; - - /* Some BTS has connected to us, but we don't know yet which line - * (as created by the OML link) to associate it with. Thus, we - * allocate a temporary bfd until we have received ID from BTS */ - - bfd->fd = accept(listen_bfd->fd, (struct sockaddr *) &sa, &sa_len); - if (bfd->fd < 0) { - perror("accept"); - return bfd->fd; - } - LOGP(DINP, LOGL_NOTICE, "accept()ed new RSL link from %s\n", inet_ntoa(sa.sin_addr)); - bfd->priv_nr = PRIV_RSL; - bfd->cb = ipaccess_fd_cb; - bfd->when = BSC_FD_READ; - ret = osmo_fd_register(bfd); - if (ret < 0) { - LOGP(DINP, LOGL_ERROR, "could not register FD\n"); - close(bfd->fd); - talloc_free(bfd); - return ret; - } - /* Request ID. FIXME: request LOCATION, HW/SW VErsion, Unit Name, Serno */ - ret = ipaccess_send_id_req(bfd->fd); - - return 0; -} - -/* Actively connect to a BTS. Currently used by ipaccess-config.c */ -int ipaccess_connect(struct e1inp_line *line, struct sockaddr_in *sa) -{ - struct e1inp_ts *e1i_ts = &line->ts[0]; - struct osmo_fd *bfd = &e1i_ts->driver.ipaccess.fd; - int ret, on = 1; - - bfd->fd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); - bfd->cb = ipaccess_fd_cb; - bfd->when = BSC_FD_READ | BSC_FD_WRITE; - bfd->data = line; - bfd->priv_nr = PRIV_OML; - - if (bfd->fd < 0) { - LOGP(DINP, LOGL_ERROR, "could not create TCP socket.\n"); - return -EIO; - } - - setsockopt(bfd->fd, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on)); - - ret = connect(bfd->fd, (struct sockaddr *) sa, sizeof(*sa)); - if (ret < 0) { - LOGP(DINP, LOGL_ERROR, "could not connect socket\n"); - close(bfd->fd); - return ret; - } - - ret = osmo_fd_register(bfd); - if (ret < 0) { - close(bfd->fd); - return ret; - } - - line->driver = &ipaccess_driver; - - return ret; - //return e1inp_line_register(line); -} - -int ipaccess_setup(struct gsm_network *gsmnet) -{ - int ret; - - e1h = talloc_zero(tall_bsc_ctx, struct ia_e1_handle); - if (!e1h) - return -ENOMEM; - - e1h->gsmnet = gsmnet; - - /* Listen for OML connections */ - ret = make_sock(&e1h->listen_fd, IPPROTO_TCP, INADDR_ANY, - IPA_TCP_PORT_OML, 0, listen_fd_cb, NULL); - if (ret < 0) - return ret; - - /* Listen for RSL connections */ - ret = make_sock(&e1h->rsl_listen_fd, IPPROTO_TCP, INADDR_ANY, - IPA_TCP_PORT_RSL, 0, rsl_listen_fd_cb, NULL); - if (ret < 0) - return ret; - - return ret; -} - -void e1inp_ipaccess_init(void) -{ - e1inp_driver_register(&ipaccess_driver); -} -- cgit v1.2.3