Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
O
OpenXG-RAN
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Analytics
Analytics
CI / CD
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
wangjie
OpenXG-RAN
Commits
c224ca8f
Commit
c224ca8f
authored
Jun 16, 2021
by
Laurent THOMAS
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
fix srb error
parent
1b62c915
Changes
4
Show whitespace changes
Inline
Side-by-side
Showing
4 changed files
with
19 additions
and
7 deletions
+19
-7
common/utils/utils.h
common/utils/utils.h
+1
-0
openair2/LAYER2/nr_pdcp/nr_pdcp_oai_api.c
openair2/LAYER2/nr_pdcp/nr_pdcp_oai_api.c
+2
-2
openair2/LAYER2/nr_pdcp/nr_pdcp_ue_manager.h
openair2/LAYER2/nr_pdcp/nr_pdcp_ue_manager.h
+1
-1
openair3/ocp-gtpu/gtp_itf.cpp
openair3/ocp-gtpu/gtp_itf.cpp
+15
-4
No files found.
common/utils/utils.h
View file @
c224ca8f
...
@@ -7,6 +7,7 @@
...
@@ -7,6 +7,7 @@
extern
"C"
{
extern
"C"
{
#endif
#endif
#define sizeofArray(a) (sizeof(a)/sizeof(*(a)))
void
*
calloc_or_fail
(
size_t
size
);
void
*
calloc_or_fail
(
size_t
size
);
void
*
malloc_or_fail
(
size_t
size
);
void
*
malloc_or_fail
(
size_t
size
);
...
...
openair2/LAYER2/nr_pdcp/nr_pdcp_oai_api.c
View file @
c224ca8f
...
@@ -549,7 +549,7 @@ static void deliver_sdu_srb(void *_ue, nr_pdcp_entity_t *entity,
...
@@ -549,7 +549,7 @@ static void deliver_sdu_srb(void *_ue, nr_pdcp_entity_t *entity,
int
srb_id
;
int
srb_id
;
int
i
;
int
i
;
for
(
i
=
0
;
i
<
3
;
i
++
)
{
for
(
i
=
0
;
i
<
sizeofArray
(
ue
->
srb
)
;
i
++
)
{
if
(
entity
==
ue
->
srb
[
i
])
{
if
(
entity
==
ue
->
srb
[
i
])
{
srb_id
=
i
+
1
;
srb_id
=
i
+
1
;
goto
srb_found
;
goto
srb_found
;
...
@@ -592,7 +592,7 @@ static void deliver_pdu_srb(void *_ue, nr_pdcp_entity_t *entity,
...
@@ -592,7 +592,7 @@ static void deliver_pdu_srb(void *_ue, nr_pdcp_entity_t *entity,
int
i
;
int
i
;
mem_block_t
*
memblock
;
mem_block_t
*
memblock
;
for
(
i
=
0
;
i
<
3
;
i
++
)
{
for
(
i
=
0
;
i
<
sizeofArray
(
ue
->
srb
)
;
i
++
)
{
if
(
entity
==
ue
->
srb
[
i
])
{
if
(
entity
==
ue
->
srb
[
i
])
{
srb_id
=
i
+
1
;
srb_id
=
i
+
1
;
goto
srb_found
;
goto
srb_found
;
...
...
openair2/LAYER2/nr_pdcp/nr_pdcp_ue_manager.h
View file @
c224ca8f
...
@@ -28,7 +28,7 @@ typedef void nr_pdcp_ue_manager_t;
...
@@ -28,7 +28,7 @@ typedef void nr_pdcp_ue_manager_t;
typedef
struct
nr_pdcp_ue_t
{
typedef
struct
nr_pdcp_ue_t
{
int
rnti
;
int
rnti
;
nr_pdcp_entity_t
*
srb
[
2
];
nr_pdcp_entity_t
*
srb
[
3
];
nr_pdcp_entity_t
*
drb
[
5
];
nr_pdcp_entity_t
*
drb
[
5
];
}
nr_pdcp_ue_t
;
}
nr_pdcp_ue_t
;
...
...
openair3/ocp-gtpu/gtp_itf.cpp
View file @
c224ca8f
...
@@ -277,12 +277,18 @@ static void gtpv1uEndTunnel(instance_t instance, gtpv1u_enb_tunnel_data_req_t *r
...
@@ -277,12 +277,18 @@ static void gtpv1uEndTunnel(instance_t instance, gtpv1u_enb_tunnel_data_req_t *r
to
.
sin_family
=
AF_INET
;
to
.
sin_family
=
AF_INET
;
to
.
sin_port
=
htons
(
tmp
.
outgoing_port
);
to
.
sin_port
=
htons
(
tmp
.
outgoing_port
);
to
.
sin_addr
.
s_addr
=
tmp
.
outgoing_ip_addr
;
to
.
sin_addr
.
s_addr
=
tmp
.
outgoing_ip_addr
;
char
ip4
[
INET_ADDRSTRLEN
];
char
ip6
[
INET6_ADDRSTRLEN
];
LOG_D
(
GTPU
,
"sending end packet to %s
\n
"
,
inet_ntoa
(
to
.
sin_addr
)
);
LOG_D
(
GTPU
,
"sending end packet to %s
\n
"
,
inet_ntoa
(
to
.
sin_addr
)
);
if
(
sendto
(
compatInst
(
instance
),
(
void
*
)
&
msgHdr
,
sizeof
(
msgHdr
),
0
,(
struct
sockaddr
*
)
&
to
,
sizeof
(
to
)
)
!=
sizeof
(
msgHdr
))
{
if
(
sendto
(
compatInst
(
instance
),
(
void
*
)
&
msgHdr
,
sizeof
(
msgHdr
),
0
,(
struct
sockaddr
*
)
&
to
,
sizeof
(
to
)
)
!=
sizeof
(
msgHdr
))
{
char
ip4
[
INET_ADDRSTRLEN
];
char
ip6
[
INET6_ADDRSTRLEN
];
LOG_E
(
GTPU
,
LOG_E
(
GTPU
,
"[SD %ld] Failed to send data to
"
IPV4_ADDR
"
on port %d, buffer size %lu
\n
"
,
"[SD %ld] Failed to send data to
%s
on port %d, buffer size %lu
\n
"
,
compatInst
(
instance
),
IPV4_ADDR_FORMAT
(
tmp
.
outgoing_ip_addr
),
tmp
.
outgoing_port
,
sizeof
(
msgHdr
));
compatInst
(
instance
),
inet_ntop
(
AF_INET
,
&
tmp
.
outgoing_ip_addr
,
ip4
,
INET_ADDRSTRLEN
),
tmp
.
outgoing_port
,
sizeof
(
msgHdr
));
}
}
}
}
...
@@ -438,10 +444,15 @@ teid_t newGtpuCreateTunnel(instance_t instance, rnti_t rnti, int bearer_id, teid
...
@@ -438,10 +444,15 @@ teid_t newGtpuCreateTunnel(instance_t instance, rnti_t rnti, int bearer_id, teid
tmp
->
outgoing_port
=
port
;
tmp
->
outgoing_port
=
port
;
tmp
->
teid_outgoing
=
outgoing_teid
;
tmp
->
teid_outgoing
=
outgoing_teid
;
pthread_mutex_unlock
(
&
globGtp
.
gtp_lock
);
pthread_mutex_unlock
(
&
globGtp
.
gtp_lock
);
LOG_I
(
GTPU
,
"Created tunnel for RNTI %x, teid for DL: %d, teid for UL %d
\n
"
,
char
ip4
[
INET_ADDRSTRLEN
];
char
ip6
[
INET6_ADDRSTRLEN
];
LOG_I
(
GTPU
,
"Created tunnel for RNTI %x, teid for DL: %d, teid for UL %d to remote IPv4: %s, IPv6 %s
\n
"
,
rnti
,
rnti
,
tmp
->
teid_incoming
,
tmp
->
teid_incoming
,
tmp
->
teid_outgoing
);
tmp
->
teid_outgoing
,
inet_ntop
(
AF_INET
,(
void
*
)
&
tmp
->
outgoing_ip_addr
,
ip4
,
INET_ADDRSTRLEN
),
inet_ntop
(
AF_INET6
,(
void
*
)
&
tmp
->
outgoing_ip6_addr
.
s6_addr
,
ip6
,
INET6_ADDRSTRLEN
));
return
incoming_teid
;
return
incoming_teid
;
}
}
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment