diff options
Diffstat (limited to 'src/openbts_sock.cpp')
| -rw-r--r-- | src/openbts_sock.cpp | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/openbts_sock.cpp b/src/openbts_sock.cpp index 2d9cae41..5e6f16c6 100644 --- a/src/openbts_sock.cpp +++ b/src/openbts_sock.cpp @@ -79,7 +79,10 @@ struct l1fwd_hdl *l1fh = talloc_zero(NULL, struct l1fwd_hdl); int pcu_sock_send(struct msgb *msg) { - osmo_wqueue_enqueue(&l1fh->udp_wq, msg); + if (osmo_wqueue_enqueue(&l1fh->udp_wq, msg) != 0) { + LOGP(DPCU, LOGL_ERROR, "PCU write queue full. Dropping message.\n"); + msgb_free(msg); + } return 0; } |