aboutsummaryrefslogtreecommitdiff
path: root/source/protocol.h
diff options
context:
space:
mode:
Diffstat (limited to 'source/protocol.h')
-rw-r--r--source/protocol.h36
1 files changed, 18 insertions, 18 deletions
diff --git a/source/protocol.h b/source/protocol.h
index f863f0a..5d330d7 100644
--- a/source/protocol.h
+++ b/source/protocol.h
@@ -204,16 +204,16 @@ recvTextMessage(Arena* msgsArena, u32 fd)
// Receive everything but the text so we can know the text's size and act accordingly
s32 nrecv = recv(fd, message, TEXTMESSAGE_SIZE, 0);
- assert(nrecv != -1);
- assert(nrecv == TEXTMESSAGE_SIZE);
+ Assert(nrecv != -1);
+ Assert(nrecv == TEXTMESSAGE_SIZE);
// Allocate memory for text and receive in that memory
u32 text_size = message->len * sizeof(*message->text);
ArenaPush(msgsArena, text_size);
nrecv = recv(fd, (u8*)&message->text, text_size, 0);
- assert(nrecv != -1);
- assert(nrecv == (s32)(message->len * sizeof(*message->text)));
+ Assert(nrecv != -1);
+ Assert(nrecv == (s32)(message->len * sizeof(*message->text)));
return message;
}
@@ -234,7 +234,7 @@ getMessageSize(HeaderType type)
case HEADER_TYPE_INTRODUCTION: size = sizeof(IntroductionMessage); break;
case HEADER_TYPE_PRESENCE: size = sizeof(PresenceMessage); break;
case HEADER_TYPE_ID: size = sizeof(IDMessage); break;
- default: assert(0);
+ default: Assert(0);
}
return size;
}
@@ -245,7 +245,7 @@ recvAnyMessageType(s32 fd, HeaderMessage* header, void *anyMessage, HeaderType t
s32 nrecv = recv(fd, header, sizeof(*header), 0);
if (nrecv == -1 || nrecv == 0)
return nrecv;
- assert(nrecv == sizeof(*header));
+ Assert(nrecv == sizeof(*header));
s32 size = 0;
switch (type)
@@ -262,13 +262,13 @@ recvAnyMessageType(s32 fd, HeaderMessage* header, void *anyMessage, HeaderType t
TextMessage* message = anyMessage;
size = TEXTMESSAGE_SIZE + message->len * sizeof(*message->text);
} break;
- default: assert(0); break;
+ default: Assert(0); break;
}
- assert(header->type == type);
+ Assert(header->type == type);
nrecv = recv(fd, anyMessage, size, 0);
- assert(nrecv != -1);
- assert(nrecv == size);
+ Assert(nrecv != -1);
+ Assert(nrecv == size);
return size;
}
@@ -279,8 +279,8 @@ recvAnyMessage(Arena* arena, s32 fd)
{
HeaderMessage* header = ArenaPush(arena, sizeof(*header));
s32 nrecv = recv(fd, header, sizeof(*header), 0);
- assert(nrecv != -1);
- assert(nrecv == sizeof(*header));
+ Assert(nrecv != -1);
+ Assert(nrecv == sizeof(*header));
s32 size = 0;
switch (header->type)
@@ -300,8 +300,8 @@ recvAnyMessage(Arena* arena, s32 fd)
void* message = ArenaPush(arena, size);
nrecv = recv(fd, message, size, 0);
- assert(nrecv != -1);
- assert(nrecv == size);
+ Assert(nrecv != -1);
+ Assert(nrecv == size);
Message result;
result.header = header;
@@ -333,7 +333,7 @@ sendAnyMessage(u32 fd, HeaderMessage header, void* anyMessage)
s32 nsend = send(fd, &header, sizeof(header), 0);
if (nsend == -1) return nsend;
LoggingF("sendAnyMessage (%d)|sending "HEADER_FMT"\n", fd, HEADER_ARG(header));
- assert(nsend == sizeof(header));
+ Assert(nsend == sizeof(header));
nsend_total = nsend;
s32 size = 0;
@@ -349,8 +349,8 @@ sendAnyMessage(u32 fd, HeaderMessage header, void* anyMessage)
case HEADER_TYPE_TEXT:
{
nsend = send(fd, anyMessage, TEXTMESSAGE_SIZE, 0);
- assert(nsend != -1);
- assert(nsend == TEXTMESSAGE_SIZE);
+ Assert(nsend != -1);
+ Assert(nsend == TEXTMESSAGE_SIZE);
nsend_total += nsend;
// set size to remaning text size that should be sent
TextMessage* message = (TextMessage*)anyMessage;
@@ -366,7 +366,7 @@ sendAnyMessage(u32 fd, HeaderMessage header, void* anyMessage)
nsend = send(fd, anyMessage, size, 0);
if (nsend == -1) return nsend;
- assert(nsend == size);
+ Assert(nsend == size);
nsend_total += nsend;
return nsend_total;