diff options
Diffstat (limited to 'openbsc/src/ipaccess/ipaccess-proxy.c')
| -rw-r--r-- | openbsc/src/ipaccess/ipaccess-proxy.c | 43 |
1 files changed, 29 insertions, 14 deletions
diff --git a/openbsc/src/ipaccess/ipaccess-proxy.c b/openbsc/src/ipaccess/ipaccess-proxy.c index 9e8ec88e3..bb52a4811 100644 --- a/openbsc/src/ipaccess/ipaccess-proxy.c +++ b/openbsc/src/ipaccess/ipaccess-proxy.c @@ -40,6 +40,7 @@ #include <openbsc/gsm_data.h> #include <osmocom/core/application.h> #include <osmocom/core/select.h> +#include <osmocom/core/socket.h> #include <osmocom/gsm/tlv.h> #include <osmocom/core/msgb.h> #include <osmocom/gsm/ipa.h> @@ -47,7 +48,6 @@ #include <osmocom/abis/ipaccess.h> #include <openbsc/debug.h> #include <openbsc/ipaccess.h> -#include <openbsc/socket.h> #include <osmocom/core/talloc.h> /* one instance of an ip.access protocol proxy */ @@ -369,8 +369,12 @@ static int ipbc_alloc_connect(struct ipa_proxy_conn *ipc, struct osmo_fd *bfd, /* Create UDP socket for BTS packet injection */ udp_port = 10000 + (site_id % 1000)*100 + (bts_id % 100); - ret = make_sock(&ipbc->udp_bts_fd, IPPROTO_UDP, INADDR_ANY, udp_port, - UDP_TO_BTS, udp_fd_cb, ipbc); + ipbc->udp_bts_fd.cb = udp_fd_cb; + ipbc->udp_bts_fd.data = ipbc; + ipbc->udp_bts_fd.priv_nr = UDP_TO_BTS; + ret = osmo_sock_init_ofd(&ipbc->udp_bts_fd, AF_INET, SOCK_DGRAM, + IPPROTO_UDP, "0.0.0.0", udp_port, + OSMO_SOCK_F_BIND|OSMO_SOCK_F_NONBLOCK); if (ret < 0) goto err_udp_bts; DEBUGP(DLINP, "(%u/%u/%u) Created UDP socket for injection " @@ -378,8 +382,12 @@ static int ipbc_alloc_connect(struct ipa_proxy_conn *ipc, struct osmo_fd *bfd, /* Create UDP socket for BSC packet injection */ udp_port = 20000 + (site_id % 1000)*100 + (bts_id % 100); - ret = make_sock(&ipbc->udp_bsc_fd, IPPROTO_UDP, INADDR_ANY, udp_port, - UDP_TO_BSC, udp_fd_cb, ipbc); + ipbc->udp_bsc_fd.cb = udp_fd_cb; + ipbc->udp_bsc_fd.data = ipbc; + ipbc->udp_bsc_fd.priv_nr = UDP_TO_BSC; + ret = osmo_sock_init_ofd(&ipbc->udp_bsc_fd, AF_INET, SOCK_DGRAM, + IPPROTO_UDP, "0.0.0.0", udp_port, + OSMO_SOCK_F_BIND|OSMO_SOCK_F_NONBLOCK); if (ret < 0) goto err_udp_bsc; DEBUGP(DLINP, "(%u/%u/%u) Created UDP socket for injection " @@ -391,12 +399,14 @@ static int ipbc_alloc_connect(struct ipa_proxy_conn *ipc, struct osmo_fd *bfd, struct sockaddr_in sock; socklen_t len = sizeof(sock); struct in_addr addr; - uint32_t ip; inet_aton(listen_ipaddr, &addr); - ip = ntohl(addr.s_addr); /* make_sock() needs host byte order */ - ret = make_sock(&ipbc->gprs_ns_fd, IPPROTO_UDP, ip, 0, 0, - gprs_ns_cb, ipbc); + + ipbc->gprs_ns_fd.cb = gprs_ns_cb; + ipbc->gprs_ns_fd.data = ipbc; + ret = osmo_sock_init_ofd(&ipbc->gprs_ns_fd, AF_INET, SOCK_DGRAM, + IPPROTO_UDP, inet_ntoa(addr), 0, + OSMO_SOCK_F_BIND|OSMO_SOCK_F_NONBLOCK); if (ret < 0) { LOGP(DLINP, LOGL_ERROR, "Creating the GPRS socket failed.\n"); goto err_udp_bsc; @@ -1063,15 +1073,20 @@ static int ipaccess_proxy_setup(void) ipp->reconn_timer.data = ipp; /* Listen for OML connections */ - ret = make_sock(&ipp->oml_listen_fd, IPPROTO_TCP, INADDR_ANY, - IPA_TCP_PORT_OML, OML_FROM_BTS, listen_fd_cb, NULL); + ipp->oml_listen_fd.cb = listen_fd_cb; + ipp->oml_listen_fd.priv_nr = OML_FROM_BTS; + ret = osmo_sock_init_ofd(&ipp->oml_listen_fd, AF_INET, SOCK_STREAM, + IPPROTO_TCP, "0.0.0.0", IPA_TCP_PORT_OML, + OSMO_SOCK_F_BIND|OSMO_SOCK_F_NONBLOCK); if (ret < 0) return ret; /* Listen for RSL connections */ - ret = make_sock(&ipp->rsl_listen_fd, IPPROTO_TCP, INADDR_ANY, - IPA_TCP_PORT_RSL, RSL_FROM_BTS, listen_fd_cb, NULL); - + ipp->rsl_listen_fd.cb =listen_fd_cb; + ipp->rsl_listen_fd.priv_nr = RSL_FROM_BTS; + ret = osmo_sock_init_ofd(&ipp->rsl_listen_fd, AF_INET, SOCK_STREAM, + IPPROTO_TCP, "0.0.0.0", IPA_TCP_PORT_RSL, + OSMO_SOCK_F_BIND|OSMO_SOCK_F_NONBLOCK); if (ret < 0) return ret; |