summaryrefslogtreecommitdiff
path: root/src/ipcpd/shim-udp
diff options
context:
space:
mode:
Diffstat (limited to 'src/ipcpd/shim-udp')
-rw-r--r--src/ipcpd/shim-udp/main.c25
1 files changed, 11 insertions, 14 deletions
diff --git a/src/ipcpd/shim-udp/main.c b/src/ipcpd/shim-udp/main.c
index db9a89e2..6869aaf0 100644
--- a/src/ipcpd/shim-udp/main.c
+++ b/src/ipcpd/shim-udp/main.c
@@ -222,26 +222,23 @@ static ssize_t ipcp_udp_flow_write(int fd, void * buf, size_t count)
return -1; /* -ENOTENROLLED */
}
- index = shm_create_du_buff(_ap_instance->dum, count, 0, buf, count);
-
- if (index == -1) {
- return -1;
- }
-
- e.index = index;
-
rw_lock_rdlock(&_ap_instance->flows_lock);
+ while ((index = shm_create_du_buff(_ap_instance->dum,
+ count + DU_BUFF_HEADSPACE +
+ DU_BUFF_TAILSPACE,
+ DU_BUFF_HEADSPACE,
+ (uint8_t *) buf,
+ count)) < 0)
+ ;
+
+ e.index = index;
e.port_id = _ap_instance->flows[fd].port_id;
- if (shm_ap_rbuff_write(_ap_instance->flows[fd].rb, &e) < 0) {
- rw_lock_unlock(&_ap_instance->flows_lock);
- shm_release_du_buff(_ap_instance->dum, index);
- return -EPIPE;
- }
+ while (shm_ap_rbuff_write(_ap_instance->flows[fd].rb, &e) < 0)
+ ;
rw_lock_unlock(&_ap_instance->flows_lock);
-
rw_lock_unlock(&_ipcp->state_lock);
return 0;