archives/gates_of_skeldal
2
0
Fork 0
mirror of https://github.com/ondra-novak/gates_of_skeldal.git synced 2025-07-20 05:04:53 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix compile error on linux

Browse source
This commit is contained in:
Ondřej Novák 2025-05-09 08:02:11 +02:00
parent 240c8764fb
commit 47edde89d5
1 changed files with 10 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

18
platform/sse_receiver.c
View file

@ -1,5 +1,7 @@
// sse_receiver.c // sse_receiver.c
#include "sse_receiver.h" #include "sse_receiver.h"
#include <ctype.h>
#include <stdlib.h> #include <stdlib.h>
#include <string.h> #include <string.h>
#include <time.h> #include <time.h>
@ -34,7 +36,7 @@ struct tag_sse_receiver {
char port[16]; char port[16];
sock_t sock; sock_t sock;
int connected; int connected;
char buffer[BUFFER_SIZE+1]; char buffer[BUFFER_SIZE+1];
size_t buf_len; size_t buf_len;
size_t line_len; size_t line_len;
time_t next_attempt; time_t next_attempt;
@ -118,7 +120,7 @@ const char *sse_receiver_receive(SSE_RECEIVER *sse) {
if (rm) { if (rm) {
const char *r = sse->buffer+sse->line_len; const char *r = sse->buffer+sse->line_len;
size_t sep = find_sep(r, rm, '\n'); size_t sep = find_sep(r, rm, '\n');
if (sep < rm) { if (sep < rm) {
sep += sse->line_len; sep += sse->line_len;
sse->buffer[sep] = 0; sse->buffer[sep] = 0;
sse->line_len = sep+1; sse->line_len = sep+1;
@ -129,13 +131,13 @@ const char *sse_receiver_receive(SSE_RECEIVER *sse) {
if (*r) { if (*r) {
return r; return r;
} }
} }
continue; continue;
} }
if (r != sse->buffer) memmove(sse->buffer, r, rm); if (r != sse->buffer) memmove(sse->buffer, r, rm);
} }
sse->line_len = 0; sse->line_len = 0;
sse->buf_len = rm; sse->buf_len = rm;
if (!sse->connected) { if (!sse->connected) {
time_t t = time(NULL); time_t t = time(NULL);
@ -143,8 +145,8 @@ const char *sse_receiver_receive(SSE_RECEIVER *sse) {
return NULL; return NULL;
} }
if (!connect_and_handshake(sse)) { if (!connect_and_handshake(sse)) {
snprintf(sse->buffer, sizeof(sse->buffer) - 1, snprintf(sse->buffer, sizeof(sse->buffer) - 1,
"MESSAGE Failed to connect the command server %s:%s ", "MESSAGE Failed to connect the command server %s:%s ",
sse->host, sse->port); sse->host, sse->port);
sse->next_attempt = t+5; sse->next_attempt = t+5;
return sse->buffer; return sse->buffer;
@ -169,7 +171,7 @@ const char *sse_receiver_receive(SSE_RECEIVER *sse) {
} }
sse->buf_len += n; sse->buf_len += n;
} }
} }
void sse_receiver_destroy(SSE_RECEIVER *sse) { void sse_receiver_destroy(SSE_RECEIVER *sse) {