aboutsummaryrefslogtreecommitdiff
path: root/broadd.c
diff options
context:
space:
mode:
Diffstat (limited to 'broadd.c')
-rw-r--r--broadd.c9
1 files changed, 6 insertions, 3 deletions
diff --git a/broadd.c b/broadd.c
index cef3531..44c162a 100644
--- a/broadd.c
+++ b/broadd.c
@@ -59,7 +59,7 @@
#if 1
// max buffer size
#define UDP_BUFS 1024
- #define TCP_BUFS 8192
+ #define TCP_BUFS 16384
// rate limit: BUFS bytes / RLM seconds
#define RATE_LIMIT_S 1
@@ -72,6 +72,9 @@
// max age for timestamped message
#define DROP_OLD 5
+
+ // set to 0 to enable ratelimit
+ #define DISABLE_RATELIMIT 1
#endif
// ==============================
@@ -865,12 +868,12 @@ int main(int argc, char** argv) {
} else if (buf[ 0 ] == 'M' && rd >= 9) {
// M: broadcast with password
- if (likely(now - clients[ j ].last_rl >= env_rate_limit_s)) {
+ if (likely(now - clients[ j ].last_rl >= env_rate_limit_s) && !DISABLE_RATELIMIT) {
clients[ j ].last_rl = now;
clients[ j ].rl_bytes = 0;
}
int plen = rd - 1;
- if (unlikely(clients[ j ].rl_bytes + plen > env_bufs)) {
+ if (unlikely(clients[ j ].rl_bytes + plen > env_bufs) && !DISABLE_RATELIMIT) {
onlytcp(write(clients[ j ].fd, "Rate\n", 5));
onlyudp(sendto(sock, "Rate\n", 5, 0, (struct sockaddr*) &udp_src, udp_srclen));
} else {