diff options
Diffstat (limited to 'source/protocol.h')
-rw-r--r-- | source/protocol.h | 36 |
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; |