acouzens
/
open5gs
1
0
Fork 1
Code Issues Pull Requests 1 Projects Releases Wiki Activity

the MacOSX porting

This commit is contained in:
Sukchan Lee 2019-06-01 18:06:47 +09:00
parent 1f752e51e8
commit 8a7634d00c
4 changed files with 10 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/mme/mme_context.c
View File

@ -1442,7 +1442,7 @@ int mme_enb_remove(mme_enb_t *enb)
#endif
if (enb->sock_type == SOCK_STREAM)
s1ap_closesocket(enb->sock);
ogs_sctp_destroy(enb->sock);
ogs_free(enb->addr);

2
src/mme/ogs-usrsctp.c
View File

@ -32,7 +32,7 @@ void ogs_sctp_final()
{
while(usrsctp_finish() != 0)
{
ogs_error("try to finsih SCTP");
ogs_warn("try to finsih SCTP");
ogs_msleep(1000);
}
}

6
src/mme/s1ap_lksctp.c
View File

@ -25,12 +25,6 @@ void s1ap_server(ogs_socknode_t *node, int type)
OGS_ADDR(node->addr, buf), OGS_PORT(node->addr));
}
void s1ap_closesocket(ogs_sock_t *sock)
{
ogs_assert(sock);
ogs_sock_destroy(sock);
}
int s1ap_send(ogs_sock_t *sock, ogs_pkbuf_t *pkbuf,
ogs_sockaddr_t *addr, uint16_t stream_no)
{

23
src/mme/s1ap_usrsctp.c
View File

@ -1,5 +1,6 @@
#include "ogs-sctp.h"
#include "app/context.h"
#include "mme_event.h"
#include "s1ap_path.h"
@ -27,29 +28,21 @@ static ogs_sockaddr_t *usrsctp_remote_addr(union sctp_sockstore *store);
void s1ap_server(ogs_socknode_t *node, int type)
{
char buf[OGS_ADDRSTRLEN];
ogs_sock_t *sock = NULL;
ogs_assert(node);
node->sock = ogs_sctp_server(type, node);
ogs_assert(node->sock);
ogs_socknode_set_option(node, &context_self()->config.sockopt);
ogs_socknode_set_poll(node, mme_self()->pollset,
OGS_POLLIN, s1ap_usrsctp_recv_handler, node);
sock = ogs_sctp_server(type, node);
ogs_assert(sock);
ogs_info("s1ap_server() [%s]:%d",
OGS_ADDR(node->addr, buf), OGS_PORT(node->addr));
}
void s1ap_closesocket(ogs_sock_t *sock)
{
ogs_assert(sock);
usrsctp_close((struct socket *)sock);
}
void s1ap_delete(ogs_socknode_t *snode)
{
ogs_assert(snode);
s1ap_closesocket(snode->sock);
snode->sock = NULL;
}
int s1ap_send(ogs_sock_t *sock, ogs_pkbuf_t *pkbuf,
ogs_sockaddr_t *addr, uint16_t stream_no)
{