diff --git a/core/src/main/java/com/yahoo/ycsb/Client.java b/core/src/main/java/com/yahoo/ycsb/Client.java index 4fc427b07e97b9edd30aded8dd430b65682cb683..94d14ce29b8a25e2174c23d187cb6faae576d1c5 100644 --- a/core/src/main/java/com/yahoo/ycsb/Client.java +++ b/core/src/main/java/com/yahoo/ycsb/Client.java @@ -405,6 +405,14 @@ class ClientThread implements Runnable { this.completeLatch = completeLatch; } + public void setThreadId(final int threadId) { + threadid = threadId; + } + + public void setThreadCount(final int threadCount) { + threadcount = threadCount; + } + public int getOpsDone() { return opsdone; } @@ -877,7 +885,8 @@ public final class Client { ClientThread t = new ClientThread(db, dotransactions, workload, props, threadopcount, targetperthreadperms, completeLatch); - + t.setThreadId(threadid); + t.setThreadCount(threadcount); clients.add(t); }