summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorSander Vrijders <sander.vrijders@ugent.be>2018-06-08 15:31:44 +0200
committerSander Vrijders <sander.vrijders@ugent.be>2018-06-08 15:31:44 +0200
commita58e8743dad97758947470c7d72f5820955f9e82 (patch)
treeacd2dc1445f6af9dfab0d3b3485a5068afadfd6b /src
parente06cd0c186c1a7ead4778aa09de7db69c649f1a5 (diff)
parent22be1ea9cab402a921776a59ff9667bcb5e2c299 (diff)
downloadouroboros-a58e8743dad97758947470c7d72f5820955f9e82.tar.gz
ouroboros-a58e8743dad97758947470c7d72f5820955f9e82.zip
Merge branch 'testing' into be
Diffstat (limited to 'src')
-rw-r--r--src/ipcpd/config.h.in4
-rw-r--r--src/ipcpd/eth/eth.c13
2 files changed, 16 insertions, 1 deletions
diff --git a/src/ipcpd/config.h.in b/src/ipcpd/config.h.in
index 375ac750..b9961b01 100644
--- a/src/ipcpd/config.h.in
+++ b/src/ipcpd/config.h.in
@@ -32,6 +32,10 @@
#define CONNECT_TIMEOUT @CONNECT_TIMEOUT@
#define SHM_BUFFER_SIZE @SHM_BUFFER_SIZE@
+#define SHM_RDRB_BLOCK_SIZE @SHM_RDRB_BLOCK_SIZE@
+#define DU_BUFF_HEADSPACE @DU_BUFF_HEADSPACE@
+#define DU_BUFF_TAILSPACE @DU_BUFF_TAILSPACE@
+#cmakedefine SHM_RDRB_MULTI_BLOCK
#define IPCP_MIN_THREADS @IPCP_MIN_THREADS@
#define IPCP_ADD_THREADS @IPCP_ADD_THREADS@
diff --git a/src/ipcpd/eth/eth.c b/src/ipcpd/eth/eth.c
index a58839f0..0bd1589d 100644
--- a/src/ipcpd/eth/eth.c
+++ b/src/ipcpd/eth/eth.c
@@ -840,7 +840,7 @@ static void * eth_ipcp_sdu_reader(void * o)
if (select(eth_data.s_fd + 1, &fds, NULL, NULL, NULL) < 0)
continue;
assert(FD_ISSET(eth_data.s_fd, &fds));
- if (ipcp_sdb_reserve(&sdb, ETH_FRAME_SIZE))
+ if (ipcp_sdb_reserve(&sdb, eth_data.mtu))
continue;
buf = shm_du_buff_head(sdb);
frame_len = recv(eth_data.s_fd, buf, ETH_FRAME_SIZE, 0);
@@ -1180,6 +1180,9 @@ static int eth_ipcp_bootstrap(const struct ipcp_config * conf)
#elif defined(__linux__)
int skfd;
#endif
+#ifndef SHM_RDRB_MULTI_BLOCK
+ size_t maxsz;
+#endif
assert(conf);
assert(conf->type == THIS_TYPE);
@@ -1250,6 +1253,14 @@ static int eth_ipcp_bootstrap(const struct ipcp_config * conf)
eth_data.mtu = MIN((int) ETH_MTU_MAX, ifr.ifr_mtu);
+#ifndef SHM_RDRB_MULTI_BLOCK
+ maxsz = SHM_RDRB_BLOCK_SIZE - 5 * sizeof(size_t) -
+ (DU_BUFF_HEADSPACE + DU_BUFF_TAILSPACE);
+ if ((size_t) eth_data.mtu > maxsz ) {
+ log_dbg("Layer MTU truncated to shm block size.");
+ eth_data.mtu = maxsz;
+ }
+#endif
log_dbg("Layer MTU is %d.", eth_data.mtu);
close(skfd);