summaryrefslogtreecommitdiff
path: root/src/ipc/ipc.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/ipc/ipc.c')
-rwxr-xr-xsrc/ipc/ipc.c18
1 files changed, 9 insertions, 9 deletions
diff --git a/src/ipc/ipc.c b/src/ipc/ipc.c
index 98ffe6e..69def17 100755
--- a/src/ipc/ipc.c
+++ b/src/ipc/ipc.c
@@ -1,7 +1,7 @@
#include "ipc.h"
-ipc_sender *setup_ipc_sender(struct str addr, int backlog){
+ipc_sender *setup_ipc_sender(str addr, int backlog){
ipc_sender *is = calloc(1, sizeof(ipc_sender));
is->addr = dup_str(addr);
is->ssocket = socket(AF_UNIX, SOCK_STREAM, 0);
@@ -40,7 +40,7 @@ void destroy_ipc_sender(ipc_sender **is){
}
}
-ipc_listener *setup_ipc_listener(struct str saddr){
+ipc_listener *setup_ipc_listener(str saddr){
ipc_listener *il = calloc(1, sizeof(ipc_listener));
il->saddr = dup_str(saddr);
il->csocket = socket(AF_UNIX, SOCK_STREAM, 0);
@@ -78,8 +78,8 @@ void free_ipc_message(ipc_message im){
free_str(&im.val);
}
-static inline struct str ipc_message_to_str(ipc_message msg){
- struct str smsg = nstr(msg.key.len + msg.val.len + 2*sizeof(u32));
+static inline str ipc_message_to_str(ipc_message msg){
+ str smsg = dnstr(msg.key.len + msg.val.len + 2*sizeof(u32));
memcpy(smsg.ptr+smsg.len, &msg.key.len, sizeof(msg.key.len));
smsg.len += sizeof(msg.key.len);
copy_str(smsg, msg.key);
@@ -90,7 +90,7 @@ static inline struct str ipc_message_to_str(ipc_message msg){
}
int send_ipc_message(int to, ipc_message msg){
- struct str smsg = ipc_message_to_str(msg);
+ str smsg = ipc_message_to_str(msg);
if(send(to, smsg.ptr, smsg.len, 0) == -1){
log_error("cant send message to socket %d: %s", to, strerror(errno));
free_str(&smsg);
@@ -109,25 +109,25 @@ int send_ipc_message(int to, ipc_message msg){
return 0;
}
-static inline ipc_message str_to_ipc_message(struct str smsg){
+static inline ipc_message str_to_ipc_message(str smsg){
struct ipc_message msg;
u32 l;
memcpy(&l, smsg.ptr, sizeof(l));
smsg.ptr += sizeof(l);
- msg.key = nstr(l);
+ msg.key = dnstr(l);
msg.key.len = l;
memcpy(msg.key.ptr, smsg.ptr, l);
smsg.ptr += l;
memcpy(&l, smsg.ptr, sizeof(l));
smsg.ptr += sizeof(l);
- msg.val = nstr(l);
+ msg.val = dnstr(l);
msg.val.len = l;
memcpy(msg.val.ptr, smsg.ptr, l);
return msg;
}
ipc_message receive_ipc_message(ipc_listener *il){
- struct str smsg = nstr(MAX_IPC_MSG_LEN); // we are gonna have to poll btw
+ str smsg = dnstr(MAX_IPC_MSG_LEN); // we are gonna have to poll btw
ipc_message msg = {0};
smsg.len = recv(il->csocket, smsg.ptr, smsg.cap, 0);
if(smsg.len == -1){