/* ip.access nanoBTS configuration tool */ /* (C) 2009-2010 by Harald Welte * (C) 2009-2011 by Holger Hans Peter Freyther * (C) 2009-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 #include #include #include #include #include #include #include #include #include #include #include static int net_listen_testnr; static int restart; static bool get_attr; static char *prim_oml_ip; static char *bts_ip_addr, *bts_ip_mask, *bts_ip_gw; static char *unit_id; static uint16_t nv_flags; static uint16_t nv_mask; static char *software = NULL; static int sw_load_state = 0; static int oml_state = 0; static int dump_files = 0; static char *firmware_analysis = NULL; static int found_trx = 0; static int loop_tests = 0; static bool quiet = false; static void *tall_ctx_config = NULL; static struct abis_nm_sw_desc *sw_load1 = NULL; static struct abis_nm_sw_desc *sw_load2 = NULL; extern struct e1inp_line_ops ipaccess_e1inp_line_ops; /* Functions from ipaccess-config-e1-driver.c: */ extern void e1inp_ipaccess_config_init(void *ctx); extern void e1inp_ipaccess_config_set_connect_addr(const char *connect_addr); /* configure pseudo E1 line in ip.access style and connect to BTS */ static int ia_config_connect(struct gsm_bts *bts, const char *bts_ip) { struct e1inp_line *line; struct e1inp_ts *sign_ts, *rsl_ts; struct e1inp_sign_link *oml_link, *osmo_link, *rsl_link; line = talloc_zero(tall_bsc_ctx, struct e1inp_line); if (!line) return -ENOMEM; e1inp_ipaccess_config_init(tall_bsc_ctx); e1inp_ipaccess_config_set_connect_addr(bts_ip); line = e1inp_line_create(0, "ipaccess-config"); if (!line) { fprintf(stderr, "cannot create line with `ipaccess-config' driver, giving up.\n"); return -EINVAL; } e1inp_line_bind_ops(line, &ipaccess_e1inp_line_ops); e1_set_pcap_fd2(line, -1); /* Disable writing to pcap */ e1inp_line_update(line); sign_ts = e1inp_line_ipa_oml_ts(line); rsl_ts = e1inp_line_ipa_rsl_ts(line, 0); /* create E1 timeslots for signalling and TRAU frames */ e1inp_ts_config_sign(sign_ts, line); e1inp_ts_config_sign(rsl_ts, line); rsl_ts->driver.ipaccess.fd.fd = -1; /* create signalling links for TRX0 */ oml_link = e1inp_sign_link_create(sign_ts, E1INP_SIGN_OML, bts->c0, IPAC_PROTO_OML, 0); osmo_link = e1inp_sign_link_create(sign_ts, E1INP_SIGN_OSMO, bts->c0, IPAC_PROTO_OSMO, 0); rsl_link = e1inp_sign_link_create(rsl_ts, E1INP_SIGN_RSL, bts->c0, IPAC_PROTO_RSL, 0); /* create back-links from bts/trx */ bts->oml_link = oml_link; bts->osmo_link = osmo_link; bts->c0->rsl_link_primary = rsl_link; return 0; } /* * Callback function for NACK on the OML NM * * Currently we send the config requests but don't check the * result. The nanoBTS will send us a NACK when we did something the * BTS didn't like. */ static int ipacc_msg_nack(uint8_t mt) { fprintf(stderr, "Failure to set attribute. This seems fatal\n"); exit(-1); return 0; } static void check_restart_or_exit(struct gsm_bts_trx *trx) { if (restart) { abis_nm_ipaccess_restart(trx); } else { exit(0); } } static int ipacc_msg_ack(uint8_t mt, struct gsm_bts_trx *trx) { if (mt != NM_MT_IPACC_SET_NVATTR_ACK && mt != NM_MT_IPACC_SET_ATTR_ACK) return 0; if (sw_load_state == 1) { fprintf(stderr, "The new software is activated.\n"); check_restart_or_exit(trx); } else if (oml_state == 1) { fprintf(stderr, "Set the NV Attributes.\n"); check_restart_or_exit(trx); } return 0; } static const uint8_t phys_conf_min[] = { 0x02 }; static uint16_t build_physconf_arfcn_by_rxlev(uint8_t *physconf_buf, const struct rxlev_stats *st) { uint16_t *whitelist = (uint16_t *) (physconf_buf + 4); int num_arfcn; unsigned int arfcnlist_size; /* Create whitelist from rxlevels */ physconf_buf[0] = phys_conf_min[0]; physconf_buf[1] = NM_IPAC_EIE_ARFCN_WHITE; num_arfcn = ipac_rxlevstat2whitelist(whitelist, st, 0, 100); arfcnlist_size = num_arfcn * 2; *((uint16_t *) (physconf_buf+2)) = htons(arfcnlist_size); DEBUGP(DNM, "physconf_buf (%s)\n", osmo_hexdump(physconf_buf, arfcnlist_size+4)); return arfcnlist_size+4; } static int nwl_sig_cb(unsigned int subsys, unsigned int signal, void *handler_data, void *signal_data) { struct gsm_bts_trx *trx; uint8_t physconf_buf[2*NUM_ARFCNS+16]; uint16_t physconf_len; switch (signal) { case S_IPAC_NWL_COMPLETE: trx = signal_data; DEBUGP(DNM, "received S_IPAC_NWL_COMPLETE signal\n"); switch (trx->ipaccess.test_nr) { case NM_IPACC_TESTNO_CHAN_USAGE: /* Dump RxLev results */ //rxlev_stat_dump(&trx->ipaccess.rxlev_stat); /* Create whitelist from results */ physconf_len = build_physconf_arfcn_by_rxlev(physconf_buf, &trx->ipaccess.rxlev_stat); /* Start next test about BCCH channel usage */ ipac_nwl_test_start(trx, NM_IPACC_TESTNO_BCCH_CHAN_USAGE, physconf_buf, physconf_len); break; case NM_IPACC_TESTNO_BCCH_CHAN_USAGE: /* Dump BCCH RxLev results */ //rxlev_stat_dump(&trx->ipaccess.rxlev_stat); /* Create whitelist from results */ physconf_len = build_physconf_arfcn_by_rxlev(physconf_buf, &trx->ipaccess.rxlev_stat); /* Start next test about BCCH info */ ipac_nwl_test_start(trx, NM_IPACC_TESTNO_BCCH_INFO, physconf_buf, physconf_len); break; case NM_IPACC_TESTNO_BCCH_INFO: /* re-start full process with CHAN_USAGE */ if (loop_tests) { DEBUGP(DNM, "starting next test cycle\n"); ipac_nwl_test_start(trx, net_listen_testnr, phys_conf_min, sizeof(phys_conf_min)); } else { exit(0); } break; } break; } return 0; } static const struct value_string ipa_nvflag_strs[]; static int print_attr_rep(struct msgb *mb) { /* Parse using nanoBTS own formatting for Get Attribute Response */ struct abis_om_hdr *oh = msgb_l2(mb); struct abis_om_fom_hdr *foh = msgb_l3(mb); struct e1inp_sign_link *sign_link = mb->dst; struct gsm_bts_trx *trx = sign_link->trx; struct gsm_bts *bts = trx->bts; struct tlv_parsed tp; struct in_addr ia = {0}; char oml_ip[20] = {0}; uint16_t oml_port = 0; char unit_id[40] = {0}; unsigned int indent = 0; if (abis_nm_tlv_parse(&tp, bts, foh->data, oh->length-sizeof(*foh)) < 0) { LOGPFOH(DNM, LOGL_ERROR, foh, "%s(): tlv_parse failed\n", __func__); return -EINVAL; } abis_nm_tlv_attr_primary_oml(&tp, &ia, &oml_port); osmo_strlcpy(oml_ip, inet_ntoa(ia), sizeof(oml_ip)); abis_nm_tlv_attr_unit_id(&tp, unit_id, sizeof(unit_id)); #define ENDL(last) \ fprintf(stdout, "%s\n", last ? "" : ",") #define print_offset(fmt, args...) \ fprintf(stdout, "%*s" fmt, indent * 4, "", ## args) #define print_field(field, fmt, args...) \ print_offset("\"%s\": \"" fmt "\"", field, ## args) print_offset("{\n"); indent++; print_field("primary_oml_ip", "%s", oml_ip); ENDL(false); print_field("primary_oml_port", "%u", oml_port); ENDL(false); print_field("unit_id", "%s", unit_id); ENDL(false); uint16_t Fx = (TLVP_VAL(&tp, NM_ATT_IPACC_NV_FLAGS)[2] << 8) | (TLVP_VAL(&tp, NM_ATT_IPACC_NV_FLAGS)[0] << 0); uint16_t Mx = (TLVP_VAL(&tp, NM_ATT_IPACC_NV_FLAGS)[3] << 8) | (TLVP_VAL(&tp, NM_ATT_IPACC_NV_FLAGS)[1] << 0); const struct value_string *nvflag = ipa_nvflag_strs; print_offset("\"nv_flags\": {\n"); indent++; while (nvflag->value && nvflag->str) { const char *val = (Fx & nvflag->value) ? "yes" : "no"; if (~Mx & nvflag->value) val = "unknown"; print_field(nvflag->str, "%s", val); nvflag++; if (nvflag->value && nvflag->str) ENDL(false); /* more fields to print */ else ENDL(true); /* this was the last field */ } indent--; print_offset("}\n"); indent--; print_offset("}\n"); return 0; } static int nm_state_event(int evt, uint8_t obj_class, void *obj, const struct gsm_nm_state *old_state, const struct gsm_nm_state *new_state, struct abis_om_obj_inst *obj_inst); static int nm_sig_cb(unsigned int subsys, unsigned int signal, void *handler_data, void *signal_data) { struct ipacc_ack_signal_data *ipacc_data; struct nm_statechg_signal_data *nsd; struct msgb *oml_msg; struct gsm_bts_trx *trx; switch (signal) { case S_NM_IPACC_NACK: ipacc_data = signal_data; return ipacc_msg_nack(ipacc_data->foh->msg_type); case S_NM_IPACC_ACK: ipacc_data = signal_data; switch (ipacc_data->foh->obj_class) { case NM_OC_BASEB_TRANSC: case NM_OC_RADIO_CARRIER: trx = gsm_bts_trx_num(ipacc_data->bts, ipacc_data->foh->obj_inst.trx_nr); return ipacc_msg_ack(ipacc_data->foh->msg_type, trx); default: return 0; } case S_NM_IPACC_RESTART_ACK: if (!quiet) printf("The BTS has acked the restart. Exiting.\n"); exit(0); break; case S_NM_IPACC_RESTART_NACK: if (!quiet) printf("The BTS has nacked the restart. Exiting.\n"); exit(0); break; case S_NM_STATECHG: nsd = signal_data; nm_state_event(signal, nsd->obj_class, nsd->obj, &nsd->old_state, &nsd->new_state, nsd->obj_inst); break; case S_NM_GET_ATTR_REP: fprintf(stderr, "Received SIGNAL S_NM_GET_ATTR_REP\n"); oml_msg = signal_data; print_attr_rep(oml_msg); exit(0); default: break; } return 0; } /* Callback function to be called every time we receive a signal from INPUT */ static int inp_sig_cb(unsigned int subsys, unsigned int signal, void *handler_data, void *signal_data) { struct input_signal_data *isd = signal_data; if (subsys != SS_L_INPUT) return -EINVAL; fprintf(stderr, "%s(): Input signal '%s' received\n", __func__, get_value_string(e1inp_signal_names, signal)); switch (signal) { case S_L_INP_TEI_UP: break; case S_L_INP_TEI_DN: fprintf(stderr, "Lost E1 %s link\n", e1inp_signtype_name(isd->link_type)); exit(1); break; default: break; } return 0; } /* callback function passed to the ABIS OML code */ static int percent; static int percent_old; static int swload_cbfn(unsigned int hook, unsigned int event, struct msgb *_msg, void *data, void *param) { struct msgb *msg; struct gsm_bts_trx *trx; if (hook != GSM_HOOK_NM_SWLOAD) return 0; trx = (struct gsm_bts_trx *) data; switch (event) { case NM_MT_LOAD_INIT_ACK: if (!quiet) fprintf(stdout, "Software Load Initiate ACK\n"); break; case NM_MT_LOAD_INIT_NACK: fprintf(stderr, "ERROR: Software Load Initiate NACK\n"); exit(5); break; case NM_MT_LOAD_END_ACK: fprintf(stderr, "LOAD END ACK..."); /* now make it the default */ sw_load_state = 1; msg = msgb_alloc(1024, "sw: nvattr"); msg->l2h = msgb_put(msg, 3); msg->l3h = &msg->l2h[3]; /* activate software */ if (sw_load1) abis_nm_put_sw_desc(msg, sw_load1, true); if (sw_load2) abis_nm_put_sw_desc(msg, sw_load2, true); /* fill in the data */ msg->l2h[0] = NM_ATT_IPACC_CUR_SW_CFG; msg->l2h[1] = msgb_l3len(msg) >> 8; msg->l2h[2] = msgb_l3len(msg) & 0xff; if (!quiet) printf("Foo l2h: %p l3h: %p... length l2: %u l3: %u\n", msg->l2h, msg->l3h, msgb_l2len(msg), msgb_l3len(msg)); abis_nm_ipaccess_set_nvattr(trx, msg->l2h, msgb_l2len(msg)); msgb_free(msg); break; case NM_MT_LOAD_END_NACK: fprintf(stderr, "ERROR: Software Load End NACK\n"); exit(3); break; case NM_MT_ACTIVATE_SW_NACK: fprintf(stderr, "ERROR: Activate Software NACK\n"); exit(4); break; case NM_MT_ACTIVATE_SW_ACK: break; case NM_MT_LOAD_SEG_ACK: percent = abis_nm_software_load_status(trx->bts); if (!quiet && percent > percent_old) printf("Software Download Progress: %d%%\n", percent); percent_old = percent; break; case NM_MT_LOAD_ABORT: fprintf(stderr, "ERROR: Load aborted by the BTS.\n"); exit(6); break; } return 0; } static void nv_put_ip_if_cfg(struct msgb *nmsg, uint32_t ip, uint32_t mask) { msgb_put_u8(nmsg, NM_ATT_IPACC_IP_IF_CFG); msgb_put_u32(nmsg, ip); msgb_put_u32(nmsg, mask); } static void nv_put_gw_cfg(struct msgb *nmsg, uint32_t addr, uint32_t mask, uint32_t gw) { msgb_put_u8(nmsg, NM_ATT_IPACC_IP_GW_CFG); msgb_put_u32(nmsg, addr); msgb_put_u32(nmsg, mask); msgb_put_u32(nmsg, gw); } static void nv_put_unit_id(struct msgb *nmsg, const char *unit_id) { msgb_tl16v_put(nmsg, NM_ATT_IPACC_UNIT_ID, strlen(unit_id)+1, (const uint8_t *)unit_id); } static void nv_put_prim_oml(struct msgb *nmsg, uint32_t ip, uint16_t port) { int len; /* 0x88 + IP + port */ len = 1 + sizeof(ip) + sizeof(port); msgb_put_u8(nmsg, NM_ATT_IPACC_PRIM_OML_CFG_LIST); msgb_put_u16(nmsg, len); msgb_put_u8(nmsg, NM_ATT_IPACC_PRIM_OML_CFG); /* IP address */ msgb_put_u32(nmsg, ip); /* port number */ msgb_put_u16(nmsg, port); } static void nv_put_flags(struct msgb *nmsg, uint16_t nv_flags, uint16_t nv_mask) { msgb_put_u8(nmsg, NM_ATT_IPACC_NV_FLAGS); msgb_put_u16(nmsg, sizeof(nv_flags) + sizeof(nv_mask)); msgb_put_u8(nmsg, nv_flags & 0xff); msgb_put_u8(nmsg, nv_mask & 0xff); msgb_put_u8(nmsg, nv_flags >> 8); msgb_put_u8(nmsg, nv_mask >> 8); } /* human-readable test names for the ip.access tests */ static const struct value_string ipa_test_strs[] = { { 64, "ccch-usage" }, { 65, "bcch-usage" }, { 66, "freq-sync" }, { 67, "rtp-usage" }, { 68, "rtp-perf" }, { 69, "gprs-ccch" }, { 70, "pccch-usage" }, { 71, "gprs-usage" }, { 72, "esta-mf" }, { 73, "uplink-mf" }, { 74, "dolink-mf" }, { 75, "tbf-details" }, { 76, "tbf-usage" }, { 77, "llc-data" }, { 78, "pdch-usage" }, { 79, "power-control" }, { 80, "link-adaption" }, { 81, "tch-usage" }, { 82, "amr-mf" }, { 83, "rtp-multiplex-perf" }, { 84, "rtp-multiplex-usage" }, { 85, "srtp-multiplex-usage" }, { 86, "abis-traffic" }, { 89, "gprs-multiplex-perf" }, { 90, "gprs-multiplex-usage" }, { 0, NULL }, }; /* human-readable names for the ip.access nanoBTS NVRAM Flags */ static const struct value_string ipa_nvflag_strs[] = { { 0x0001, "static-ip" }, { 0x0002, "static-gw" }, { 0x0004, "no-dhcp-vsi" }, { 0x0008, "dhcp-enabled" }, { 0x0040, "led-enabled" }, { 0x0100, "secondary-oml-enabled" }, { 0x0200, "diag-enabled" }, { 0x0400, "cli-enabled" }, { 0x0800, "http-enabled" }, { 0x1000, "post-enabled" }, { 0x2000, "snmp-enabled" }, { 0, NULL } }; /* set the flags in flags/mask according to a string-identified flag and 'enable' */ static int ipa_nvflag_set(uint16_t *flags, uint16_t *mask, const char *name, int en) { int rc; rc = get_string_value(ipa_nvflag_strs, name); if (rc < 0) { fprintf(stderr, "Unknown attribute '%s'\n", name); return rc; } *mask |= rc; if (en) *flags |= rc; else *flags &= ~rc; return 0; } static void bootstrap_om(struct gsm_bts_trx *trx) { struct msgb *nmsg_get = msgb_alloc(1024, "nested get msgb"); struct msgb *nmsg_set = msgb_alloc(1024, "nested set msgb"); int need_to_set_attr = 0; int len; if (!quiet) printf("OML link established using TRX %d\n", trx->nr); if (get_attr) { msgb_put_u8(nmsg_get, NM_ATT_IPACC_PRIM_OML_CFG); msgb_put_u8(nmsg_get, NM_ATT_IPACC_UNIT_ID); msgb_put_u8(nmsg_get, NM_ATT_IPACC_NV_FLAGS); } if (unit_id) { len = strlen(unit_id); if (len > nmsg_set->data_len-10) goto out_err; if (!quiet) printf("setting Unit ID to '%s'\n", unit_id); nv_put_unit_id(nmsg_set, unit_id); need_to_set_attr = 1; } if (prim_oml_ip) { struct in_addr ia; if (!inet_aton(prim_oml_ip, &ia)) { fprintf(stderr, "invalid IP address: %s\n", prim_oml_ip); goto out_err; } if (!quiet) printf("setting primary OML link IP to '%s'\n", inet_ntoa(ia)); nv_put_prim_oml(nmsg_set, ntohl(ia.s_addr), 0); need_to_set_attr = 1; } if (nv_mask) { if (!quiet) printf("setting NV Flags/Mask to 0x%04x/0x%04x\n", nv_flags, nv_mask); nv_put_flags(nmsg_set, nv_flags, nv_mask); need_to_set_attr = 1; } if (bts_ip_addr && bts_ip_mask) { struct in_addr ia_addr, ia_mask; if (!inet_aton(bts_ip_addr, &ia_addr)) { fprintf(stderr, "invalid IP address: %s\n", bts_ip_addr); goto out_err; } if (!inet_aton(bts_ip_mask, &ia_mask)) { fprintf(stderr, "invalid IP address: %s\n", bts_ip_mask); goto out_err; } if (!quiet) printf("setting static IP Address/Mask\n"); nv_put_ip_if_cfg(nmsg_set, ntohl(ia_addr.s_addr), ntohl(ia_mask.s_addr)); need_to_set_attr = 1; } if (bts_ip_gw) { struct in_addr ia_gw; if (!inet_aton(bts_ip_gw, &ia_gw)) { fprintf(stderr, "invalid IP address: %s\n", bts_ip_gw); goto out_err; } if (!quiet) printf("setting static IP Gateway\n"); /* we only set the default gateway with zero addr/mask */ nv_put_gw_cfg(nmsg_set, 0, 0, ntohl(ia_gw.s_addr)); need_to_set_attr = 1; } if (get_attr) { fprintf(stderr, "getting Attributes (%d): %s\n", nmsg_get->len, osmo_hexdump(msgb_data(nmsg_get), msgb_length(nmsg_get))); abis_nm_get_attr(trx->bts, NM_OC_BASEB_TRANSC, 0, trx->nr, 0xff, nmsg_get->head, nmsg_get->len); oml_state = 1; } if (need_to_set_attr) { abis_nm_ipaccess_set_nvattr(trx, nmsg_set->head, nmsg_set->len); oml_state = 1; } if (restart && !prim_oml_ip && !software) { if (!quiet) printf("restarting BTS\n"); abis_nm_ipaccess_restart(trx); } out_err: msgb_free(nmsg_get); msgb_free(nmsg_set); } static int nm_state_event(int evt, uint8_t obj_class, void *obj, const struct gsm_nm_state *old_state, const struct gsm_nm_state *new_state, struct abis_om_obj_inst *obj_inst) { if (obj_class == NM_OC_BASEB_TRANSC) { if (!found_trx && obj_inst->trx_nr != 0xff) { struct gsm_bts_trx *trx = container_of(obj, struct gsm_bts_trx, bb_transc); bootstrap_om(trx); found_trx = 1; } } else if (evt == S_NM_STATECHG && obj_class == NM_OC_RADIO_CARRIER && new_state->availability == NM_AVSTATE_OFF_LINE) { struct gsm_bts_trx *trx = obj; if (net_listen_testnr) ipac_nwl_test_start(trx, net_listen_testnr, phys_conf_min, sizeof(phys_conf_min)); else if (software) { int rc; if (!quiet) printf("Attempting software upload with '%s'\n", software); rc = abis_nm_software_load(trx->bts, trx->nr, software, 19, 0, swload_cbfn, trx); if (rc < 0) { fprintf(stderr, "Failed to start software load\n"); exit(-3); } } } return 0; } static struct abis_nm_sw_desc *create_swload(struct sdp_header *header) { struct abis_nm_sw_desc *load; load = talloc_zero(tall_ctx_config, struct abis_nm_sw_desc); osmo_strlcpy((char *)load->file_id, header->firmware_info.sw_part, sizeof(load->file_id)); load->file_id_len = strlen((char*)load->file_id) + 1; osmo_strlcpy((char *)load->file_version, header->firmware_info.version, sizeof(load->file_version)); load->file_version_len = strlen((char*)load->file_version) + 1; return load; } static int find_sw_load_params(const char *filename) { struct stat stat; struct sdp_header *header; struct llist_head *entry; int fd; void *tall_firm_ctx = 0; entry = talloc_zero(tall_firm_ctx, struct llist_head); INIT_LLIST_HEAD(entry); fd = open(filename, O_RDONLY); if (fd < 0) { perror("nada"); return -1; } /* verify the file */ if (fstat(fd, &stat) == -1) { perror("Can not stat the file"); close(fd); return -1; } ipaccess_analyze_file(fd, stat.st_size, 0, entry); if (close(fd) != 0) { perror("Close failed.\n"); return -1; } /* try to find what we are looking for */ llist_for_each_entry(header, entry, entry) { if (ntohs(header->firmware_info.more_more_magic) == 0x1000) { sw_load1 = create_swload(header); } else if (ntohs(header->firmware_info.more_more_magic) == 0x2001) { sw_load2 = create_swload(header); } } if (!sw_load1 || !sw_load2) { fprintf(stderr, "Did not find data.\n"); talloc_free(tall_firm_ctx); return -1; } talloc_free(tall_firm_ctx); return 0; } static void dump_entry(struct sdp_header_item *sub_entry, int part, int fd) { int out_fd; int copied; char filename[4096]; off_t target; if (!dump_files) return; if (sub_entry->header_entry.something1 == 0) return; snprintf(filename, sizeof(filename), "part.%d", part++); out_fd = open(filename, O_WRONLY | O_CREAT, 0660); if (out_fd < 0) { perror("Can not dump firmware"); return; } target = sub_entry->absolute_offset + ntohl(sub_entry->header_entry.start) + 4; if (lseek(fd, target, SEEK_SET) != target) { perror("seek failed"); close(out_fd); return; } for (copied = 0; copied < ntohl(sub_entry->header_entry.length); ++copied) { char c; if (read(fd, &c, sizeof(c)) != sizeof(c)) { perror("copy failed"); break; } if (write(out_fd, &c, sizeof(c)) != sizeof(c)) { perror("write failed"); break; } } close(out_fd); } static void analyze_firmware(const char *filename) { struct stat stat; struct sdp_header *header; struct sdp_header_item *sub_entry; struct llist_head *entry; int fd; void *tall_firm_ctx = 0; int part = 0; entry = talloc_zero(tall_firm_ctx, struct llist_head); INIT_LLIST_HEAD(entry); if (!quiet) printf("Opening possible firmware '%s'\n", filename); fd = open(filename, O_RDONLY); if (fd < 0) { perror("nada"); return; } /* verify the file */ if (fstat(fd, &stat) == -1) { perror("Can not stat the file"); close(fd); return; } ipaccess_analyze_file(fd, stat.st_size, 0, entry); llist_for_each_entry(header, entry, entry) { printf("Printing header information:\n"); printf("more_more_magic: 0x%x\n", ntohs(header->firmware_info.more_more_magic)); printf("header_length: %u\n", ntohl(header->firmware_info.header_length)); printf("file_length: %u\n", ntohl(header->firmware_info.file_length)); printf("sw_part: %.20s\n", header->firmware_info.sw_part); printf("text1: %.64s\n", header->firmware_info.text1); printf("time: %.12s\n", header->firmware_info.time); printf("date: %.14s\n", header->firmware_info.date); printf("text2: %.10s\n", header->firmware_info.text2); printf("version: %.20s\n", header->firmware_info.version); printf("subitems...\n"); llist_for_each_entry(sub_entry, &header->header_list, entry) { printf("\tsomething1: %u\n", sub_entry->header_entry.something1); printf("\ttext1: %.64s\n", sub_entry->header_entry.text1); printf("\ttime: %.12s\n", sub_entry->header_entry.time); printf("\tdate: %.14s\n", sub_entry->header_entry.date); printf("\ttext2: %.10s\n", sub_entry->header_entry.text2); printf("\tversion: %.20s\n", sub_entry->header_entry.version); printf("\tlength: %u\n", ntohl(sub_entry->header_entry.length)); printf("\taddr1: 0x%x\n", ntohl(sub_entry->header_entry.addr1)); printf("\taddr2: 0x%x\n", ntohl(sub_entry->header_entry.addr2)); printf("\tstart: 0x%x\n", ntohl(sub_entry->header_entry.start)); printf("\tabs. offset: 0x%lx\n", sub_entry->absolute_offset); printf("\n\n"); dump_entry(sub_entry, part++, fd); } printf("\n\n"); } if (close(fd) != 0) { perror("Close failed.\n"); return; } talloc_free(tall_firm_ctx); } static bool check_unitid_fmt(const char* unit_id) { regex_t regexp; int rc; if (strlen(unit_id) < 5) goto wrong_fmt; rc = regcomp(®exp, "^[0-9]+/[0-9]+/[0-9]+$", REG_EXTENDED | REG_NOSUB); OSMO_ASSERT(!rc); rc = regexec(®exp, unit_id, 0, NULL, 0); regfree(®exp); if (rc == 0) return true; wrong_fmt: fprintf(stderr, "ERROR: unit-id wrong format. Must be '\\d+/\\d+/\\d+'\n"); return false; } static void print_usage(void) { printf("Usage: ipaccess-config IP_OF_BTS\n"); } static void print_help(void) { #if 0 printf("Commands for reading from the BTS:\n"); printf(" -D --dump\t\t\tDump the BTS configuration\n"); printf("\n"); #endif printf("Commands for writing to the BTS:\n"); printf(" -u --unit-id UNIT_ID\t\tSet the Unit ID of the BTS\n"); printf(" -o --oml-ip IP\t\tSet primary OML IP (IP of your BSC)\n"); printf(" -G --get-attr\t\t\tGet several attributes from BTS\n"); printf(" -i --ip-address IP/MASK\tSet static IP address + netmask of BTS\n"); printf(" -g --ip-gateway IP\t\tSet static IP gateway of BTS\n"); printf(" -r --restart\t\t\tRestart the BTS (after other operations)\n"); printf(" -n --nvram-flags FLAGS/MASK\tSet NVRAM attributes\n"); printf(" -S --nvattr-set FLAG\t\tSet one additional NVRAM attribute\n"); printf(" -U --nvattr-unset FLAG\tSet one additional NVRAM attribute\n"); printf(" -l --listen TESTNR\t\tPerform specified test number\n"); printf(" -L --Listen TEST_NAME\t\tPerform specified test\n"); printf(" -s --stream-id ID\t\tSet the IPA Stream Identifier for OML\n"); printf(" -d --software FIRMWARE\tDownload firmware into BTS\n"); printf("\n"); printf("Miscellaneous commands:\n"); printf(" -h --help\t\t\tthis text\n"); printf(" -H --HELP\t\t\tPrint parameter details.\n"); printf(" -f --firmware FIRMWARE\tProvide firmware information\n"); printf(" -w --write-firmware\t\tThis will dump the firmware parts to the filesystem. Use with -f.\n"); printf(" -p --loop\t\t\tLoop the tests executed with the --listen command.\n"); printf(" -q --quiet\t\t\tAvoid printing unformatted logging to stdout, useful with -G.\n"); } static void print_value_string(const struct value_string *val, int size) { int i; for (i = 0; i < size - 1; ++i) { char sep = val[i + 1].str == NULL ? '.' : ','; printf("%s%c ", val[i].str, sep); } printf("\n"); } static void print_options(void) { printf("Options for NVRAM (-S,-U):\n "); print_value_string(&ipa_nvflag_strs[0], ARRAY_SIZE(ipa_nvflag_strs)); printf("Options for Tests (-L):\n "); print_value_string(&ipa_test_strs[0], ARRAY_SIZE(ipa_test_strs)); } static const struct log_info_cat log_categories[] = { [DNM] = { .name = "DNM", .description = "A-bis Network Management / O&M (NM/OML)", .color = "\033[1;36m", .loglevel = LOGL_NOTICE, .enabled = 1, }, }; static const struct log_info log_info = { .cat = log_categories, .num_cat = ARRAY_SIZE(log_categories), }; int main(int argc, char **argv) { struct gsm_bts *bts; char *bts_ip; int rc, option_index = 0, stream_id = 0xff; tall_ctx_config = talloc_named_const(NULL, 0, "ipaccess-config"); tall_bsc_ctx = tall_ctx_config; msgb_talloc_ctx_init(tall_ctx_config, 0); osmo_init_logging2(tall_ctx_config, &log_info); bts_model_nanobts_init(); while (1) { int c; unsigned long ul; char *slash; static struct option long_options[] = { { "get-attr", 0, 0, 'G' }, { "unit-id", 1, 0, 'u' }, { "oml-ip", 1, 0, 'o' }, { "ip-address", 1, 0, 'i' }, { "ip-gateway", 1, 0, 'g' }, { "restart", 0, 0, 'r' }, { "nvram-flags", 1, 0, 'n' }, { "nvattr-set", 1, 0, 'S' }, { "nvattr-unset", 1, 0, 'U' }, { "help", 0, 0, 'h' }, { "HELP", 0, 0, 'H' }, { "listen", 1, 0, 'l' }, { "Listen", 1, 0, 'L' }, { "stream-id", 1, 0, 's' }, { "software", 1, 0, 'd' }, { "firmware", 1, 0, 'f' }, { "write-firmware", 0, 0, 'w' }, { "disable-color", 0, 0, 'c'}, { "loop", 0, 0, 'p' }, { "quiet", 0, 0, 'q' }, { 0, 0, 0, 0 }, }; c = getopt_long(argc, argv, "Gu:o:i:g:rn:S:U:l:L:hs:d:f:wcpqH", long_options, &option_index); if (c == -1) break; switch (c) { case 'G': get_attr = true; break; case 'u': if (!check_unitid_fmt(optarg)) exit(2); unit_id = optarg; break; case 'o': prim_oml_ip = optarg; break; case 'i': slash = strchr(optarg, '/'); if (!slash) exit(2); bts_ip_addr = optarg; *slash = 0; bts_ip_mask = slash+1; break; case 'g': bts_ip_gw = optarg; break; case 'r': restart = 1; break; case 'n': slash = strchr(optarg, '/'); if (!slash) exit(2); ul = strtoul(optarg, NULL, 16); nv_flags = ul & 0xffff; ul = strtoul(slash+1, NULL, 16); nv_mask = ul & 0xffff; break; case 'S': if (ipa_nvflag_set(&nv_flags, &nv_mask, optarg, 1) < 0) exit(2); break; case 'U': if (ipa_nvflag_set(&nv_flags, &nv_mask, optarg, 0) < 0) exit(2); break; case 'l': net_listen_testnr = atoi(optarg); break; case 'L': net_listen_testnr = get_string_value(ipa_test_strs, optarg); if (net_listen_testnr < 0) { fprintf(stderr, "The test '%s' is not known. Use -H to" " see available tests.\n", optarg); exit(2); } break; case 's': stream_id = atoi(optarg); break; case 'd': software = strdup(optarg); if (find_sw_load_params(optarg) != 0) exit(0); break; case 'f': firmware_analysis = optarg; break; case 'w': dump_files = 1; break; case 'c': log_set_use_color(osmo_stderr_target, 0); break; case 'p': loop_tests = 1; break; case 'q': quiet = true; break; case 'h': print_usage(); print_help(); exit(0); case 'H': print_options(); exit(0); } }; if (!quiet) { printf("ipaccess-config (C) 2009-2010 by Harald Welte and others\n"); printf("This is FREE SOFTWARE with ABSOLUTELY NO WARRANTY\n\n"); } if (firmware_analysis) { analyze_firmware(firmware_analysis); if (argc == optind) /* Nothing more to do, exit successfully */ exit(EXIT_SUCCESS); } if (argc - optind != 1) { fprintf(stderr, "you have to specify the IP address of the BTS. Use --help for more information\n"); exit(2); } bts_ip = argv[optind++]; libosmo_abis_init(tall_ctx_config); bsc_gsmnet = gsm_network_init(tall_ctx_config); if (!bsc_gsmnet) exit(1); bts = gsm_bts_alloc_register(bsc_gsmnet, GSM_BTS_TYPE_NANOBTS, HARDCODED_BSIC); /* ip.access supports up to 4 chained TRX */ gsm_bts_trx_alloc(bts); gsm_bts_trx_alloc(bts); gsm_bts_trx_alloc(bts); bts->oml_tei = stream_id; osmo_signal_register_handler(SS_NM, nm_sig_cb, NULL); osmo_signal_register_handler(SS_L_INPUT, inp_sig_cb, NULL); osmo_signal_register_handler(SS_IPAC_NWL, nwl_sig_cb, NULL); ipac_nwl_init(); if (!quiet) printf("Trying to connect to ip.access BTS %s...\n", bts_ip); rc = ia_config_connect(bts, bts_ip); if (rc < 0) { perror("Error connecting to the BTS"); exit(1); } while (1) { rc = osmo_select_main(0); if (rc < 0) exit(3); } exit(0); }