We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 39d538e + b01d4de commit 43d4344Copy full SHA for 43d4344
1 file changed
lib/microLB/micro_lb/balancer.cpp
@@ -2,7 +2,6 @@
2
#include <net/tcp/stream.hpp>
3
4
#define READQ_PER_CLIENT 4096
5
-#define MAX_READQ_PER_NODE 8192
6
#define READQ_FOR_NODES 8192
7
#define MAX_OUTGOING_ATTEMPTS 100
8
// checking if nodes are dead or not
@@ -155,13 +154,8 @@ namespace microLB
155
154
[this] (auto buf) {
156
// prevent buffer bloat attack
157
this->total += buf->size();
158
- if (this->total > MAX_READQ_PER_NODE) {
159
- this->conn->close();
160
- }
161
- else {
162
- LBOUT("*** Queued %lu bytes\n", buf->size());
163
- readq.push_back(buf);
164
+ LBOUT("*** Queued %lu bytes\n", buf->size());
+ readq.push_back(buf);
165
});
166
}
167
0 commit comments