diff options
Diffstat (limited to 'src')
-rw-r--r-- | src/common/Makefile.am | 2 | ||||
-rw-r--r-- | src/common/main.c | 332 | ||||
-rw-r--r-- | src/common/pcu_sock.c | 2 | ||||
-rw-r--r-- | src/osmo-bts-octphy/l1_if.c | 6 | ||||
-rw-r--r-- | src/osmo-bts-octphy/main.c | 239 | ||||
-rw-r--r-- | src/osmo-bts-octphy/octphy_vty.c | 13 | ||||
-rw-r--r-- | src/osmo-bts-sysmo/main.c | 324 | ||||
-rw-r--r-- | src/osmo-bts-trx/main.c | 267 |
8 files changed, 454 insertions, 731 deletions
diff --git a/src/common/Makefile.am b/src/common/Makefile.am index d2580f93..e577eba6 100644 --- a/src/common/Makefile.am +++ b/src/common/Makefile.am @@ -8,4 +8,4 @@ libbts_a_SOURCES = gsm_data_shared.c sysinfo.c logging.c abis.c oml.c bts.c \ load_indication.c pcu_sock.c handover.c msg_utils.c \ load_indication.c pcu_sock.c handover.c msg_utils.c \ tx_power.c bts_ctrl_commands.c bts_ctrl_lookup.c \ - l1sap.c cbch.c power_control.c + l1sap.c cbch.c power_control.c main.c diff --git a/src/common/main.c b/src/common/main.c new file mode 100644 index 00000000..d9fa7786 --- /dev/null +++ b/src/common/main.c @@ -0,0 +1,332 @@ +/* Main program for Osmocom BTS */ + +/* (C) 2011-2015 by Harald Welte <laforge@gnumonks.org> + * + * 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 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 <http://www.gnu.org/licenses/>. + * + */ + +#include <stdint.h> +#include <unistd.h> +#include <stdlib.h> +#include <errno.h> +#include <getopt.h> +#include <limits.h> +#include <sys/signal.h> +#include <sys/types.h> +#include <sys/stat.h> +#include <sched.h> + +#include <netinet/in.h> +#include <arpa/inet.h> + +#include <osmocom/core/talloc.h> +#include <osmocom/core/application.h> +#include <osmocom/vty/telnet_interface.h> +#include <osmocom/vty/logging.h> +#include <osmocom/vty/ports.h> +#include <osmocom/core/gsmtap_util.h> +#include <osmocom/core/gsmtap.h> + +#include <osmo-bts/gsm_data.h> +#include <osmo-bts/logging.h> +#include <osmo-bts/abis.h> +#include <osmo-bts/bts.h> +#include <osmo-bts/vty.h> +#include <osmo-bts/l1sap.h> +#include <osmo-bts/bts_model.h> +#include <osmo-bts/pcu_if.h> +#include <osmo-bts/control_if.h> + +int quit = 0; +static const char *config_file = "osmo-bts.cfg"; +static int daemonize = 0; +static int rt_prio = -1; +static int trx_num = 1; +static char *gsmtap_ip = 0; + +static void print_help() +{ + printf( "Some useful options:\n" + " -h --help this text\n" + " -d --debug MASK Enable debugging (e.g. -d DRSL:DOML:DLAPDM)\n" + " -D --daemonize For the process into a background daemon\n" + " -c --config-file Specify the filename of the config file\n" + " -s --disable-color Don't use colors in stderr log output\n" + " -T --timestamp Prefix every log line with a timestamp\n" + " -V --version Print version information and exit\n" + " -e --log-level Set a global log-level\n" + " -r --realtime PRIO Use SCHED_RR with the specified priority\n" + " -i --gsmtap-ip The destination IP used for GSMTAP.\n" + " -t --trx-num Set number of TRX (default=%d)\n", + trx_num + ); + bts_model_print_help(); +} + +/* FIXME: finally get some option parsing code into libosmocore */ +static void handle_options(int argc, char **argv) +{ + char *argv_out[argc]; + int argc_out = 0; + + argv_out[argc_out++] = argv[0]; + + /* disable generation of error messages on encountering unknown + * options */ + opterr = 0; + + while (1) { + int option_idx = 0, c; + static const struct option long_options[] = { + /* FIXME: all those are generic Osmocom app options */ + { "help", 0, 0, 'h' }, + { "debug", 1, 0, 'd' }, + { "daemonize", 0, 0, 'D' }, + { "config-file", 1, 0, 'c' }, + { "disable-color", 0, 0, 's' }, + { "timestamp", 0, 0, 'T' }, + { "version", 0, 0, 'V' }, + { "log-level", 1, 0, 'e' }, + /* FIXME: generic BTS app options */ + { "gsmtap-ip", 1, 0, 'i' }, + { "trx-num", 1, 0, 't' }, + { "realtime", 1, 0, 'r' }, + { 0, 0, 0, 0 } + }; + + c = getopt_long(argc, argv, "-hc:d:Dc:sTVe:i:t:r:", + long_options, &option_idx); + if (c == -1) + break; + + switch (c) { + case 'h': + print_help(); + exit(0); + break; + case 's': + log_set_use_color(osmo_stderr_target, 0); + break; + case 'd': + log_parse_category_mask(osmo_stderr_target, optarg); + break; + case 'D': + daemonize = 1; + break; + case 'c': + config_file = optarg; + break; + case 'T': + log_set_print_timestamp(osmo_stderr_target, 1); + break; + case 'V': + print_version(1); + exit(0); + break; + case 'e': + log_set_log_level(osmo_stderr_target, atoi(optarg)); + break; + case 'r': + rt_prio = atoi(optarg); + break; + case 'i': + gsmtap_ip = optarg; + break; + case 't': + trx_num = atoi(optarg); + if (trx_num < 1) + trx_num = 1; + break; + case '?': + case 1: + /* prepare argv[] for bts_model */ + argv_out[argc_out++] = argv[optind-1]; + break; + default: + break; + } + } + + /* re-set opt-ind for new parsig round */ + optind = 1; + /* enable error-checking for the following getopt call */ + opterr = 1; + if (bts_model_handle_options(argc_out, argv_out)) { + print_help(); + exit(1); + } +} + +static struct gsm_bts *bts; + +static void signal_handler(int signal) +{ + fprintf(stderr, "signal %u received\n", signal); + + switch (signal) { + case SIGINT: + //osmo_signal_dispatch(SS_GLOBAL, S_GLOBAL_SHUTDOWN, NULL); + if (!quit) + bts_shutdown(bts, "SIGINT"); + quit++; + break; + case SIGABRT: + case SIGUSR1: + case SIGUSR2: + talloc_report_full(tall_bts_ctx, stderr); + break; + default: + break; + } +} + +static int write_pid_file(char *procname) +{ + FILE *outf; + char tmp[PATH_MAX+1]; + + snprintf(tmp, sizeof(tmp)-1, "/var/run/%s.pid", procname); + tmp[PATH_MAX-1] = '\0'; + + outf = fopen(tmp, "w"); + if (!outf) + return -1; + + fprintf(outf, "%d\n", getpid()); + + fclose(outf); + + return 0; +} + +int bts_main(int argc, char **argv) +{ + struct gsm_bts_role_bts *btsb; + struct gsm_bts_trx *trx; + struct e1inp_line *line; + void *tall_msgb_ctx; + int rc, i; + + printf("((*))\n |\n / \\ OsmoBTS\n"); + + tall_bts_ctx = talloc_named_const(NULL, 1, "OsmoBTS context"); + tall_msgb_ctx = talloc_pool(tall_bts_ctx, 100*1024); + msgb_set_talloc_ctx(tall_msgb_ctx); + + bts_log_init(NULL); + + handle_options(argc, argv); + + bts = gsm_bts_alloc(tall_bts_ctx); + if (!bts) { + fprintf(stderr, "Failed to create BTS structure\n"); + exit(1); + } + for (i = 1; i < trx_num; i++) { + trx = gsm_bts_trx_alloc(bts); + if (!trx) { + fprintf(stderr, "Failed to create TRX structure\n"); + exit(1); + } + } + vty_init(&bts_vty_info); + e1inp_vty_init(); + bts_vty_init(bts, &bts_log_info); + + /* enable realtime priority for us */ + if (rt_prio != -1) { + struct sched_param param; + + memset(¶m, 0, sizeof(param)); + param.sched_priority = rt_prio; + rc = sched_setscheduler(getpid(), SCHED_RR, ¶m); + if (rc != 0) { + fprintf(stderr, "Setting SCHED_RR priority(%d) failed: %s\n", + param.sched_priority, strerror(errno)); + exit(1); + } + } + + if (gsmtap_ip) { + gsmtap = gsmtap_source_init(gsmtap_ip, GSMTAP_UDP_PORT, 1); + if (!gsmtap) { + fprintf(stderr, "Failed during gsmtap_init()\n"); + exit(1); + } + gsmtap_source_add_sink(gsmtap); + } + + if (bts_init(bts) < 0) { + fprintf(stderr, "unable to open bts\n"); + exit(1); + } + + abis_init(bts); + + rc = vty_read_config_file(config_file, NULL); + if (rc < 0) { + fprintf(stderr, "Failed to parse the config file: '%s'\n", + config_file); + exit(1); + } + + write_pid_file("osmo-bts"); + + bts_controlif_setup(bts); + + rc = telnet_init(tall_bts_ctx, NULL, OSMO_VTY_PORT_BTS); + if (rc < 0) { + fprintf(stderr, "Error initializing telnet\n"); + exit(1); + } + + if (pcu_sock_init()) { + fprintf(stderr, "PCU L1 socket failed\n"); + exit(1); + } + + signal(SIGINT, &signal_handler); + //signal(SIGABRT, &signal_handler); + signal(SIGUSR1, &signal_handler); + signal(SIGUSR2, &signal_handler); + osmo_init_ignore_signals(); + + btsb = bts_role_bts(bts); + if (!btsb->bsc_oml_host) { + fprintf(stderr, "Cannot start BTS without knowing BSC OML IP\n"); + exit(1); + } + + line = abis_open(bts, btsb->bsc_oml_host, "sysmoBTS"); + if (!line) { + fprintf(stderr, "unable to connect to BSC\n"); + exit(2); + } + + if (daemonize) { + rc = osmo_daemonize(); + if (rc < 0) { + perror("Error during daemonize"); + exit(1); + } + } + + while (quit < 2) { + log_reset_context(); + osmo_select_main(0); + } +} diff --git a/src/common/pcu_sock.c b/src/common/pcu_sock.c index f7d3651d..34c6e74b 100644 --- a/src/common/pcu_sock.c +++ b/src/common/pcu_sock.c @@ -44,7 +44,7 @@ uint32_t trx_get_hlayer1(struct gsm_bts_trx *trx); extern struct gsm_network bts_gsmnet; -extern int pcu_direct; +int pcu_direct = 0; static int avail_lai = 0, avail_nse = 0, avail_cell = 0, avail_nsvc[2] = {0, 0}; static const char *sapi_string[] = { diff --git a/src/osmo-bts-octphy/l1_if.c b/src/osmo-bts-octphy/l1_if.c index 6d8932e4..db6e032c 100644 --- a/src/osmo-bts-octphy/l1_if.c +++ b/src/osmo-bts-octphy/l1_if.c @@ -688,8 +688,14 @@ int bts_model_l1sap_down(struct gsm_bts_trx *trx, struct osmo_phsap_prim *l1sap) int bts_model_init(struct gsm_bts *bts) { + struct gsm_bts_role_bts *btsb; struct octphy_hdl *fl1h; + LOGP(DL1C, LOGL_NOTICE, "model_init()\n"); + + btsb = bts_role_bts(bts); + btsb->support.ciphers = CIPHER_A5(1) | CIPHER_A5(2) | CIPHER_A5(3); + fl1h = talloc_zero(bts, struct octphy_hdl); if (!fl1h) return -ENOMEM; diff --git a/src/osmo-bts-octphy/main.c b/src/osmo-bts-octphy/main.c index 1cb7cfc2..1f516e4a 100644 --- a/src/osmo-bts-octphy/main.c +++ b/src/osmo-bts-octphy/main.c @@ -40,266 +40,57 @@ #include <osmocom/core/application.h> #include <osmocom/vty/telnet_interface.h> #include <osmocom/vty/logging.h> -#include <osmocom/core/gsmtap_util.h> -#include <osmocom/core/gsmtap.h> #include <osmo-bts/logging.h> -#include <osmo-bts/abis.h> #include <osmo-bts/bts.h> #include <osmo-bts/vty.h> -#include <osmo-bts/pcu_if.h> #include <osmo-bts/l1sap.h> #include "l1_if.h" -int pcu_direct = 0; #define RF_LOCK_PATH "/var/lock/bts_rf_lock" -static const char *config_file = "osmo-bts.cfg"; -static int daemonize = 0; -static int rt_prio = -1; -static char *gsmtap_ip = 0; +extern int pcu_direct; -static void print_help() +static struct gsm_bts *bts; + +int bts_model_print_help() { - printf( "Some useful options:\n" - " -h --help this text\n" - " -d --debug MASK Enable debugging (e.g. -d DRSL:DOML:DLAPDM)\n" - " -D --daemonize For the process into a background daemon\n" - " -c --config-file Specify the filename of the config file\n" - " -s --disable-color Don't use colors in stderr log output\n" - " -T --timestamp Prefix every log line with a timestamp\n" - " -V --version Print version information and exit\n" - " -e --log-level Set a global log-level\n" - " -r --realtime PRIO Use SCHED_RR with the specified priority\n" - " -i --gsmtap-ip The destination IP used for GSMTAP.\n" - ); } -/* FIXME: finally get some option parsing code into libosmocore */ -static void handle_options(int argc, char **argv) +int bts_model_handle_options(int argc, char **argv) { + int num_errors = 0; + while (1) { int option_idx = 0, c; static const struct option long_options[] = { - /* FIXME: all those are generic Osmocom app options */ - { "help", 0, 0, 'h' }, - { "debug", 1, 0, 'd' }, - { "daemonize", 0, 0, 'D' }, - { "config-file", 1, 0, 'c' }, - { "disable-color", 0, 0, 's' }, - { "timestamp", 0, 0, 'T' }, - { "version", 0, 0, 'V' }, - { "log-level", 1, 0, 'e' }, - { "realtime", 1, 0, 'r' }, - { "gsmtap-ip", 1, 0, 'i' }, + /* specific to this hardware */ { 0, 0, 0, 0 } }; - c = getopt_long(argc, argv, "hc:d:Dc:sTVe:r:i:m:l:", + c = getopt_long(argc, argv, "", long_options, &option_idx); if (c == -1) break; switch (c) { - case 'h': - print_help(); - exit(0); - break; - case 's': - log_set_use_color(osmo_stderr_target, 0); - break; - case 'd': - log_parse_category_mask(osmo_stderr_target, optarg); - break; - case 'D': - daemonize = 1; - break; - case 'c': - config_file = strdup(optarg); - break; - case 'T': - log_set_print_timestamp(osmo_stderr_target, 1); - break; - case 'V': - print_version(1); - exit(0); - break; - case 'e': - log_set_log_level(osmo_stderr_target, atoi(optarg)); - break; - case 'r': - rt_prio = atoi(optarg); - break; - case 'i': - gsmtap_ip = optarg; - break; default: + num_errors++; break; } } -} - -static struct gsm_bts *bts; - -static void signal_handler(int signal) -{ - fprintf(stderr, "signal %u received\n", signal); - switch (signal) { - case SIGINT: - //osmo_signal_dispatch(SS_GLOBAL, S_GLOBAL_SHUTDOWN, NULL); - bts_shutdown(bts, "SIGINT"); - break; - case SIGABRT: - case SIGUSR1: - case SIGUSR2: - talloc_report_full(tall_bts_ctx, stderr); - break; - default: - break; - } + return num_errors; } -static int write_pid_file(char *procname) +void bts_model_abis_close(struct gsm_bts *bts) { - FILE *outf; - char tmp[PATH_MAX + 1]; - - snprintf(tmp, sizeof(tmp) - 1, "/var/run/%s.pid", procname); - tmp[PATH_MAX - 1] = '\0'; - - outf = fopen(tmp, "w"); - if (!outf) - return -1; - - fprintf(outf, "%d\n", getpid()); - - fclose(outf); - - return 0; + /* for now, we simply terminate the program and re-spawn */ + bts_shutdown(bts, "Abis close"); } int main(int argc, char **argv) { - struct stat st; - struct sched_param param; - struct gsm_bts_role_bts *btsb; - struct e1inp_line *line; - void *tall_msgb_ctx; - int rc; - - tall_bts_ctx = talloc_named_const(NULL, 1, "OsmoBTS context"); - tall_msgb_ctx = talloc_named_const(tall_bts_ctx, 1, "msgb"); - msgb_set_talloc_ctx(tall_msgb_ctx); - - bts_log_init(NULL); - - bts = gsm_bts_alloc(tall_bts_ctx); - vty_init(&bts_vty_info); - e1inp_vty_init(); - bts_vty_init(bts, &bts_log_info); - - handle_options(argc, argv); - - /* enable realtime priority for us */ - if (rt_prio != -1) { - memset(¶m, 0, sizeof(param)); - param.sched_priority = rt_prio; - rc = sched_setscheduler(getpid(), SCHED_RR, ¶m); - if (rc != 0) { - fprintf(stderr, - "Setting SCHED_RR priority(%d) failed: %s\n", - param.sched_priority, strerror(errno)); - exit(1); - } - } - - if (gsmtap_ip) { - gsmtap = gsmtap_source_init(gsmtap_ip, GSMTAP_UDP_PORT, 1); - if (!gsmtap) { - fprintf(stderr, "Failed during gsmtap_init()\n"); - exit(1); - } - gsmtap_source_add_sink(gsmtap); - } - - if (bts_init(bts) < 0) { - fprintf(stderr, "unable to to open bts\n"); - exit(1); - } - btsb = bts_role_bts(bts); - btsb->support.ciphers = CIPHER_A5(1) | CIPHER_A5(2) | CIPHER_A5(3); - - abis_init(bts); - - rc = vty_read_config_file(config_file, NULL); - if (rc < 0) { - fprintf(stderr, "Failed to parse the config file: '%s'\n", - config_file); - exit(1); - } - - if (stat(RF_LOCK_PATH, &st) == 0) { - LOGP(DL1C, LOGL_NOTICE, - "Not starting BTS due to RF_LOCK file present\n"); - exit(23); - } - write_pid_file("osmo-bts"); - - rc = telnet_init(tall_bts_ctx, NULL, 4241); - if (rc < 0) { - fprintf(stderr, "Error initializing telnet\n"); - exit(1); - } - - if (pcu_sock_init()) { - fprintf(stderr, "PCU L1 socket failed\n"); - exit(-1); - } - - signal(SIGINT, &signal_handler); - //signal(SIGABRT, &signal_handler); - signal(SIGUSR1, &signal_handler); - signal(SIGUSR2, &signal_handler); - osmo_init_ignore_signals(); - - if (!btsb->bsc_oml_host) { - fprintf(stderr, - "Cannot start BTS without knowing BSC OML IP\n"); - exit(1); - } - - line = abis_open(bts, btsb->bsc_oml_host, "OsmoBTS-OCTPHY"); - if (!line) { - fprintf(stderr, "unable to connect to BSC\n"); - exit(1); - } - - /* Open L1 interface */ - rc = l1if_open(bts->c0->role_bts.l1h); - if (rc < 0) { - LOGP(DL1C, LOGL_FATAL, "Cannot open L1 Interface\n"); - exit(1); - } - - if (daemonize) { - rc = osmo_daemonize(); - if (rc < 0) { - perror("Error during daemonize"); - exit(1); - } - } - - while (1) { - log_reset_context(); - osmo_select_main(0); - } - -} - -void bts_model_abis_close(struct gsm_bts *bts) -{ - /* for now, we simply terminate the program and re-spawn */ - bts_shutdown(bts, "Abis close"); + return bts_main(argc, argv); } diff --git a/src/osmo-bts-octphy/octphy_vty.c b/src/osmo-bts-octphy/octphy_vty.c index 55c9099c..dbc903a9 100644 --- a/src/osmo-bts-octphy/octphy_vty.c +++ b/src/osmo-bts-octphy/octphy_vty.c @@ -223,3 +223,16 @@ int bts_model_vty_init(struct gsm_bts *bts) return 0; } + +int bts_model_ctrl_cmds_install(struct gsm_bts *bts) +{ + /* FIXME: really ugly hack: We can only initialize the L1 intrface + * after reading the config file, and this is the only call-back after + * vty_read_config_fioe() at this point. Will be cleaned up with the + * phy interface generalization patches coming up soon as part of the + * multi-trx work */ + struct octphy_hdl *fl1h = bts->c0->role_bts.l1h; + l1if_open(fl1h); + + return 0; +} diff --git a/src/osmo-bts-sysmo/main.c b/src/osmo-bts-sysmo/main.c index 2a082782..d468a71f 100644 --- a/src/osmo-bts-sysmo/main.c +++ b/src/osmo-bts-sysmo/main.c @@ -1,6 +1,6 @@ /* Main program for Sysmocom BTS */ -/* (C) 2011-2013 by Harald Welte <laforge@gnumonks.org> +/* (C) 2011-2015 by Harald Welte <laforge@gnumonks.org> * * All Rights Reserved * @@ -38,17 +38,12 @@ #include <osmocom/vty/telnet_interface.h> #include <osmocom/vty/logging.h> #include <osmocom/vty/ports.h> -#include <osmocom/core/gsmtap_util.h> -#include <osmocom/core/gsmtap.h> #include <osmo-bts/gsm_data.h> #include <osmo-bts/logging.h> -#include <osmo-bts/abis.h> #include <osmo-bts/bts.h> #include <osmo-bts/vty.h> #include <osmo-bts/bts_model.h> -#include <osmo-bts/pcu_if.h> -#include <osmo-bts/control_if.h> #include <osmo-bts/l1sap.h> #define SYSMOBTS_RF_LOCK_PATH "/var/lock/bts_rf_lock" @@ -59,20 +54,60 @@ #include "hw_misc.h" #include "oml_router.h" -int pcu_direct = 0; - -static int quit = 0; -static const char *config_file = "osmo-bts.cfg"; -static int daemonize = 0; +extern int pcu_direct; static unsigned int dsp_trace = 0x00000000; -static int rt_prio = -1; -static char *gsmtap_ip = 0; + +/* Set the clock calibration to the value + * read from the eeprom. + */ +void clk_cal_use_eeprom(struct gsm_bts *bts) +{ + int rc; + struct femtol1_hdl *hdl; + eeprom_RfClockCal_t rf_clk; + + hdl = bts->c0->role_bts.l1h; + + if (!hdl || !hdl->clk_use_eeprom) + return; + + rc = eeprom_ReadRfClockCal(&rf_clk); + if (rc != EEPROM_SUCCESS) { + LOGP(DL1C, LOGL_ERROR, "Failed to read from EEPROM.\n"); + return; + } + + hdl->clk_cal = rf_clk.iClkCor; + LOGP(DL1C, LOGL_NOTICE, + "Read clock calibration(%d) from EEPROM.\n", hdl->clk_cal); +} + int bts_model_init(struct gsm_bts *bts) { + struct gsm_bts_role_bts *btsb; struct femtol1_hdl *fl1h; + struct stat st; + struct osmo_fd accept_fd, read_fd; int rc; + btsb = bts_role_bts(bts); + btsb->support.ciphers = CIPHER_A5(1) | CIPHER_A5(2) | CIPHER_A5(3); + + clk_cal_use_eeprom(bts); + + if (stat(SYSMOBTS_RF_LOCK_PATH, &st) == 0) { + LOGP(DL1C, LOGL_NOTICE, "Not starting BTS due to RF_LOCK file present\n"); + exit(23); + } + + rc = oml_router_init(bts, OML_ROUTER_PATH, &accept_fd, &read_fd); + if (rc < 0) { + fprintf(stderr, "Error creating the OML router: %s rc=%d\n", + OML_ROUTER_PATH, rc); + exit(1); + } + fl1h = l1if_open(bts->c0); if (!fl1h) { LOGP(DL1C, LOGL_FATAL, "Cannot open L1 Interface\n"); @@ -105,31 +140,6 @@ int bts_model_oml_estab(struct gsm_bts *bts) return 0; } -/* Set the clock calibration to the value - * read from the eeprom. - */ -void clk_cal_use_eeprom(struct gsm_bts *bts) -{ - int rc; - struct femtol1_hdl *hdl; - eeprom_RfClockCal_t rf_clk; - - hdl = bts->c0->role_bts.l1h; - - if (!hdl || !hdl->clk_use_eeprom) - return; - - rc = eeprom_ReadRfClockCal(&rf_clk); - if (rc != EEPROM_SUCCESS) { - LOGP(DL1C, LOGL_ERROR, "Failed to read from EEPROM.\n"); - return; - } - - hdl->clk_cal = rf_clk.iClkCor; - LOGP(DL1C, LOGL_NOTICE, - "Read clock calibration(%d) from EEPROM.\n", hdl->clk_cal); -} - void bts_update_status(enum bts_global_status which, int on) { static uint64_t states = 0; @@ -154,25 +164,15 @@ void bts_update_status(enum bts_global_status which, int on) sysmobts_led_set(LED_RF_ACTIVE, led_rf_active_on); } -static void print_help() +void bts_model_print_help() { - printf( "Some useful options:\n" - " -h --help this text\n" - " -d --debug MASK Enable debugging (e.g. -d DRSL:DOML:DLAPDM)\n" - " -D --daemonize For the process into a background daemon\n" - " -c --config-file Specify the filename of the config file\n" - " -s --disable-color Don't use colors in stderr log output\n" - " -T --timestamp Prefix every log line with a timestamp\n" - " -V --version Print version information and exit\n" - " -e --log-level Set a global log-level\n" + printf( " -p --dsp-trace Set DSP trace flags\n" - " -r --realtime PRIO Use SCHED_RR with the specified priority\n" " -w --hw-version Print the targeted HW Version\n" " -M --pcu-direct Force PCU to access message queue for " "PDCH dchannel directly\n" - " -i --gsmtap-ip The destination IP used for GSMTAP.\n" - ); -} + ); +}; static void print_hwversion() { @@ -183,246 +183,52 @@ static void print_hwversion() #endif } -/* FIXME: finally get some option parsing code into libosmocore */ -static void handle_options(int argc, char **argv) +int bts_model_handle_options(int argc, char **argv) { + int num_errors = 0; + while (1) { int option_idx = 0, c; static const struct option long_options[] = { - /* FIXME: all those are generic Osmocom app options */ - { "help", 0, 0, 'h' }, - { "debug", 1, 0, 'd' }, - { "daemonize", 0, 0, 'D' }, - { "config-file", 1, 0, 'c' }, - { "disable-color", 0, 0, 's' }, - { "timestamp", 0, 0, 'T' }, - { "version", 0, 0, 'V' }, - { "log-level", 1, 0, 'e' }, + /* specific to this hardware */ { "dsp-trace", 1, 0, 'p' }, { "hw-version", 0, 0, 'w' }, { "pcu-direct", 0, 0, 'M' }, - { "realtime", 1, 0, 'r' }, - { "gsmtap-ip", 1, 0, 'i' }, { 0, 0, 0, 0 } }; - c = getopt_long(argc, argv, "hc:d:Dc:sTVe:p:w:Mr:i:", + c = getopt_long(argc, argv, "p:w:M", long_options, &option_idx); if (c == -1) break; switch (c) { - case 'h': - print_help(); - exit(0); - break; - case 's': - log_set_use_color(osmo_stderr_target, 0); - break; - case 'd': - log_parse_category_mask(osmo_stderr_target, optarg); - break; - case 'D': - daemonize = 1; - break; - case 'c': - config_file = optarg; - break; - case 'T': - log_set_print_timestamp(osmo_stderr_target, 1); + case 'p': + dsp_trace = strtoul(optarg, NULL, 16); break; case 'M': pcu_direct = 1; break; - case 'V': - print_version(1); - exit(0); - break; - case 'e': - log_set_log_level(osmo_stderr_target, atoi(optarg)); - break; - case 'p': - dsp_trace = strtoul(optarg, NULL, 16); - break; case 'w': print_hwversion(); exit(0); break; - case 'r': - rt_prio = atoi(optarg); - break; - case 'i': - gsmtap_ip = optarg; - break; default: + num_errors++; break; } } -} - -static struct gsm_bts *bts; -static void signal_handler(int signal) -{ - fprintf(stderr, "signal %u received\n", signal); - - switch (signal) { - case SIGINT: - //osmo_signal_dispatch(SS_GLOBAL, S_GLOBAL_SHUTDOWN, NULL); - if (!quit) - bts_shutdown(bts, "SIGINT"); - quit++; - break; - case SIGABRT: - case SIGUSR1: - case SIGUSR2: - talloc_report_full(tall_bts_ctx, stderr); - break; - default: - break; - } + return num_errors; } -static int write_pid_file(char *procname) +void bts_model_abis_close(struct gsm_bts *bts) { - FILE *outf; - char tmp[PATH_MAX+1]; - - snprintf(tmp, sizeof(tmp)-1, "/var/run/%s.pid", procname); - tmp[PATH_MAX-1] = '\0'; - - outf = fopen(tmp, "w"); - if (!outf) - return -1; - - fprintf(outf, "%d\n", getpid()); - - fclose(outf); - - return 0; + /* for now, we simply terminate the program and re-spawn */ + bts_shutdown(bts, "Abis close"); } int main(int argc, char **argv) { - struct stat st; - struct sched_param param; - struct gsm_bts_role_bts *btsb; - struct e1inp_line *line; - void *tall_msgb_ctx; - struct osmo_fd accept_fd, read_fd; - int rc; - - tall_bts_ctx = talloc_named_const(NULL, 1, "OsmoBTS context"); - tall_msgb_ctx = talloc_pool(tall_bts_ctx, 100*1024); - msgb_set_talloc_ctx(tall_msgb_ctx); - - bts_log_init(NULL); - - bts = gsm_bts_alloc(tall_bts_ctx); - vty_init(&bts_vty_info); - e1inp_vty_init(); - bts_vty_init(bts, &bts_log_info); - - handle_options(argc, argv); - - /* enable realtime priority for us */ - if (rt_prio != -1) { - memset(¶m, 0, sizeof(param)); - param.sched_priority = rt_prio; - rc = sched_setscheduler(getpid(), SCHED_RR, ¶m); - if (rc != 0) { - fprintf(stderr, "Setting SCHED_RR priority(%d) failed: %s\n", - param.sched_priority, strerror(errno)); - exit(1); - } - } - - if (gsmtap_ip) { - gsmtap = gsmtap_source_init(gsmtap_ip, GSMTAP_UDP_PORT, 1); - if (!gsmtap) { - fprintf(stderr, "Failed during gsmtap_init()\n"); - exit(1); - } - gsmtap_source_add_sink(gsmtap); - } - - if (bts_init(bts) < 0) { - fprintf(stderr, "unable to open bts\n"); - exit(1); - } - btsb = bts_role_bts(bts); - btsb->support.ciphers = CIPHER_A5(1) | CIPHER_A5(2) | CIPHER_A5(3); - - abis_init(bts); - - rc = vty_read_config_file(config_file, NULL); - if (rc < 0) { - fprintf(stderr, "Failed to parse the config file: '%s'\n", - config_file); - exit(1); - } - - clk_cal_use_eeprom(bts); - - if (stat(SYSMOBTS_RF_LOCK_PATH, &st) == 0) { - LOGP(DL1C, LOGL_NOTICE, "Not starting BTS due to RF_LOCK file present\n"); - exit(23); - } - write_pid_file("osmo-bts"); - - bts_controlif_setup(bts); - - rc = telnet_init(tall_bts_ctx, NULL, OSMO_VTY_PORT_BTS); - if (rc < 0) { - fprintf(stderr, "Error initializing telnet\n"); - exit(1); - } - - if (pcu_sock_init()) { - fprintf(stderr, "PCU L1 socket failed\n"); - exit(1); - } - - signal(SIGINT, &signal_handler); - //signal(SIGABRT, &signal_handler); - signal(SIGUSR1, &signal_handler); - signal(SIGUSR2, &signal_handler); - osmo_init_ignore_signals(); - - rc = oml_router_init(bts, OML_ROUTER_PATH, &accept_fd, &read_fd); - if (rc < 0) { - fprintf(stderr, "Error creating the OML router: %s rc=%d\n", - OML_ROUTER_PATH, rc); - exit(1); - } - - if (!btsb->bsc_oml_host) { - fprintf(stderr, "Cannot start BTS without knowing BSC OML IP\n"); - exit(1); - } - - line = abis_open(bts, btsb->bsc_oml_host, "sysmoBTS"); - if (!line) { - fprintf(stderr, "unable to connect to BSC\n"); - exit(2); - } - - if (daemonize) { - rc = osmo_daemonize(); - if (rc < 0) { - perror("Error during daemonize"); - exit(1); - } - } - - while (quit < 2) { - log_reset_context(); - osmo_select_main(0); - } -} - -void bts_model_abis_close(struct gsm_bts *bts) -{ - /* for now, we simply terminate the program and re-spawn */ - bts_shutdown(bts, "Abis close"); + return bts_main(argc, argv); } diff --git a/src/osmo-bts-trx/main.c b/src/osmo-bts-trx/main.c index 13851095..6c2dabf7 100644 --- a/src/osmo-bts-trx/main.c +++ b/src/osmo-bts-trx/main.c @@ -1,6 +1,6 @@ /* Main program for OsmoBTS-TRX */ -/* (C) 2011 by Harald Welte <laforge@gnumonks.org> +/* (C) 2011-2015 by Harald Welte <laforge@gnumonks.org> * (C) 2013 by Andreas Eversberg <jolly@eversberg.eu> * * All Rights Reserved @@ -39,6 +39,7 @@ #include <osmocom/core/application.h> #include <osmocom/vty/telnet_interface.h> #include <osmocom/vty/logging.h> +#include <osmocom/vty/ports.h> #include <osmocom/core/gsmtap.h> #include <osmocom/core/gsmtap_util.h> #include <osmocom/core/bits.h> @@ -51,27 +52,21 @@ #include <osmo-bts/bts_model.h> #include <osmo-bts/pcu_if.h> #include <osmo-bts/l1sap.h> +#include <osmo-bts/control_if.h> #include "l1_if.h" #include "trx_if.h" #include "scheduler.h" -const int pcu_direct = 0; - -int quit = 0; -static const char *config_file = "osmo-bts.cfg"; -static int daemonize = 0; -static char *gsmtap_ip = 0; -static int rt_prio = -1; -static int trx_num = 1; -char *software_version = "0.0"; -char *bsc_host = "localhost"; -char *bts_id = "1801/0"; - int bts_model_init(struct gsm_bts *bts) { void *l1h; struct gsm_bts_trx *trx; + struct gsm_bts_role_bts *btsb = bts_role_bts(bts); + + btsb->support.ciphers = CIPHER_A5(1) | CIPHER_A5(2); + if (!settsc_enabled && !setbsic_enabled) + settsc_enabled = setbsic_enabled = 1; llist_for_each_entry(trx, &bts->trx_list, list) { l1h = l1if_open(trx); @@ -106,266 +101,46 @@ uint32_t trx_get_hlayer1(struct gsm_bts_trx *trx) return 0; } -static void print_help() +void bts_model_print_help() { - printf( "Some useful options:\n" - " -h --help this text\n" - " -d --debug MASK Enable debugging (e.g. -d DRSL:DOML:DLAPDM)\n" - " -D --daemonize For the process into a background daemon\n" - " -c --config-file Specify the filename of the config file\n" - " -s --disable-color Don't use colors in stderr log output\n" - " -T --timestamp Prefix every log line with a timestamp\n" - " -V --version Print version information and exit\n" - " -e --log-level Set a global log-level\n" - " -t --trx-num Set number of TRX (default=%d)\n" - " -i --gsmtap-ip The destination IP used for GSMTAP.\n" - " -r --realtime PRIO Set realtime scheduler with given prio\n" + printf( " -I --local-trx-ip Local IP for transceiver to connect (default=%s)\n" - ,trx_num, transceiver_ip); + , transceiver_ip + ); } -/* FIXME: finally get some option parsing code into libosmocore */ -static void handle_options(int argc, char **argv) +int bts_model_handle_options(int argc, char **argv) { + int num_errors = 0; + while (1) { int option_idx = 0, c; static const struct option long_options[] = { - /* FIXME: all those are generic Osmocom app options */ - { "help", 0, 0, 'h' }, - { "debug", 1, 0, 'd' }, - { "daemonize", 0, 0, 'D' }, - { "config-file", 1, 0, 'c' }, - { "disable-color", 0, 0, 's' }, - { "timestamp", 0, 0, 'T' }, - { "version", 0, 0, 'V' }, - { "log-level", 1, 0, 'e' }, - { "trx-num", 1, 0, 't' }, - { "gsmtap-ip", 1, 0, 'i' }, - { "realtime", 1, 0, 'r' }, + /* specific to this hardware */ { "local-trx-ip", 1, 0, 'I' }, { 0, 0, 0, 0 } }; - c = getopt_long(argc, argv, "hc:d:Dc:sTVe:t:i:r:I:", + c = getopt_long(argc, argv, "I:", long_options, &option_idx); + if (c == -1) break; switch (c) { - case 'h': - print_help(); - exit(0); - break; - case 's': - log_set_use_color(osmo_stderr_target, 0); - break; - case 'd': - log_parse_category_mask(osmo_stderr_target, optarg); - break; - case 'D': - daemonize = 1; - break; - case 'c': - config_file = strdup(optarg); - break; - case 'T': - log_set_print_timestamp(osmo_stderr_target, 1); - break; - case 'V': - print_version(1); - exit(0); - break; - case 'e': - log_set_log_level(osmo_stderr_target, atoi(optarg)); - break; - case 't': - trx_num = atoi(optarg); - if (trx_num < 1) - trx_num = 1; - break; - case 'i': - gsmtap_ip = optarg; - break; - case 'r': - rt_prio = atoi(optarg); - break; case 'I': transceiver_ip = strdup(optarg); break; default: + num_errors++; break; } } -} - -static struct gsm_bts *bts; - -static void signal_handler(int signal) -{ - fprintf(stderr, "signal %u received\n", signal); - - switch (signal) { - case SIGINT: - //osmo_signal_dispatch(SS_GLOBAL, S_GLOBAL_SHUTDOWN, NULL); - if (!quit) - bts_shutdown(bts, "SIGINT"); - quit++; - break; - case SIGABRT: - case SIGUSR1: - case SIGUSR2: - talloc_report_full(tall_bts_ctx, stderr); - break; - default: - break; - } -} - -static int write_pid_file(char *procname) -{ - FILE *outf; - char tmp[PATH_MAX+1]; - - snprintf(tmp, sizeof(tmp)-1, "/var/run/%s.pid", procname); - tmp[PATH_MAX-1] = '\0'; - - outf = fopen(tmp, "w"); - if (!outf) - return -1; - fprintf(outf, "%d\n", getpid()); - - fclose(outf); - - return 0; + return num_errors; } int main(int argc, char **argv) { - struct gsm_bts_role_bts *btsb; - struct gsm_bts_trx *trx; - struct e1inp_line *line; - void *tall_msgb_ctx; - int rc, i; - - printf("((*))\n |\n / \\ OsmoBTS\n"); - - tall_bts_ctx = talloc_named_const(NULL, 1, "OsmoBTS context"); - tall_msgb_ctx = talloc_named_const(tall_bts_ctx, 1, "msgb"); - msgb_set_talloc_ctx(tall_msgb_ctx); - - bts_log_init(NULL); - - handle_options(argc, argv); - - bts = gsm_bts_alloc(tall_bts_ctx); - if (!bts) { - fprintf(stderr, "Failed to create BTS structure\n"); - exit(1); - } - for (i = 1; i < trx_num; i++) { - trx = gsm_bts_trx_alloc(bts); - if (!trx) { - fprintf(stderr, "Failed to TRX structure\n"); - exit(1); - } - } - - vty_init(&bts_vty_info); - e1inp_vty_init(); - bts_vty_init(bts, &bts_log_info); - - if (bts_init(bts) < 0) { - fprintf(stderr, "unable to to open bts\n"); - exit(1); - } - btsb = bts_role_bts(bts); - btsb->support.ciphers = CIPHER_A5(1) | CIPHER_A5(2); - - if (gsmtap_ip) { - gsmtap = gsmtap_source_init(gsmtap_ip, GSMTAP_UDP_PORT, 1); - if (!gsmtap) { - fprintf(stderr, "Failed during gsmtap_init()\n"); - exit(1); - } - gsmtap_source_add_sink(gsmtap); - } - - abis_init(bts); - - rc = vty_read_config_file(config_file, NULL); - if (rc < 0) { - fprintf(stderr, "Failed to parse the config file: '%s'\n", - config_file); - exit(1); - } - if (!settsc_enabled && !setbsic_enabled) - settsc_enabled = setbsic_enabled = 1; - - write_pid_file("osmo-bts"); - - bts_controlif_setup(bts); - - rc = telnet_init(tall_bts_ctx, NULL, 4241); - if (rc < 0) { - fprintf(stderr, "Error initializing telnet\n"); - exit(1); - } - - if (pcu_sock_init()) { - fprintf(stderr, "PCU L1 socket failed\n"); - exit(-1); - } - - signal(SIGINT, &signal_handler); - //signal(SIGABRT, &signal_handler); - signal(SIGUSR1, &signal_handler); - signal(SIGUSR2, &signal_handler); - osmo_init_ignore_signals(); - - if (!btsb->bsc_oml_host) { - fprintf(stderr, "Cannot start BTS without knowing BSC OML IP\n"); - exit(1); - } - - line = abis_open(bts, btsb->bsc_oml_host, "sysmoBTS"); - if (!line) { - fprintf(stderr, "unable to connect to BSC\n"); - exit(1); - } - - if (daemonize) { - rc = osmo_daemonize(); - if (rc < 0) { - perror("Error during daemonize"); - exit(1); - } - } - - if (rt_prio != -1) { - struct sched_param schedp; - - /* high priority scheduling required for handling bursts */ - memset(&schedp, 0, sizeof(schedp)); - schedp.sched_priority = rt_prio; - rc = sched_setscheduler(0, SCHED_RR, &schedp); - if (rc) { - fprintf(stderr, "Error setting SCHED_RR with prio %d\n", - rt_prio); - } - } - - while (quit < 2) { - log_reset_context(); - osmo_select_main(0); - } - -#if 0 - telnet_exit(); - - talloc_report_full(tall_bts_ctx, stderr); -#endif - - return 0; + return bts_main(argc, argv); } - |