From a17faf8512992a53a14e8b615f5369be05c5f0cc Mon Sep 17 00:00:00 2001 From: Harald Welte Date: Thu, 3 Mar 2011 23:36:48 +0100 Subject: Rename bsc_nat -> osmo-bsc_nat and bsc_mgcp -> osmo-bsc_mgcp This now enforces a unique structure: All of our main daemon programs start with an "osmo-" prefix. --- openbsc/src/mgcp/mgcp_main.c | 283 ------------------------------------------- 1 file changed, 283 deletions(-) delete mode 100644 openbsc/src/mgcp/mgcp_main.c (limited to 'openbsc/src/mgcp') diff --git a/openbsc/src/mgcp/mgcp_main.c b/openbsc/src/mgcp/mgcp_main.c deleted file mode 100644 index c8d9a625e..000000000 --- a/openbsc/src/mgcp/mgcp_main.c +++ /dev/null @@ -1,283 +0,0 @@ -/* A Media Gateway Control Protocol Media Gateway: RFC 3435 */ -/* The main method to drive it as a standalone process */ - -/* - * (C) 2009 by Holger Hans Peter Freyther - * (C) 2009 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 "../../bscconfig.h" - -/* this is here for the vty... it will never be called */ -void subscr_put() { abort(); } - -#define _GNU_SOURCE -#include - -#warning "Make use of the rtp proxy code" - -static struct mgcp_config *cfg; -static int reset_endpoints = 0; -static int daemonize = 0; - -const char *openbsc_copyright = - "Copyright (C) 2009-2010 Holger Freyther and On-Waves\r\n" - "Contributions by Daniel Willmann, Jan Lübbe, Stefan Schmidt\r\n" - "Dieter Spaar, Andreas Eversberg, Harald Welte\r\n\r\n" - "License AGPLv3+: GNU AGPL version 3 or later \r\n" - "This is free software: you are free to change and redistribute it.\r\n" - "There is NO WARRANTY, to the extent permitted by law.\r\n"; - -static char *config_file = "mgcp.cfg"; - -/* used by msgb and mgcp */ -void *tall_bsc_ctx = NULL; - -static void print_help() -{ - printf("Some useful help...\n"); - printf(" -h --help is printing this text.\n"); - printf(" -c --config-file filename The config file to use.\n"); -} - -static void handle_options(int argc, char **argv) -{ - while (1) { - int option_index = 0, c; - static struct option long_options[] = { - {"help", 0, 0, 'h'}, - {"config-file", 1, 0, 'c'}, - {"daemonize", 0, 0, 'D'}, - {"version", 0, 0, 'V'}, - {0, 0, 0, 0}, - }; - - c = getopt_long(argc, argv, "hc:VD", long_options, &option_index); - - if (c == -1) - break; - - switch(c) { - case 'h': - print_help(); - exit(0); - break; - case 'c': - config_file = talloc_strdup(tall_bsc_ctx, optarg); - break; - case 'V': - print_version(1); - exit(0); - break; - case 'D': - daemonize = 1; - break; - default: - /* ignore */ - break; - }; - } -} - -/* simply remember this */ -static int mgcp_rsip_cb(struct mgcp_config *cfg) -{ - reset_endpoints = 1; - - return 0; -} - -static int mgcp_change_cb(struct mgcp_trunk_config *cfg, int endpoint, int state) -{ - if (state != MGCP_ENDP_MDCX) - return 0; - - mgcp_send_dummy(&cfg->endpoints[endpoint]); - return 0; -} - -static int read_call_agent(struct bsc_fd *fd, unsigned int what) -{ - struct sockaddr_in addr; - socklen_t slen = sizeof(addr); - struct msgb *msg; - struct msgb *resp; - int i; - - msg = (struct msgb *) fd->data; - - /* read one less so we can use it as a \0 */ - int rc = recvfrom(cfg->gw_fd.bfd.fd, msg->data, msg->data_len - 1, 0, - (struct sockaddr *) &addr, &slen); - if (rc < 0) { - perror("Gateway failed to read"); - return -1; - } else if (slen > sizeof(addr)) { - fprintf(stderr, "Gateway received message from outerspace: %lu %d\n", - slen, sizeof(addr)); - return -1; - } - - /* handle message now */ - msg->l2h = msgb_put(msg, rc); - resp = mgcp_handle_message(cfg, msg); - msgb_reset(msg); - - if (resp) { - sendto(cfg->gw_fd.bfd.fd, resp->l2h, msgb_l2len(resp), 0, (struct sockaddr *) &addr, sizeof(addr)); - msgb_free(resp); - } - - if (reset_endpoints) { - LOGP(DMGCP, LOGL_NOTICE, "Asked to reset endpoints.\n"); - reset_endpoints = 0; - - /* is checking in_addr.s_addr == INADDR_LOOPBACK making it more secure? */ - for (i = 1; i < cfg->trunk.number_endpoints; ++i) - mgcp_free_endp(&cfg->trunk.endpoints[i]); - } - - return 0; -} - -extern enum node_type bsc_vty_go_parent(struct vty *vty); - -static struct vty_app_info vty_info = { - .name = "OpenBSC MGCP", - .version = PACKAGE_VERSION, - .go_parent_cb = bsc_vty_go_parent, - .is_config_node = bsc_vty_is_config_node, -}; - -int main(int argc, char **argv) -{ - struct gsm_network dummy_network; - struct sockaddr_in addr; - int on = 1, rc; - struct log_target *stderr_target; - - tall_bsc_ctx = talloc_named_const(NULL, 1, "mgcp-callagent"); - - log_init(&log_info); - stderr_target = log_target_create_stderr(); - log_add_target(stderr_target); - log_set_all_filter(stderr_target, 1); - - cfg = mgcp_config_alloc(); - if (!cfg) - return -1; - - vty_info.copyright = openbsc_copyright; - vty_init(&vty_info); - logging_vty_add_cmds(); - mgcp_vty_init(); - - handle_options(argc, argv); - - rc = mgcp_parse_config(config_file, cfg); - if (rc < 0) - return rc; - - rc = telnet_init(tall_bsc_ctx, &dummy_network, 4243); - if (rc < 0) - return rc; - - /* set some callbacks */ - cfg->reset_cb = mgcp_rsip_cb; - cfg->change_cb = mgcp_change_cb; - - /* we need to bind a socket */ - if (rc == 0) { - cfg->gw_fd.bfd.when = BSC_FD_READ; - cfg->gw_fd.bfd.cb = read_call_agent; - cfg->gw_fd.bfd.fd = socket(AF_INET, SOCK_DGRAM, 0); - if (cfg->gw_fd.bfd.fd < 0) { - perror("Gateway failed to listen"); - return -1; - } - - setsockopt(cfg->gw_fd.bfd.fd, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on)); - - memset(&addr, 0, sizeof(addr)); - addr.sin_family = AF_INET; - addr.sin_port = htons(cfg->source_port); - inet_aton(cfg->source_addr, &addr.sin_addr); - - if (bind(cfg->gw_fd.bfd.fd, (struct sockaddr *) &addr, sizeof(addr)) < 0) { - perror("Gateway failed to bind"); - return -1; - } - - cfg->gw_fd.bfd.data = msgb_alloc(4096, "mgcp-msg"); - if (!cfg->gw_fd.bfd.data) { - fprintf(stderr, "Gateway memory error.\n"); - return -1; - } - - - if (bsc_register_fd(&cfg->gw_fd.bfd) != 0) { - LOGP(DMGCP, LOGL_FATAL, "Failed to register the fd\n"); - return -1; - } - - LOGP(DMGCP, LOGL_NOTICE, "Configured for MGCP.\n"); - } - - /* initialisation */ - srand(time(NULL)); - - if (daemonize) { - rc = osmo_daemonize(); - if (rc < 0) { - perror("Error during daemonize"); - exit(1); - } - } - - /* main loop */ - while (1) { - bsc_select_main(0); - } - - - return 0; -} -- cgit v1.2.3