This commit is contained in:
xxDark 2023-07-15 09:10:51 +05:30 committed by GitHub
commit cb1448c3c1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -949,7 +949,6 @@ public class EarlybirdServer implements EarlybirdService.ServiceIface, ServerSet
protected static class EarlybirdThriftRequestLoggingUtil {
private static final int DEFAULT_MAX_ENTRIES_TO_LOG = 50000;
private static final int DEFAULT_BUFFER_SIZE = 10000;
private static final int DEFAULT_LOGGING_SLEEP_MS = 100;
@VisibleForTesting
protected static volatile boolean thriftLoggerBusy = false;
@ -998,13 +997,8 @@ public class EarlybirdServer implements EarlybirdService.ServiceIface, ServerSet
try {
int count = 0;
while (count < maxEntriesToLog) {
if (REQUEST_BUFFER.isEmpty()) {
Thread.sleep(DEFAULT_LOGGING_SLEEP_MS);
continue;
}
try {
EarlybirdRequest ebRequest = REQUEST_BUFFER.poll();
EarlybirdRequest ebRequest = REQUEST_BUFFER.take();
String logLine = serializeThriftObject(ebRequest, serializer);
thriftLogWriter.write(logLine);
count++;