miegl/mud
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Use two counters

Browse Source
This commit is contained in:
angt
2016-02-02 20:32:01 +01:00
parent 62df93ab67
commit 924df5798f
1 changed files with 8 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
mud.c
View File

@@ -16,12 +16,13 @@ struct path {
int fd; int fd;
struct sockaddr_storage addr; struct sockaddr_storage addr;
socklen_t addrlen; socklen_t addrlen;
unsigned count;
uint32_t rtt; uint32_t rtt;
uint32_t dt; uint32_t dt;
uint32_t send_dt; uint32_t send_dt;
uint32_t recv_time; uint32_t recv_time;
unsigned recv_count;
uint32_t send_time; uint32_t send_time;
unsigned send_count;
struct path *next; struct path *next;
}; };
@@ -339,17 +340,17 @@ ssize_t mud_recv (struct mud *mud, void *data, size_t size)
return -1; return -1;
} }
if (path->count == 256) { if (path->recv_count == 256) {
unsigned char reply[3*4]; unsigned char reply[3*4];
uint32_t dt = (now-path->recv_time)>>8; uint32_t dt = (now-path->recv_time)>>8;
path->count = 0; path->recv_count = 0;
path->recv_time = now; path->recv_time = now;
memset(reply, 0, 4); memset(reply, 0, 4);
memcpy(&reply[4], buf, 4); memcpy(&reply[4], buf, 4);
mud_write32(&reply[8], dt); mud_write32(&reply[8], dt);
mud_send_path(path, reply, sizeof(reply)); mud_send_path(path, reply, sizeof(reply));
} else { } else {
path->count++; path->recv_count++;
} }
memcpy(data, &buf[4], ret-4); memcpy(data, &buf[4], ret-4);
@@ -376,12 +377,12 @@ void mud_flush (struct mud *mud, uint32_t time)
if (ret != packet->size) if (ret != packet->size)
continue; continue;
if (path->count == 256) { if (path->send_count == 256) {
path->count = 0; path->send_count = 0;
path->send_dt = (time-path->send_time)>>8; path->send_dt = (time-path->send_time)>>8;
path->send_time = time; path->send_time = time;
} else { } else {
path->count++; path->send_count++;
} }
} }
} }