andi/perfdb
1
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Activity

increase entry buffer

Browse Source
This commit is contained in:
ahr
2017-11-05 08:52:10 +01:00
parent 11b3610971
commit 27db9f934d
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
pdb-ui/src/main/java/org/lucares/pdbui/TcpIngestor.java
View File

@@ -109,6 +109,11 @@ public class TcpIngestor implements Ingestor, AutoCloseable, DisposableBean {
} }
LOGGER.debug("connection closed: " + clientAddress); LOGGER.debug("connection closed: " + clientAddress);
} }
catch (Exception e)
{
LOGGER.warn("Stream handling failed", e);
throw e;
}
return null; return null;
} }
@@ -181,7 +186,7 @@ public class TcpIngestor implements Ingestor, AutoCloseable, DisposableBean {
@Override @Override
public void start() throws Exception { public void start() throws Exception {
final ArrayBlockingQueue<Entry> queue = new ArrayBlockingQueue<>(1); final ArrayBlockingQueue<Entry> queue = new ArrayBlockingQueue<>(100);
serverThreadPool.submit(() -> { serverThreadPool.submit(() -> {
Thread.currentThread().setName("db-ingestion"); Thread.currentThread().setName("db-ingestion");