paulmataruso/open5gs
1
0
Fork 0
mirror of https://github.com/open5gs/open5gs.git synced 2025-11-04 05:53:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

Oops! re-add net_read() in testcode

Browse Source
This commit is contained in:
Sukchan Lee
2017-10-20 13:47:43 +09:00
parent 7b1949da6c
commit d40ba2a67c
1 changed files with 55 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

77
test/testpacket.c
View File

@@ -88,6 +88,7 @@ int tests1ap_enb_read(net_sock_t *sock, pkbuf_t *recvbuf)
{
int rc = 0;
#if USE_USRSCTP == 1
struct socket *psock = (struct socket *)sock;
struct sockaddr_in addr;
char name[INET6_ADDRSTRLEN];
@@ -98,32 +99,64 @@ int tests1ap_enb_read(net_sock_t *sock, pkbuf_t *recvbuf)
struct sctp_rcvinfo rcv_info;
unsigned int infotype;
n = usrsctp_recvv(psock, recvbuf->payload, MAX_SDU_LEN,
(struct sockaddr *)&addr, &from_len, (void *)&rcv_info,
&infolen, &infotype, &flags);
if (n > 0) {
if (flags & MSG_NOTIFICATION) {
printf("Notification of length %llu received.\n",
(unsigned long long)n);
} else {
if (infotype == SCTP_RECVV_RCVINFO) {
printf("Msg of length %llu received from %s:%u"
"on stream %u with SSN %u and TSN %u, PPID %u,"
"context %u, complete %d.\n",
(unsigned long long)n,
inet_ntop(AF_INET, &addr.sin_addr,
name, INET_ADDRSTRLEN), ntohs(addr.sin_port),
rcv_info.rcv_sid,
rcv_info.rcv_ssn,
rcv_info.rcv_tsn,
ntohl(rcv_info.rcv_ppid),
rcv_info.rcv_context,
(flags & MSG_EOR) ? 1 : 0);
while(1)
{
n = usrsctp_recvv(psock, recvbuf->payload, MAX_SDU_LEN,
(struct sockaddr *)&addr, &from_len, (void *)&rcv_info,
&infolen, &infotype, &flags);
if (n > 0) {
if (flags & MSG_NOTIFICATION) {
printf("Notification of length %llu received.\n",
(unsigned long long)n);
} else {
rc = n;
c_uint32_t ppid = ntohl(rcv_info.rcv_ppid);
if (infotype == SCTP_RECVV_RCVINFO) {
printf("Msg of length %llu received from %s:%u"
"on stream %u with SSN %u and TSN %u, PPID %u,"
"context %u, complete %d.\n",
(unsigned long long)n,
inet_ntop(AF_INET, &addr.sin_addr,
name, INET_ADDRSTRLEN), ntohs(addr.sin_port),
rcv_info.rcv_sid,
rcv_info.rcv_ssn,
rcv_info.rcv_tsn,
ppid,
rcv_info.rcv_context,
(flags & MSG_EOR) ? 1 : 0);
} else {
#if 0
if (ppid == SCTP_S1AP_PPID)
#endif
{
rc = n;
break;
}
}
}
}
}
#else
while(1)
{
rc = net_read(sock, recvbuf->payload, recvbuf->len, 0);
if (rc == -2)
{
continue;
}
else if (rc <= 0)
{
if (sock->sndrcv_errno == EAGAIN)
{
continue;
}
break;
}
else
{
break;
}
}
#endif
return rc;
}