summaryrefslogtreecommitdiff
path: root/src/irmd
diff options
context:
space:
mode:
authorSander Vrijders <sander.vrijders@ugent.be>2018-05-03 12:10:02 +0200
committerDimitri Staessens <dimitri.staessens@ugent.be>2018-05-03 12:26:48 +0200
commit12968ba98642bd7057e8e7f41e184ab2d61671ed (patch)
tree8f3e3706bc8038f795d6f5b758b46126787dde9f /src/irmd
parent711777a4c7665db2d7ec8d05105eee29054c8562 (diff)
downloadouroboros-0.11.3.tar.gz
ouroboros-0.11.3.zip
lib: Make UNIX socket buffer size configurable0.11.3
This makes the buffer size used by the UNIX sockets configurable. In case of a lot of IPCPs in the system it might become too small with the default value, resulting in irm command failures. The user can now easily configure it with an adequate value. Signed-off-by: Sander Vrijders <sander.vrijders@ugent.be> Signed-off-by: Dimitri Staessens <dimitri.staessens@ugent.be>
Diffstat (limited to 'src/irmd')
-rw-r--r--src/irmd/ipcp.c4
-rw-r--r--src/irmd/main.c4
2 files changed, 4 insertions, 4 deletions
diff --git a/src/irmd/ipcp.c b/src/irmd/ipcp.c
index 49bf13c9..dc8f1c6e 100644
--- a/src/irmd/ipcp.c
+++ b/src/irmd/ipcp.c
@@ -53,7 +53,7 @@ ipcp_msg_t * send_recv_ipcp_msg(pid_t pid,
ipcp_msg_t * msg)
{
int sockfd = 0;
- uint8_t buf[IPCP_MSG_BUF_SIZE];
+ uint8_t buf[SOCK_BUF_SIZE];
char * sock_path = NULL;
ssize_t len;
ipcp_msg_t * recv_msg = NULL;
@@ -116,7 +116,7 @@ ipcp_msg_t * send_recv_ipcp_msg(pid_t pid,
ipcp_msg__pack(msg, buf);
if (write(sockfd, buf, len) != -1)
- len = read(sockfd, buf, IPCP_MSG_BUF_SIZE);
+ len = read(sockfd, buf, SOCK_BUF_SIZE);
if (len > 0)
recv_msg = ipcp_msg__unpack(NULL, len, buf);
diff --git a/src/irmd/main.c b/src/irmd/main.c
index db9d7bbd..b2a521d5 100644
--- a/src/irmd/main.c
+++ b/src/irmd/main.c
@@ -68,7 +68,7 @@
#define IRMD_CLEANUP_TIMER ((IRMD_FLOW_TIMEOUT / 20) * MILLION) /* ns */
#define SHM_SAN_HOLDOFF 1000 /* ms */
#define IPCP_HASH_LEN(e) hash_len(e->dir_hash_algo)
-#define IB_LEN IRM_MSG_BUF_SIZE
+#define IB_LEN SOCK_BUF_SIZE
enum init_state {
IPCP_NULL = 0,
@@ -1862,7 +1862,7 @@ static void * acceptloop(void * o)
break;
}
- cmd->len = read(csockfd, cmd->cbuf, IRM_MSG_BUF_SIZE);
+ cmd->len = read(csockfd, cmd->cbuf, SOCK_BUF_SIZE);
if (cmd->len <= 0) {
log_err("Failed to read from socket.");
close(csockfd);